Home | History | Annotate | Download | only in unit

Lines Matching refs:queue

26 static void async_run(struct cds_wfq_queue *queue)
32 	cds_wfq_enqueue(queue, node);
35 static void *async_loop(void *queue)
40 		free(cds_wfq_dequeue_blocking(queue));
47 static void *spawn_jobs(void *queue)
50 		async_run(queue);
60 	struct cds_wfq_queue queue;
64 	cds_wfq_init(&queue);
65 	pthread_create(&consumer, NULL, async_loop, &queue);
68 		pthread_create(&producers[k], NULL, spawn_jobs, &queue);