Задайте функцию, чтобы вызвать, когда новые данные будут получены на DataQueue
listener = afterEach(queue, funtocall)
задает функциональный listener
= afterEach(queue
, funtocall
)funtocall
, чтобы выполниться каждый раз, когда queue
получает новые данные. Можно задать несколько различных функций, чтобы вызвать, потому что каждый вызов afterEach
создает новый прослушиватель на очереди. Если вы хотите задать другую функцию, вызовите afterEach
снова. Чтобы удалить регистрацию функции с queue
, удалите возвращенный объект listener
.
Необходимо вызвать afterEach
в том же процессе, где вы создали очередь данных, в противном случае ошибка происходит. После вызова afterEach
любые текущие данные в очереди сразу отправлены предоставленной функции.
event.listener
| parallel.pool.DataQueue
| parallel.pool.PollableDataQueue
| parfor
| poll
| send