| /external/python/cpython3/Lib/concurrent/futures/ |
| D | process.py | 164 work_item = self.pending_work_items.pop(obj.work_id, None)
167 if work_item is not None:
168 work_item.future.set_exception(e)
269 work_item = pending_work_items[work_id]
271 if work_item.future.set_running_or_notify_cancel():
273 work_item.fn,
274 work_item.args,
275 work_item.kwargs),
385 for work_id, work_item in pending_work_items.items():
386 work_item.future.set_exception(bpe)
[all …]
|
| D | thread.py | 78 work_item = work_queue.get(block=True)
79 if work_item is not None:
80 work_item.run()
82 del work_item
192 work_item = self._work_queue.get_nowait()
195 if work_item is not None:
196 work_item.future.set_exception(BrokenThreadPool(self._broken))
|
| /external/python/futures/concurrent/futures/ |
| D | process.py | 162 work_item = pending_work_items[work_id]
164 if work_item.future.set_running_or_notify_cancel():
166 work_item.fn,
167 work_item.args,
168 work_item.kwargs),
210 work_item = pending_work_items[result_item.work_id]
214 work_item.future.set_exception(result_item.exception)
216 work_item.future.set_result(result_item.result)
218 del work_item
|
| D | thread.py | 73 work_item = work_queue.get(block=True)
74 if work_item is not None:
75 work_item.run()
77 del work_item
|
| /external/deqp-deps/SPIRV-Tools/source/opt/ |
| D | vector_dce.cpp | 178 VectorDCE::WorkListItem work_item, in MarkCompositeContructUsesAsLive() argument
185 Instruction* current_inst = work_item.instruction; in MarkCompositeContructUsesAsLive()
194 if (work_item.components.Get(current_component)) { in MarkCompositeContructUsesAsLive()
208 if (work_item.components.Get(current_component)) { in MarkCompositeContructUsesAsLive()
351 WorkListItem work_item, VectorDCE::LiveComponentMap* live_components, in AddItemToWorkListIfNeeded() argument
353 Instruction* current_inst = work_item.instruction; in AddItemToWorkListIfNeeded()
357 std::make_pair(current_inst->result_id(), work_item.components)); in AddItemToWorkListIfNeeded()
358 work_list->emplace_back(work_item); in AddItemToWorkListIfNeeded()
360 if (it->second.Or(work_item.components)) { in AddItemToWorkListIfNeeded()
361 work_list->emplace_back(work_item); in AddItemToWorkListIfNeeded()
|
| D | vector_dce.h | 99 void AddItemToWorkListIfNeeded(WorkListItem work_item,
137 void MarkCompositeContructUsesAsLive(WorkListItem work_item,
|
| /external/swiftshader/third_party/SPIRV-Tools/source/opt/ |
| D | vector_dce.cpp | 198 VectorDCE::WorkListItem work_item, in MarkCompositeContructUsesAsLive() argument
205 Instruction* current_inst = work_item.instruction; in MarkCompositeContructUsesAsLive()
214 if (work_item.components.Get(current_component)) { in MarkCompositeContructUsesAsLive()
228 if (work_item.components.Get(current_component)) { in MarkCompositeContructUsesAsLive()
381 WorkListItem work_item, VectorDCE::LiveComponentMap* live_components, in AddItemToWorkListIfNeeded() argument
383 Instruction* current_inst = work_item.instruction; in AddItemToWorkListIfNeeded()
387 std::make_pair(current_inst->result_id(), work_item.components)); in AddItemToWorkListIfNeeded()
388 work_list->emplace_back(work_item); in AddItemToWorkListIfNeeded()
390 if (it->second.Or(work_item.components)) { in AddItemToWorkListIfNeeded()
391 work_list->emplace_back(work_item); in AddItemToWorkListIfNeeded()
|
| D | vector_dce.h | 100 void AddItemToWorkListIfNeeded(WorkListItem work_item,
139 void MarkCompositeContructUsesAsLive(WorkListItem work_item,
|
| /external/tensorflow/tensorflow/core/kernels/data/ |
| D | unbounded_thread_pool.cc | 131 WorkItem work_item; in PooledThreadFunc() local
143 work_item = std::move(work_queue_.front()); in PooledThreadFunc()
148 work_item.work_function(); in PooledThreadFunc()
151 work_item.done_notification->Notify(); in PooledThreadFunc()
|
| /external/compiler-rt/test/asan/TestCases/Windows/ |
| D | queue_user_work_item_report.cc | 8 DWORD CALLBACK work_item(LPVOID) { in work_item() function
26 QueueUserWorkItem(&work_item, nullptr, 0); in main()
|
| D | queue_user_work_item.cc | 36 DWORD CALLBACK work_item(LPVOID) { in work_item() function
46 QueueUserWorkItem(&work_item, nullptr, 0); in main()
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | dataset.cc | 453 void BackgroundWorker::Schedule(std::function<void()> work_item) { in Schedule() argument
456 work_queue_.push_back(std::move(work_item)); in Schedule()
463 std::function<void()> work_item = nullptr; in WorkerLoop() local
473 work_item = std::move(work_queue_.front()); in WorkerLoop()
476 DCHECK(work_item != nullptr); in WorkerLoop()
477 work_item(); in WorkerLoop()
|
| D | dataset.h | 930 void Schedule(std::function<void()> work_item);
|
| /external/tensorflow/tensorflow/core/kernels/ |
| D | sparse_matmul_op.cc | 1469 int work_item = cur_create_block_number.fetch_add(1); in Compute() local
1470 if (work_item >= total_num_creation_blocks) break; in Compute()
1473 (transpose_left ? 'T' : 'N'), left_data, entry->output_csr, work_item, in Compute()
1484 int work_item = cur_mult_block_number.fetch_add(1); in Compute() local
1485 if (work_item >= total_num_mult_blocks) break; in Compute()
1492 work_item, i, num_threads); in Compute()
|