| /third_party/boost/boost/statechart/ |
| D | fifo_worker.hpp | 70 typedef function0< void > work_item; typedef in boost::statechart::fifo_worker
75 void queue_work_item( work_item & item ) in queue_work_item()
86 workQueue_.push_back( work_item() ); in queue_work_item()
98 void queue_work_item( const work_item & item ) in queue_work_item()
100 work_item copy = item; in queue_work_item()
106 work_item item = boost::bind( &fifo_worker::terminate_impl, this ); in terminate()
124 work_item item = dequeue_item(); in operator ()()
143 work_item dequeue_item() in dequeue_item()
150 return work_item(); in dequeue_item()
166 return work_item(); in dequeue_item()
[all …]
|
| D | fifo_scheduler.hpp | 35 fifo_scheduler, typename FifoWorker::work_item, Allocator > container;
52 work_item item = in create_processor()
62 work_item item = container_.template create_processor< Processor >( in create_processor()
72 work_item item = container_.template create_processor< Processor >( in create_processor()
82 work_item item = container_.template create_processor< Processor >( in create_processor()
95 work_item item = container_.template create_processor< Processor >( in create_processor()
108 work_item item = container_.template create_processor< Processor >( in create_processor()
121 work_item item = container_.template create_processor< Processor >( in create_processor()
129 work_item item = container_.destroy_processor( processor ); in destroy_processor()
135 work_item item = container_.initiate_processor( processor ); in initiate_processor()
[all …]
|
| /third_party/python/Lib/concurrent/futures/ |
| D | thread.py | 81 work_item = work_queue.get(block=True)
82 if work_item is not None:
83 work_item.run()
85 del work_item
210 work_item = self._work_queue.get_nowait()
213 if work_item is not None:
214 work_item.future.set_exception(BrokenThreadPool(self._broken))
224 work_item = self._work_queue.get_nowait()
227 if work_item is not None:
228 work_item.future.cancel()
|
| D | process.py | 171 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 …]
|
| /third_party/spirv-tools/source/opt/ |
| D | vector_dce.cpp | 201 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()
|
| D | vector_dce.h | 106 void AddItemToWorkListIfNeeded(WorkListItem work_item,
145 void MarkCompositeContructUsesAsLive(WorkListItem work_item,
|
| /third_party/skia/third_party/externals/swiftshader/third_party/SPIRV-Tools/source/opt/ |
| D | vector_dce.cpp | 205 VectorDCE::WorkListItem work_item, in MarkCompositeContructUsesAsLive() argument
211 Instruction* current_inst = work_item.instruction; in MarkCompositeContructUsesAsLive()
220 if (work_item.components.Get(current_component)) { in MarkCompositeContructUsesAsLive()
233 if (work_item.components.Get(current_component)) { in MarkCompositeContructUsesAsLive()
417 WorkListItem work_item, VectorDCE::LiveComponentMap* live_components, in AddItemToWorkListIfNeeded() argument
419 Instruction* current_inst = work_item.instruction; in AddItemToWorkListIfNeeded()
423 std::make_pair(current_inst->result_id(), work_item.components)); in AddItemToWorkListIfNeeded()
424 work_list->emplace_back(work_item); in AddItemToWorkListIfNeeded()
426 if (it->second.Or(work_item.components)) { in AddItemToWorkListIfNeeded()
427 work_list->emplace_back(work_item); in AddItemToWorkListIfNeeded()
|
| D | vector_dce.h | 109 void AddItemToWorkListIfNeeded(WorkListItem work_item,
148 void MarkCompositeContructUsesAsLive(WorkListItem work_item,
|
| /third_party/skia/third_party/externals/spirv-tools/source/opt/ |
| D | vector_dce.cpp | 205 VectorDCE::WorkListItem work_item, in MarkCompositeContructUsesAsLive() argument
211 Instruction* current_inst = work_item.instruction; in MarkCompositeContructUsesAsLive()
220 if (work_item.components.Get(current_component)) { in MarkCompositeContructUsesAsLive()
233 if (work_item.components.Get(current_component)) { in MarkCompositeContructUsesAsLive()
417 WorkListItem work_item, VectorDCE::LiveComponentMap* live_components, in AddItemToWorkListIfNeeded() argument
419 Instruction* current_inst = work_item.instruction; in AddItemToWorkListIfNeeded()
423 std::make_pair(current_inst->result_id(), work_item.components)); in AddItemToWorkListIfNeeded()
424 work_list->emplace_back(work_item); in AddItemToWorkListIfNeeded()
426 if (it->second.Or(work_item.components)) { in AddItemToWorkListIfNeeded()
427 work_list->emplace_back(work_item); in AddItemToWorkListIfNeeded()
|
| D | vector_dce.h | 109 void AddItemToWorkListIfNeeded(WorkListItem work_item,
148 void MarkCompositeContructUsesAsLive(WorkListItem work_item,
|
| /third_party/gstreamer/gstplugins_bad/sys/wasapi2/ |
| D | gstwasapi2client.cpp | 161 auto work_item = Callback<Implements<RuntimeClassFlags<ClassicCom>, in ActivateDeviceAsync() local
188 work_item.Get (), &async_action); in ActivateDeviceAsync()
190 hr = work_item->Invoke (); in ActivateDeviceAsync()
|
| /third_party/gstreamer/gstplugins_bad/sys/mediafoundation/ |
| D | mediacapturewrapper.cpp | 624 auto work_item = Callback<Implements<RuntimeClassFlags<ClassicCom>, in mediaCaptureInitPre() local
691 hr = dispatcher_->RunAsync(CoreDispatcherPriority_Normal, work_item.Get(), in mediaCaptureInitPre()
694 hr = work_item->Invoke (); in mediaCaptureInitPre()
|
| /third_party/gstreamer/gstplugins_base/gst-libs/gst/video/ |
| D | video-converter.c | 149 GstParallelizedWorkItem *work_item; in gst_parallelized_task_thread_func() local
152 work_item = gst_queue_array_pop_head (runner->work_items); in gst_parallelized_task_thread_func()
155 g_assert (work_item != NULL); in gst_parallelized_task_thread_func()
156 g_assert (work_item->func != NULL); in gst_parallelized_task_thread_func()
159 work_item->func (work_item->user_data); in gst_parallelized_task_thread_func()
161 g_free (work_item); in gst_parallelized_task_thread_func()
258 GstParallelizedWorkItem *work_item; in gst_parallelized_task_runner_run() local
261 work_item = g_newa (GstParallelizedWorkItem, 1); in gst_parallelized_task_runner_run()
263 work_item = g_new0 (GstParallelizedWorkItem, 1); in gst_parallelized_task_runner_run()
265 work_item->self = self; in gst_parallelized_task_runner_run()
[all …]
|