| /external/libchrome/base/task/sequence_manager/ |
| work_queue_sets.cc | 18 void WorkQueueSets::AddQueue(WorkQueue* work_queue, size_t set_index) {
19 DCHECK(!work_queue->work_queue_sets());
22 bool has_enqueue_order = work_queue->GetFrontTaskEnqueueOrder(&enqueue_order);
23 work_queue->AssignToWorkQueueSets(this);
24 work_queue->AssignSetIndex(set_index);
27 work_queue_heaps_[set_index].insert({enqueue_order, work_queue});
30 void WorkQueueSets::RemoveQueue(WorkQueue* work_queue) {
31 DCHECK_EQ(this, work_queue->work_queue_sets());
32 work_queue->AssignToWorkQueueSets(nullptr);
33 HeapHandle heap_handle = work_queue->heap_handle()
[all...] |
| work_queue_sets.h | 16 #include "base/task/sequence_manager/work_queue.h"
38 void RemoveQueue(WorkQueue* work_queue);
47 void OnTaskPushedToEmptyQueue(WorkQueue* work_queue);
50 // Assumes |work_queue| contains the lowest enqueue order in the set.
51 void OnPopQueue(WorkQueue* work_queue);
54 void OnQueueBlocked(WorkQueue* work_queue);
|
| work_queue_sets_unittest.cc | 10 #include "base/task/sequence_manager/work_queue.h"
27 for (std::unique_ptr<WorkQueue>& work_queue : work_queues_) {
28 if (work_queue->work_queue_sets())
29 work_queue_sets_->RemoveQueue(work_queue.get());
66 WorkQueue* work_queue = NewTaskQueue("queue"); local
68 work_queue_sets_->ChangeSetIndex(work_queue, set);
70 EXPECT_EQ(set, work_queue->work_queue_set_index());
74 WorkQueue* work_queue = NewTaskQueue("queue"); local
76 work_queue_sets_->ChangeSetIndex(work_queue, set);
84 WorkQueue* work_queue = NewTaskQueue("queue") local
100 WorkQueue* work_queue = NewTaskQueue("queue"); local
111 WorkQueue* work_queue = NewTaskQueue("queue"); local
264 WorkQueue* work_queue = NewTaskQueue("queue"); local
273 WorkQueue* work_queue = NewTaskQueue("queue"); local
[all...] |
| work_queue_unittest.cc | 5 #include "base/task/sequence_manager/work_queue.h"
137 WorkQueue* work_queue; local
138 EXPECT_FALSE(work_queue_sets_->GetOldestQueueInSet(0, &work_queue));
141 EXPECT_TRUE(work_queue_sets_->GetOldestQueueInSet(0, &work_queue));
142 EXPECT_EQ(work_queue_.get(), work_queue);
147 WorkQueue* work_queue; local
148 EXPECT_FALSE(work_queue_sets_->GetOldestQueueInSet(0, &work_queue));
151 EXPECT_FALSE(work_queue_sets_->GetOldestQueueInSet(0, &work_queue));
155 WorkQueue* work_queue; local
156 EXPECT_FALSE(work_queue_sets_->GetOldestQueueInSet(0, &work_queue));
172 WorkQueue* work_queue; local
182 WorkQueue* work_queue; local
195 WorkQueue* work_queue; local
216 WorkQueue* work_queue; local
236 WorkQueue* work_queue; local
254 WorkQueue* work_queue; local
346 WorkQueue* work_queue; local
[all...] |
| sequence_manager_impl.cc | 20 #include "base/task/sequence_manager/work_queue.h"
322 internal::WorkQueue* work_queue = nullptr; local
324 main_thread_only().selector.SelectWorkQueueToService(&work_queue);
327 this, AsValueWithSelectorResult(should_run, work_queue));
333 if (work_queue->RemoveAllCanceledTasksFromFront())
336 if (work_queue->GetFrontTask()->nestable == Nestable::kNonNestable &&
343 work_queue->TakeTaskFromWorkQueue(), work_queue->task_queue(),
344 work_queue->queue_type()};
351 work_queue->TakeTaskFromWorkQueue(), work_queue->task_queue()
[all...] |
| /external/v8/tools/testrunner/local/ |
| pool.py | 55 def Worker(fn, work_queue, done_queue,
64 for args in iter(work_queue.get, "STOP"):
110 # Invariant: processing_count >= #work_queue + #done_queue. It is greater
111 # when a worker takes an item from the work_queue and before the result is
116 # work_queue.
123 self.work_queue = Queue()
155 self.work_queue,
198 self.work_queue.put(gen.next())
212 self.work_queue.put(args)
236 self.work_queue.get(True, 0.1
[all...] |
| /external/python/futures/concurrent/futures/ |
| thread.py | 70 def _worker(executor_reference, work_queue):
73 work_item = work_queue.get(block=True)
86 work_queue.put(None)
|
| /external/libchrome/base/message_loop/ |
| incoming_task_queue.cc | 296 void IncomingTaskQueue::ReloadWorkQueue(TaskQueue* work_queue) {
300 DCHECK(work_queue->empty());
304 incoming_queue_.swap(*work_queue);
305 triage_queue_empty_ = work_queue->empty();
|
| incoming_task_queue.h | 234 // Loads tasks from the |incoming_queue_| into |*work_queue|. Must be called
236 void ReloadWorkQueue(TaskQueue* work_queue);
|
| /external/llvm/utils/ |
| llvm-compilers-check | 255 def __init__(self, work_queue, jobs,
259 self.work_queue = work_queue
274 source, build = self.work_queue.get()
279 self.work_queue.task_done()
595 work_queue = queue.Queue()
611 builder = Builder(work_queue, jobs,
619 work_queue.put((source, build))
621 work_queue.join()
|
| /external/swiftshader/third_party/llvm-7.0/llvm/utils/ |
| llvm-compilers-check | 255 def __init__(self, work_queue, jobs,
259 self.work_queue = work_queue
274 source, build = self.work_queue.get()
279 self.work_queue.task_done()
595 work_queue = queue.Queue()
611 builder = Builder(work_queue, jobs,
619 work_queue.put((source, build))
621 work_queue.join()
|
| /external/python/cpython3/Lib/concurrent/futures/ |
| thread.py | 66 def _worker(executor_reference, work_queue, initializer, initargs):
78 work_item = work_queue.get(block=True)
95 work_queue.put(None)
|
| /external/swiftshader/third_party/LLVM/utils/ |
| llvmbuild | 300 def __init__(self, work_queue, jobs,
304 self.work_queue = work_queue
323 source, branch, build = self.work_queue.get()
328 self.work_queue.task_done()
751 work_queue = queue.Queue()
764 builder = Builder(work_queue, jobs,
774 work_queue.put((source, branch, build))
776 work_queue.put((source, None, build))
778 work_queue.join(
[all...] |
| /external/adhd/cras/src/server/ |
| cras_apm_list.c | 60 * work_queue - A task queue instance created and destroyed by
71 void *work_queue; member in struct:cras_apm
281 apm->work_queue = NULL;
632 rc = webrtc_apm_aec_dump(apm->apm_ptr, &apm->work_queue, start,
638 rc = webrtc_apm_aec_dump(apm->apm_ptr, &apm->work_queue, 0,
|
| /external/adhd/cras/src/tests/ |
| apm_list_unittest.cc | 258 int webrtc_apm_aec_dump(webrtc_apm ptr, void** work_queue,
|
