OpenGrok

25 struct queue {
30 static void async_run(struct queue *queue)
36 	cds_wfcq_enqueue(&queue->head, &queue->tail, node);
38 static void do_async_loop(size_t *k, struct queue *queue)
40 	struct queue my_queue;
48 					&queue->head,
49 					&queue->tail);
63 static void *async_loop(void *queue)
69 		do_async_loop(&k, queue);
75 static void *spawn_jobs(void *queue)
78 		async_run(queue);
88 	struct queue queue;
92 	cds_wfcq_init(&queue.head, &queue.tail);
93 	pthread_create(&consumer, NULL, async_loop, &queue);
96 		pthread_create(&producers[k], NULL, spawn_jobs, &queue);

Indexes created Sun Mar 01 05:31:48 UTC 2026