Home
last modified time | relevance | path

Searched refs:work_item (Results 1 – 17 of 17) sorted by relevance

/external/python/cpython3/Lib/concurrent/futures/
Dthread.py75 work_item = work_queue.get(block=True)
76 if work_item is not None:
77 work_item.run()
79 del work_item
204 work_item = self._work_queue.get_nowait()
207 if work_item is not None:
208 work_item.future.set_exception(BrokenThreadPool(self._broken))
218 work_item = self._work_queue.get_nowait()
221 if work_item is not None:
222 work_item.future.cancel()
Dprocess.py171 work_item = self.pending_work_items.pop(obj.work_id, None)
177 if work_item is not None:
178 work_item.future.set_exception(e)
354 work_item = self.pending_work_items[work_id]
356 if work_item.future.set_running_or_notify_cancel():
358 work_item.fn,
359 work_item.args,
360 work_item.kwargs),
412 work_item = self.pending_work_items.pop(result_item.work_id, None)
414 if work_item is not None:
[all …]
/external/python/futures/concurrent/futures/
Dprocess.py162 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
Dthread.py73 work_item = work_queue.get(block=True)
74 if work_item is not None:
75 work_item.run()
77 del work_item
/external/swiftshader/third_party/SPIRV-Tools/source/opt/
Dvector_dce.cpp201 VectorDCE::WorkListItem work_item, in MarkCompositeContructUsesAsLive() argument
208 Instruction* current_inst = work_item.instruction; in MarkCompositeContructUsesAsLive()
217 if (work_item.components.Get(current_component)) { in MarkCompositeContructUsesAsLive()
231 if (work_item.components.Get(current_component)) { in MarkCompositeContructUsesAsLive()
403 WorkListItem work_item, VectorDCE::LiveComponentMap* live_components, in AddItemToWorkListIfNeeded() argument
405 Instruction* current_inst = work_item.instruction; in AddItemToWorkListIfNeeded()
409 std::make_pair(current_inst->result_id(), work_item.components)); in AddItemToWorkListIfNeeded()
410 work_list->emplace_back(work_item); in AddItemToWorkListIfNeeded()
412 if (it->second.Or(work_item.components)) { in AddItemToWorkListIfNeeded()
413 work_list->emplace_back(work_item); in AddItemToWorkListIfNeeded()
Dvector_dce.h106 void AddItemToWorkListIfNeeded(WorkListItem work_item,
145 void MarkCompositeContructUsesAsLive(WorkListItem work_item,
/external/angle/third_party/vulkan-deps/spirv-tools/src/source/opt/
Dvector_dce.cpp201 VectorDCE::WorkListItem work_item, in MarkCompositeContructUsesAsLive() argument
208 Instruction* current_inst = work_item.instruction; in MarkCompositeContructUsesAsLive()
217 if (work_item.components.Get(current_component)) { in MarkCompositeContructUsesAsLive()
231 if (work_item.components.Get(current_component)) { in MarkCompositeContructUsesAsLive()
403 WorkListItem work_item, VectorDCE::LiveComponentMap* live_components, in AddItemToWorkListIfNeeded() argument
405 Instruction* current_inst = work_item.instruction; in AddItemToWorkListIfNeeded()
409 std::make_pair(current_inst->result_id(), work_item.components)); in AddItemToWorkListIfNeeded()
410 work_list->emplace_back(work_item); in AddItemToWorkListIfNeeded()
412 if (it->second.Or(work_item.components)) { in AddItemToWorkListIfNeeded()
413 work_list->emplace_back(work_item); in AddItemToWorkListIfNeeded()
Dvector_dce.h106 void AddItemToWorkListIfNeeded(WorkListItem work_item,
145 void MarkCompositeContructUsesAsLive(WorkListItem work_item,
/external/deqp-deps/SPIRV-Tools/source/opt/
Dvector_dce.cpp201 VectorDCE::WorkListItem work_item, in MarkCompositeContructUsesAsLive() argument
208 Instruction* current_inst = work_item.instruction; in MarkCompositeContructUsesAsLive()
217 if (work_item.components.Get(current_component)) { in MarkCompositeContructUsesAsLive()
231 if (work_item.components.Get(current_component)) { in MarkCompositeContructUsesAsLive()
403 WorkListItem work_item, VectorDCE::LiveComponentMap* live_components, in AddItemToWorkListIfNeeded() argument
405 Instruction* current_inst = work_item.instruction; in AddItemToWorkListIfNeeded()
409 std::make_pair(current_inst->result_id(), work_item.components)); in AddItemToWorkListIfNeeded()
410 work_list->emplace_back(work_item); in AddItemToWorkListIfNeeded()
412 if (it->second.Or(work_item.components)) { in AddItemToWorkListIfNeeded()
413 work_list->emplace_back(work_item); in AddItemToWorkListIfNeeded()
Dvector_dce.h106 void AddItemToWorkListIfNeeded(WorkListItem work_item,
145 void MarkCompositeContructUsesAsLive(WorkListItem work_item,
/external/compiler-rt/test/asan/TestCases/Windows/
Dqueue_user_work_item_report.cc8 DWORD CALLBACK work_item(LPVOID) { in work_item() function
26 QueueUserWorkItem(&work_item, nullptr, 0); in main()
Dqueue_user_work_item.cc36 DWORD CALLBACK work_item(LPVOID) { in work_item() function
46 QueueUserWorkItem(&work_item, nullptr, 0); in main()
/external/llvm-project/compiler-rt/test/asan/TestCases/Windows/
Dqueue_user_work_item_report.cpp8 DWORD CALLBACK work_item(LPVOID) { in work_item() function
24 QueueUserWorkItem(&work_item, nullptr, 0); in main()
Dqueue_user_work_item.cpp31 DWORD CALLBACK work_item(LPVOID) { in work_item() function
41 QueueUserWorkItem(&work_item, nullptr, 0); in main()
/external/tensorflow/tensorflow/core/framework/
Ddataset.cc714 void BackgroundWorker::Schedule(std::function<void()> work_item) { in Schedule() argument
721 work_queue_.push_back(std::move(work_item)); in Schedule()
729 std::function<void()> work_item = nullptr; in WorkerLoop() local
739 work_item = std::move(work_queue_.front()); in WorkerLoop()
742 DCHECK(work_item != nullptr); in WorkerLoop()
743 work_item(); in WorkerLoop()
Ddataset.h1219 void Schedule(std::function<void()> work_item);
/external/tensorflow/tensorflow/core/kernels/
Dsparse_matmul_op.cc1466 int work_item = cur_create_block_number.fetch_add(1); in Compute() local
1467 if (work_item >= total_num_creation_blocks) break; in Compute()
1470 (transpose_left ? 'T' : 'N'), left_data, entry->output_csr, work_item, in Compute()
1481 int work_item = cur_mult_block_number.fetch_add(1); in Compute() local
1482 if (work_item >= total_num_mult_blocks) break; in Compute()
1489 work_item, i, num_threads); in Compute()