| /third_party/boost/libs/thread/test/ |
| D | test_ml2.cpp | 18 std::vector< std::function<void()> > work_queue; in main() local
24 work_queue.push_back( [=] in main()
33 work_queue.push_back(inner); in main()
43 while( !work_queue.empty() ) in main()
46 auto work = work_queue.back(); in main()
49 work = work_queue.back(); in main()
51 work_queue.pop_back(); in main()
|
| /third_party/boost/boost/thread/ |
| D | user_scheduler.hpp | 31 sync_queue<work > work_queue; member in boost::user_scheduler
44 if (work_queue.try_pull(task) == queue_op_status::success) in try_executing_one()
121 work_queue.close(); in close()
129 return work_queue.closed(); in closed()
149 work_queue.push(boost::move(w)); in submit()
156 work_queue.push(boost::move(w)); in submit()
164 work_queue.push(boost::move(w)); in submit()
189 sync_queue<work>::underlying_queue_type q = work_queue.underlying_queue(); in run_queued_closures()
|
| /third_party/boost/boost/thread/executors/ |
| D | loop_executor.hpp | 38 concurrent::sync_queue<work > work_queue; member in boost::executors::loop_executor
66 work_queue.wait_pull(task) : in execute_one()
67 work_queue.try_pull(task); in execute_one()
126 work_queue.close(); in close()
134 return work_queue.closed(); in closed()
149 work_queue.push(boost::move(closure)); in submit()
195 sync_queue<work>::underlying_queue_type q = work_queue.underlying_queue(); in run_queued_closures()
|
| D | serial_executor.hpp | 44 concurrent::sync_queue<work > work_queue; member in boost::executors::serial_executor
80 if (work_queue.try_pull(task) == queue_op_status::success) in try_executing_one()
154 work_queue.close(); in close()
162 return work_queue.closed(); in closed()
178 work_queue.push(boost::move(closure)); in submit()
|
| D | basic_thread_pool.hpp | 42 concurrent::sync_queue<work > work_queue; member in boost::executors::basic_thread_pool
55 if (work_queue.try_pull(task) == queue_op_status::success) in try_executing_one()
93 queue_op_status st = work_queue.wait_pull(task); in worker_thread()
280 work_queue.close(); in close()
288 return work_queue.closed(); in closed()
303 work_queue.push(boost::move(closure)); in submit()
|
| /third_party/gn/src/gn/ |
| D | command_path.cc | 178 WorkQueue work_queue; in BreadthFirstSearch() local
179 work_queue.push_back(initial_stack); in BreadthFirstSearch()
184 while (!work_queue.empty()) { in BreadthFirstSearch()
185 PathVector current_path = work_queue.front(); in BreadthFirstSearch()
186 work_queue.pop_front(); in BreadthFirstSearch()
228 work_queue.push_back(current_path); in BreadthFirstSearch()
229 work_queue.back().push_back(TargetDep(pair.ptr, DepType::PUBLIC)); in BreadthFirstSearch()
235 work_queue.push_back(current_path); in BreadthFirstSearch()
236 work_queue.back().push_back(TargetDep(pair.ptr, DepType::PRIVATE)); in BreadthFirstSearch()
243 work_queue.push_back(current_path); in BreadthFirstSearch()
[all …]
|
| D | header_checker.cc | 542 base::queue<ChainLink> work_queue; in IsDependencyOf() local
543 work_queue.push(ChainLink(search_from, true)); in IsDependencyOf()
546 while (!work_queue.empty()) { in IsDependencyOf()
547 ChainLink cur_link = work_queue.front(); in IsDependencyOf()
549 work_queue.pop(); in IsDependencyOf()
566 work_queue.push(ChainLink(dep.ptr, true)); in IsDependencyOf()
577 work_queue.push(ChainLink(dep.ptr, false)); in IsDependencyOf()
|
| /third_party/boost/boost/graph/distributed/ |
| D | connected_components_parallel_search.hpp | 210 template<typename ComponentMap, typename work_queue>
217 update_reducer(work_queue *q, in update_reducer()
273 work_queue *q;
293 typedef std::queue<vertex_descriptor> work_queue; in connected_components_ps() typedef
312 work_queue q; // this is intentionally a local data structure in connected_components_ps()
313 c.set_reduce(cc_ps_detail::update_reducer<ComponentMap, work_queue>(&q, &collisions, id)); in connected_components_ps()
|
| /third_party/python/Lib/concurrent/futures/ |
| D | thread.py | 69 def _worker(executor_reference, work_queue, initializer, initargs): argument
81 work_item = work_queue.get(block=True)
105 work_queue.put(None)
|
| /third_party/boost/libs/thread/doc/ |
| D | changes.qbk | 125 …om/boostorg/thread/issues/117 #117] loop_executor should block on it's work_queue instead of polli…
|
| /third_party/NuttX/ |
| D | ReleaseNotes | 9792 - work_queue(): Logic that sets the queued indication and the logic
15100 - Work Queues: work_queue() must cancel existing work prior to queuing
15437 calling work_queue on pollwork if it's already queued, just skip a
26702 - Replace the busy polling with work_queue in the ethernet driver of simulator
29659 …* [#4035](https://github.com/apache/incubator-nuttx/pull/#4035) work_queue: schedule the work queu…
|