Lines Matching refs:queue
25 static void async_run(struct cds_lfs_stack *queue)
31 cds_lfs_push(queue, node);
34 static void *async_loop(void *queue)
39 free(cds_lfs_pop_blocking(queue));
46 static void *spawn_jobs(void *queue)
49 async_run(queue);
59 struct cds_lfs_stack queue;
63 cds_lfs_init(&queue);
64 pthread_create(&consumer, NULL, async_loop, &queue);
67 pthread_create(&producers[k], NULL, spawn_jobs, &queue);
Indexes created Sun Mar 01 05:31:48 UTC 2026