| /third_party/boost/libs/thread/test/sync/mutual_exclusion/sync_pq/ |
| D | pq_single_thread_pass.cpp | 29 typedef boost::concurrent::sync_priority_queue<int> sync_pq;
158 boost::concurrent::sync_priority_queue<non_copyable> q; in main()
168 boost::concurrent::sync_priority_queue<non_copyable> q; in main()
180 boost::concurrent::sync_priority_queue<int> q; in main()
191 boost::concurrent::sync_priority_queue<int> q; in main()
200 boost::concurrent::sync_priority_queue<non_copyable> q; in main()
209 boost::concurrent::sync_priority_queue<non_copyable> q; in main()
221 boost::concurrent::sync_priority_queue<int> q; in main()
234 boost::concurrent::sync_priority_queue<non_copyable> q; in main()
249 boost::concurrent::sync_priority_queue<int> q; in main()
[all …]
|
| D | tq_single_thread_pass.cpp | 26 typedef boost::concurrent::sync_timed_queue<int> sync_tq;
113 boost::concurrent::sync_timed_queue<boost::function<void()> > tq; in test_deque_times()
134 boost::concurrent::sync_timed_queue<boost::executors::work> tq;
|
| /third_party/libwebsockets/minimal-examples/ws-client/minimal-ws-client-spam/ |
| D | minimal-ws-client-spam.c | 35 static int concurrent = 3, conn, tries, est, errors, closed, sent, limit = 15; variable
88 for (n = 0; n < concurrent; n++) { in callback_minimal_spam()
98 for (n = 0; n < concurrent; n++) { in callback_minimal_spam()
130 for (n = 0; n < concurrent; n++) { in callback_minimal_spam()
138 if (n == concurrent) in callback_minimal_spam()
222 concurrent = atoi(p); in main()
229 if (concurrent < 0 || in main()
230 concurrent > (int)LWS_ARRAY_SIZE(clients)) { in main()
232 concurrent, (int)LWS_ARRAY_SIZE(clients)); in main()
244 info.fd_limit_per_thread = 1 + concurrent + 1; in main()
|
| /third_party/python/Lib/asyncio/ |
| D | futures.py | 7 import concurrent.futures
317 if exc_class is concurrent.futures.CancelledError:
319 elif exc_class is concurrent.futures.TimeoutError:
321 elif exc_class is concurrent.futures.InvalidStateError:
327 def _set_concurrent_future_state(concurrent, source): argument
331 concurrent.cancel()
332 if not concurrent.set_running_or_notify_cancel():
336 concurrent.set_exception(_convert_future_exc(exception))
339 concurrent.set_result(result)
370 concurrent.futures.Future):
[all …]
|
| D | __main__.py | 4 import concurrent.futures
23 future = concurrent.futures.Future()
|
| /third_party/ejdb/src/bindings/ejdb2_react_native/binding/android/src/main/java/com/softmotions/ejdb2/ |
| D | EJDB2Package.java | 7 import java.util.concurrent.Executor;
8 import java.util.concurrent.SynchronousQueue;
9 import java.util.concurrent.ThreadPoolExecutor;
10 import java.util.concurrent.TimeUnit;
|
| /third_party/boost/boost/thread/concurrent_queues/ |
| D | queue_op_status.hpp | 23 namespace concurrent namespace
41 using concurrent::queue_op_status;
42 using concurrent::sync_queue_is_closed;
|
| D | queue_views.hpp | 23 namespace concurrent namespace
133 using concurrent::queue_back_view;
134 using concurrent::queue_front_view;
135 using concurrent::queue_back;
136 using concurrent::queue_front;
|
| D | deque_views.hpp | 23 namespace concurrent namespace
154 using concurrent::deque_back_view;
155 using concurrent::deque_front_view;
156 using concurrent::deque_back;
157 using concurrent::deque_front;
|
| /third_party/python/Doc/library/ |
| D | concurrency.rst | 7 The modules described in this chapter provide support for concurrent
19 concurrent.rst
20 concurrent.futures.rst
|
| D | concurrent.futures.rst | 1 :mod:`concurrent.futures` --- Launching parallel tasks
4 .. module:: concurrent.futures
9 **Source code:** :source:`Lib/concurrent/futures/thread.py`
10 and :source:`Lib/concurrent/futures/process.py`
14 The :mod:`concurrent.futures` module provides a high-level interface for
50 The returned iterator raises a :exc:`concurrent.futures.TimeoutError`
155 pending jobs will raise a :exc:`~concurrent.futures.thread.BrokenThreadPool`,
190 import concurrent.futures
205 with concurrent.futures.ThreadPoolExecutor(max_workers=5) as executor:
208 for future in concurrent.futures.as_completed(future_to_url):
[all …]
|
| D | concurrent.rst | 1 The :mod:`concurrent` package
6 * :mod:`concurrent.futures` -- Launching parallel tasks
|
| /third_party/node/benchmark/fs/ |
| D | readfile.js | 19 concurrent: [1, 10] property
22 function main({ len, duration, concurrent }) { field
60 while (concurrent--) read();
|
| D | readfile-promises.js | 19 concurrent: [1, 10] property
22 function main({ len, duration, concurrent }) { field
62 while (concurrent--) read();
|
| D | readfile-partitioned.js | 22 concurrent: [1, 10] property
25 function main({ len, dur, concurrent }) { field
80 while (concurrent-- > 0) read();
|
| D | writefile-promises.js | 20 concurrent: [1, 10] property
23 function main({ encodingType, duration, concurrent, size }) { property
75 while (concurrent--) write();
|
| /third_party/boost/libs/thread/example/ |
| D | producer_consumer2.cpp | 136 … scoped_thread<> t11(boost::thread(producer, boost::ref(mcerr), concurrent::queue_back<int>(sbq))); in main()
137 … scoped_thread<> t12(boost::thread(producer, boost::ref(mcerr), concurrent::queue_back<int>(sbq))); in main()
138 … scoped_thread<> t2(boost::thread(consumer, boost::ref(mcout), concurrent::queue_front<int>(sbq))); in main()
|
| /third_party/boost/libs/multiprecision/performance/ |
| D | sf_performance.log | 155 [[cpp_bin_float_50 (3 concurrent threads)][2.36703 (0.338848s)][44]]
157 [[cpp_dec_float_50 (3 concurrent threads)][2.86599 (0.410275s)][37]]
159 [[mpf_float_50 (3 concurrent threads)][1.43643 (0.205629s)][3482853]]
161 [[mpf_float_50 (no expression templates (3 concurrent threads)][1.57224 (0.22507s)][4284875]]
163 [[mpfr_float_50 (3 concurrent threads)][1.66446 (0.238272s)][3255603]]
165 [[mpfr_float_50 (no expression templates (3 concurrent threads)][1.86742 (0.267326s)][4008535]]
167 [[static_mpfr_float_50 (3 concurrent threads)][1.25745 (0.180008s)][75947]]
169 [[static_mpfr_float_50 (no expression templates) (3 concurrent threads)][1.12861 (0.161564s)][18919…
194 [[cpp_bin_float_50 (3 concurrent threads)][3.21496 (79.9276s)][29]]
|
| /third_party/nghttp2/doc/bash_completion/ |
| D | nghttp | 11 …able-size --padding --hexdump --max-concurrent-streams --continuation --connection-window-bits --p…
|
| /third_party/ltp/testcases/network/stress/ns-tools/ |
| D | ns-tcpserver.c | 74 int concurrent; /* if non-zero, act as a concurrent server */ member
433 if (info_p->concurrent) in handle_client()
462 if (info_p->concurrent) { /* concurrent server. */ in handle_client()
516 if (info_p->concurrent) in handle_client()
580 server.concurrent = 1; in main()
|
| /third_party/flutter/skia/platform_tools/android/apps/skar_java/src/main/java/com/google/skar/examples/helloskar/helpers/ |
| D | GestureHelper.java | 24 import java.util.concurrent.ArrayBlockingQueue;
25 import java.util.concurrent.BlockingQueue;
|
| /third_party/flutter/flutter/examples/platform_channel_swift/android/app/src/androidTest/java/com/example/platformchannel/ |
| D | ExampleInstrumentedTest.java | 11 import java.util.concurrent.CountDownLatch;
12 import java.util.concurrent.TimeUnit;
|
| /third_party/flutter/flutter/examples/platform_channel/android/app/src/androidTest/java/com/example/platformchannel/ |
| D | ExampleInstrumentedTest.java | 11 import java.util.concurrent.CountDownLatch;
12 import java.util.concurrent.TimeUnit;
|
| /third_party/cef/tools/yapf/yapf/ |
| D | __init__.py | 223 import concurrent.futures # pylint: disable=g-import-not-at-top
225 with concurrent.futures.ProcessPoolExecutor(workers) as executor:
231 for future in concurrent.futures.as_completed(future_formats):
|
| /third_party/protobuf/java/core/src/main/java/com/google/protobuf/ |
| D | Protobuf.java | 36 import java.util.concurrent.ConcurrentHashMap;
37 import java.util.concurrent.ConcurrentMap;
|