| /third_party/flutter/engine/flutter/fml/ |
| D | message_loop_task_queues_merge_unmerge_unittests.cc | 28 auto task_queue = fml::MessageLoopTaskQueues::GetInstance(); in TEST() local
30 auto queue_id_1 = task_queue->CreateTaskQueue(); in TEST()
31 auto queue_id_2 = task_queue->CreateTaskQueue(); in TEST()
33 task_queue->RegisterTask( in TEST()
35 ASSERT_EQ(1u, task_queue->GetNumPendingTasks(queue_id_1)); in TEST()
37 task_queue->Merge(queue_id_1, queue_id_2); in TEST()
38 task_queue->RegisterTask( in TEST()
41 ASSERT_EQ(2u, task_queue->GetNumPendingTasks(queue_id_1)); in TEST()
42 ASSERT_EQ(0u, task_queue->GetNumPendingTasks(queue_id_2)); in TEST()
47 auto task_queue = fml::MessageLoopTaskQueues::GetInstance(); in TEST() local
[all …]
|
| D | message_loop_task_queues_unittests.cc | 27 auto task_queue = fml::MessageLoopTaskQueues::GetInstance(); in TEST() local
28 auto queue_id = task_queue->CreateTaskQueue(); in TEST()
29 ASSERT_FALSE(task_queue->HasPendingTasks(queue_id)); in TEST()
35 auto task_queue = fml::MessageLoopTaskQueues::GetInstance(); in TEST() local
36 auto queue_id = task_queue->CreateTaskQueue(); in TEST()
37 task_queue->SetWakeable(queue_id, in TEST()
42 task_queue->RegisterTask( in TEST()
44 ASSERT_TRUE(task_queue->HasPendingTasks(queue_id)); in TEST()
45 ASSERT_TRUE(task_queue->GetNumPendingTasks(queue_id) == 1); in TEST()
49 auto task_queue = fml::MessageLoopTaskQueues::GetInstance(); in TEST() local
[all …]
|
| D | message_loop_task_queues_benchmark.cc | 18 auto task_queue = fml::MessageLoopTaskQueues::GetInstance(); in BM_RegisterAndGetTasks() local
25 task_queue->CreateTaskQueue(); in BM_RegisterAndGetTasks()
34 threads.emplace_back([task_runner_id = i, &task_queue, past, &tasks_done, in BM_RegisterAndGetTasks()
37 task_queue->RegisterTask( in BM_RegisterAndGetTasks()
43 task_queue->GetTasksToRunNow(TaskQueueId(task_runner_id), in BM_RegisterAndGetTasks()
|
| /third_party/python/Doc/includes/ |
| D | mp_workers.py | 46 task_queue = Queue()
51 task_queue.put(task)
55 Process(target=worker, args=(task_queue, done_queue)).start()
64 task_queue.put(task)
72 task_queue.put('STOP')
|
| /third_party/libabigail/tests/ |
| D | test-types-stability.cc | 122 queue task_queue(num_workers); in main() local
130 ABG_ASSERT(task_queue.schedule_task(t)); in main()
133 ABG_ASSERT(task_queue.schedule_task(t)); in main()
137 task_queue.wait_for_workers_to_complete(); in main()
143 task_queue.get_completed_tasks(); in main()
|
| D | test-diff-filter.cc | 936 queue task_queue(num_workers); in main() local
943 ABG_ASSERT(task_queue.schedule_task(t)); in main()
947 task_queue.wait_for_workers_to_complete(); in main()
953 task_queue.get_completed_tasks(); in main()
|
| D | test-read-common.cc | 224 abigail::workers::queue task_queue(num_workers); in run_tests() local
236 ABG_ASSERT(task_queue.schedule_task(t)); in run_tests()
240 task_queue.wait_for_workers_to_complete(); in run_tests()
246 task_queue.get_completed_tasks(); in run_tests()
|
| D | test-read-write.cc | 359 queue task_queue(num_workers); in main() local
368 ABG_ASSERT(task_queue.schedule_task(t)); in main()
372 task_queue.wait_for_workers_to_complete(); in main()
378 task_queue.get_completed_tasks(); in main()
|
| D | test-diff-suppr.cc | 2183 abigail::workers::queue task_queue(num_workers); in main() local
2205 ABG_ASSERT(task_queue.schedule_task(t)); in main()
2209 task_queue.wait_for_workers_to_complete(); in main()
2213 task_queue.get_completed_tasks(); in main()
|
| D | test-diff-pkg.cc | 1263 queue task_queue(num_workers); in main() local
1270 ABG_ASSERT(task_queue.schedule_task(t)); in main()
1274 task_queue.wait_for_workers_to_complete(); in main()
1280 task_queue.get_completed_tasks(); in main()
|
| /third_party/node/src/ |
| D | node_task_queue.cc | 90 namespace task_queue { namespace
150 NODE_MODULE_CONTEXT_AWARE_INTERNAL(task_queue, node::task_queue::Initialize)
|
| D | node_platform.cc | 20 TaskQueue<Task>* task_queue; member
31 TaskQueue<Task>* pending_worker_tasks = worker_data->task_queue; in PlatformWorkerThread()
|
| D | node_binding.cc | 75 V(task_queue) \
|
| /third_party/ffmpeg/libavfilter/dnn/ |
| D | dnn_backend_openvino.c | 59 Queue *task_queue; // holds TaskItem member
375 ov_model->task_queue = ff_queue_create(); in init_model_ov()
376 if (!ov_model->task_queue) { in init_model_ov()
702 if (ff_queue_push_back(ov_model->task_queue, task) < 0) { in ff_dnn_execute_model_async_ov()
721 TaskItem *task = ff_queue_peek_front(ov_model->task_queue); in ff_dnn_get_async_result_ov()
733 ff_queue_pop_front(ov_model->task_queue); in ff_dnn_get_async_result_ov()
795 while (ff_queue_size(ov_model->task_queue) != 0) { in ff_dnn_free_model_ov()
796 TaskItem *item = ff_queue_pop_front(ov_model->task_queue); in ff_dnn_free_model_ov()
801 ff_queue_destroy(ov_model->task_queue); in ff_dnn_free_model_ov()
|
| /third_party/python/Doc/library/ |
| D | graphlib.rst | 71 # 'task_queue' queue.
72 task_queue.put(node)
77 # least one node has been placed on 'task_queue' that hasn't yet
80 # again, so put newly freed nodes on 'task_queue' as soon as
|
| /third_party/chromium/patch/ |
| D | 0003-ohos-1115.patch | 48097 #include "components/offline_pages/task/task_queue.h"
|