Home
last modified time | relevance | path

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

/external/python/cpython3/Lib/concurrent/futures/
Dprocess.py171 work_item = self.pending_work_items.pop(obj.work_id, None)
174 if work_item is not None:
175 work_item.future.set_exception(e)
277 work_item = pending_work_items[work_id]
279 if work_item.future.set_running_or_notify_cancel():
281 work_item.fn,
282 work_item.args,
283 work_item.kwargs),
393 for work_id, work_item in pending_work_items.items():
394 work_item.future.set_exception(bpe)
[all …]
Dthread.py78 work_item = work_queue.get(block=True)
79 if work_item is not None:
80 work_item.run()
82 del work_item
224 work_item = self._work_queue.get_nowait()
227 if work_item is not None:
228 work_item.future.set_exception(BrokenThreadPool(self._broken))
/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/angle/third_party/spirv-tools/src/source/opt/
Dvector_dce.cpp198 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()
Dvector_dce.h100 void AddItemToWorkListIfNeeded(WorkListItem work_item,
139 void MarkCompositeContructUsesAsLive(WorkListItem work_item,
/external/deqp-deps/SPIRV-Tools/source/opt/
Dvector_dce.cpp198 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()
Dvector_dce.h100 void AddItemToWorkListIfNeeded(WorkListItem work_item,
139 void MarkCompositeContructUsesAsLive(WorkListItem work_item,
/external/swiftshader/third_party/SPIRV-Tools/source/opt/
Dvector_dce.cpp198 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()
Dvector_dce.h100 void AddItemToWorkListIfNeeded(WorkListItem work_item,
139 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/OpenCL-CTS/test_conformance/clcpp/pipes/
Dtest_pipes.hpp39 work_item, enumerator
89 if (options.operation == pipe_operation::work_item) in generate_source()
258 if (options.operation == pipe_operation::work_item) in generate_source()
556 pipe_operation::work_item,
/external/tensorflow/tensorflow/core/framework/
Ddataset.cc498 void BackgroundWorker::Schedule(std::function<void()> work_item) { in Schedule() argument
505 work_queue_.push_back(std::move(work_item)); in Schedule()
512 std::function<void()> work_item = nullptr; in WorkerLoop() local
522 work_item = std::move(work_queue_.front()); in WorkerLoop()
525 DCHECK(work_item != nullptr); in WorkerLoop()
526 work_item(); in WorkerLoop()
Ddataset.h1147 void Schedule(std::function<void()> work_item);
/external/v8/src/heap/
Dscavenger.cc225 auto& work_item = memory_chunks_[i]; in ConcurrentScavengePages() local
226 if (!work_item.first.TryAcquire()) break; in ConcurrentScavengePages()
227 scavenger->ScavengePage(work_item.second); in ConcurrentScavengePages()
Dmark-compact.cc3130 auto& work_item = evacuation_items_[i]; in ProcessItems() local
3131 if (!work_item.first.TryAcquire()) break; in ProcessItems()
3132 evacuator->EvacuatePage(work_item.second); in ProcessItems()
3504 auto& work_item = updating_items_[i]; in UpdatePointers() local
3505 if (!work_item->TryAcquire()) break; in UpdatePointers()
3506 work_item->Process(); in UpdatePointers()
4910 auto& work_item = marking_items_[i]; in ProcessMarkingItems() local
4911 if (!work_item.TryAcquire()) break; in ProcessMarkingItems()
4912 work_item.Process(task); in ProcessMarkingItems()
/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()