| /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 …]
|
| /third_party/libwebsockets/minimal-examples/ws-client/minimal-ws-client-spam/ |
| D | minimal-ws-client-spam.c | 41 static int concurrent = 3, conn, tries, est, errors, closed, sent, limit = 15; variable
95 for (n = 0; n < concurrent; n++) { in callback_minimal_spam()
105 for (n = 0; n < concurrent; n++) { in callback_minimal_spam()
141 for (n = 0; n < concurrent; n++) { in callback_minimal_spam()
149 if (n == concurrent) in callback_minimal_spam()
241 concurrent = atoi(p); in main()
248 if (concurrent < 0 || in main()
249 concurrent > (int)LWS_ARRAY_SIZE(clients)) { in main()
251 concurrent, (int)LWS_ARRAY_SIZE(clients)); in main()
263 info.fd_limit_per_thread = (unsigned int)(1 + concurrent + 1); in main()
|
| /third_party/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-cpp/ |
| D | main.cxx | 17 static int interrupted, bad = 1, concurrent = 1, completed; variable
31 if (++completed == concurrent) { in lss_completion()
57 concurrent = atoi(p); in main()
59 if (concurrent > 12) in main()
60 concurrent = 12; in main()
79 for (int n = 0; n < concurrent; n++) { in main()
|
| /third_party/benchmark/test/ |
| D | benchmark_setup_teardown_test.cc | 43 namespace concurrent { namespace
50 concurrent::setup_call.fetch_add(1, std::memory_order_acquire); in DoSetup2()
55 concurrent::teardown_call.fetch_add(1, std::memory_order_acquire); in DoTeardown2()
62 concurrent::func_call.fetch_add(1, std::memory_order_acquire); in BM_concurrent()
141 assert(concurrent::setup_call.load(std::memory_order_relaxed) == 3); in main()
142 assert(concurrent::teardown_call.load(std::memory_order_relaxed) == 3); in main()
144 concurrent::func_call.load(std::memory_order_relaxed)); 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 …]
|
| /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/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 | writefile-promises.js | 20 concurrent: [1, 10] property
23 function main({ encodingType, duration, concurrent, size }) { property
75 while (concurrent--) write();
|
| D | readfile-partitioned.js | 22 concurrent: [1, 10] property
25 function main({ len, dur, concurrent }) { field
80 while (concurrent-- > 0) read();
|
| /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/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-stress/ |
| D | README.md | 3 This is the same as minimal-secure-streams, except you can have it perform concurrent
6 It basically forks as many times as `-c <concurrent>` and each fork does `--budget <count>`
20 -c <concurrent>|Fork this many times on init|
|
| D | minimal-secure-streams.c | 559 int n = 0, expected = 0, concurrent = 1; in main() local
569 concurrent = atoi(p); in main()
571 if (concurrent < 0 || concurrent > 100) in main()
579 for (n = 0; n < concurrent - 1; n++) { 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/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/libphonenumber/java/libphonenumber/test/com/google/i18n/phonenumbers/metadata/source/ |
| D | BlockingMetadataBootstrappingGuardTest.java | 32 import java.util.concurrent.Callable;
33 import java.util.concurrent.ExecutorService;
34 import java.util.concurrent.Executors;
|
| /third_party/python/Lib/test/test_importlib/partial/ |
| D | cfimport.py | 13 from concurrent.futures import ThreadPoolExecutor
20 from concurrent.futures.thread import ThreadPoolExecutor
|
| /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/nghttp2/doc/bash_completion/ |
| D | nghttp | 11 …able-size --padding --hexdump --max-concurrent-streams --continuation --connection-window-bits --p…
|
| /third_party/libphonenumber/java/libphonenumber/src/com/google/i18n/phonenumbers/metadata/source/ |
| D | MapBackedMetadataContainer.java | 20 import java.util.concurrent.ConcurrentHashMap;
21 import java.util.concurrent.ConcurrentMap;
|