Searched refs:work_queue (Results 1 – 4 of 4) sorted by relevance
50 fixed_queue_t* work_queue; member79 ret->work_queue = fixed_queue_new(work_queue_capacity); in thread_new_sized()80 if (!ret->work_queue) goto error; in thread_new_sized()100 fixed_queue_free(ret->work_queue, osi_free); in thread_new_sized()117 fixed_queue_free(thread->work_queue, osi_free); in thread_free()142 fixed_queue_enqueue(thread->work_queue, item); in thread_post()215 int fd = fixed_queue_get_dequeue_fd(thread->work_queue); in run_thread()216 void* context = thread->work_queue; in run_thread()228 static_cast<work_item_t*>(fixed_queue_try_dequeue(thread->work_queue)); in run_thread()229 while (item && count <= fixed_queue_capacity(thread->work_queue)) { in run_thread()[all …]
70 num_work_items = thread->work_queue.size(); in run_message_loop()77 work_item = thread->work_queue.front(); in run_message_loop()78 thread->work_queue.pop(); in run_message_loop()91 num_work_items = thread->work_queue.size(); in run_message_loop()97 work_item = thread->work_queue.front(); in run_message_loop()98 thread->work_queue.pop(); in run_message_loop()
83 std::queue<work_item> work_queue;
77 thread->work_queue.push(std::make_pair(func, context)); in SetUp()85 thread->work_queue = {}; in SetUp()