in threads.c [78:85]
void enqueue_and_wake_all(struct ncrx_listener *listener) { int i; for (i = 0; i < listener->nr_workers; i++) if (!prequeue_is_empty(listener, i)) enqueue_and_wake_worker(listener, i); }