Home
last modified time | relevance | path

Searched refs:concurrent (Results 1 – 25 of 308) sorted by relevance

12345678910>>...13

/third_party/libwebsockets/minimal-examples/ws-client/minimal-ws-client-spam/
Dminimal-ws-client-spam.c41 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/
Dmain.cxx17 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/python/Lib/asyncio/
Dfutures.py7 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__.py4 import concurrent.futures
23 future = concurrent.futures.Future()
/third_party/benchmark/test/
Dbenchmark_setup_teardown_test.cc43 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/Doc/library/
Dconcurrent.futures.rst1 :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 …]
Dconcurrency.rst7 The modules described in this chapter provide support for concurrent
19 concurrent.rst
20 concurrent.futures.rst
Dconcurrent.rst1 The :mod:`concurrent` package
6 * :mod:`concurrent.futures` -- Launching parallel tasks
Dasyncio-future.rst70 Wrap a :class:`concurrent.futures.Future` object in a
257 :class:`concurrent.futures.Future`. Key differences include:
259 - unlike asyncio Futures, :class:`concurrent.futures.Future`
274 :func:`concurrent.futures.wait` and
275 :func:`concurrent.futures.as_completed` functions.
278 but :func:`concurrent.futures.cancel` does not.
/third_party/node/benchmark/fs/
Dreadfile.js20 concurrent: [1, 10], property
23 function main({ len, duration, concurrent, encoding }) { property
69 while (concurrent--) read();
Dreadfile-promises.js27 concurrent: [1, 10], property
30 function main({ len, duration, concurrent, encoding }) { property
78 while (concurrent--) read();
Dreadfile-partitioned.js23 concurrent: [1, 10], property
26 function main({ len, duration, concurrent, encoding }) { property
89 while (concurrent-- > 0) read();
Dwritefile-promises.js20 concurrent: [1, 10], property
23 function main({ encodingType, duration, concurrent, size }) { property
79 while (concurrent--) write();
/third_party/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-stress/
DREADME.md3 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|
Dminimal-secure-streams.c559 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/libphonenumber/java/libphonenumber/test/com/google/i18n/phonenumbers/metadata/source/
DBlockingMetadataBootstrappingGuardTest.java32 import java.util.concurrent.Callable;
33 import java.util.concurrent.ExecutorService;
34 import java.util.concurrent.Executors;
/third_party/ltp/testcases/network/stress/ns-tools/
Dns-tcpserver.c74 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/python/Lib/test/test_importlib/partial/
Dcfimport.py13 from concurrent.futures import ThreadPoolExecutor
20 from concurrent.futures.thread import ThreadPoolExecutor
/third_party/node/deps/v8/include/cppgc/
DREADME.md9 - Incremental and concurrent marking;
10 - Incremental and concurrent sweeping;
14 - Non-incremental and non-concurrent compaction for selected spaces;
56 ## Atomic, incremental and concurrent garbage collection
75 Using concurrent GC allows the mutator thread to spend less time on GC and more on the actual mutat…
90 With incremental/concurrent marking, step 1 is executed in a short pause after which the mutator re…
122 With incremental/concurrent sweeping, step 2 is interleaved with mutator.
123 Incremental/concurrent sweeping can be atomically finalized in case it is needed to trigger another…
124 Even with concurrent sweeping, destructors are guaranteed to run on the thread the object has been …
/third_party/libphonenumber/java/libphonenumber/src/com/google/i18n/phonenumbers/metadata/source/
DMapBackedMetadataContainer.java20 import java.util.concurrent.ConcurrentHashMap;
21 import java.util.concurrent.ConcurrentMap;
/third_party/nghttp2/doc/bash_completion/
Dnghttp11concurrent-streams --header-table-size --encoder-header-table-size --padding --har --color --conti…
/third_party/cef/tools/yapf/yapf/
D__init__.py223 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/nghttp2/doc/sources/
Dh2load-howto.rst28 The number of concurrent clients. Default: 1
31 The max concurrent streams to issue per client. Default: 1
41 using total 100000 requests, 100 concurrent clients and 10 max
42 concurrent streams:
/third_party/skia/platform_tools/android/apps/skottie/skottielib/src/main/java/org/skia/skottie/
DSkottieRunner.java20 import java.util.concurrent.CountDownLatch;
21 import java.util.concurrent.TimeUnit;
22 import java.util.concurrent.TimeoutException;
/third_party/protobuf/java/core/src/main/java/com/google/protobuf/
DProtobuf.java36 import java.util.concurrent.ConcurrentHashMap;
37 import java.util.concurrent.ConcurrentMap;

12345678910>>...13