| /third_party/skia/third_party/externals/swiftshader/third_party/llvm-10.0/llvm/lib/Support/ |
| D | Parallel.cpp | 40 class ThreadPoolExecutor : public Executor { class
42 explicit ThreadPoolExecutor(unsigned ThreadCount = hardware_concurrency()) { in ThreadPoolExecutor() function in llvm::parallel::detail::__anonbc7e59330111::ThreadPoolExecutor
70 ~ThreadPoolExecutor() override { in ~ThreadPoolExecutor()
81 static void call(void *Ptr) { ((ThreadPoolExecutor *)Ptr)->stop(); } in call()
132 static ManagedStatic<ThreadPoolExecutor, object_creator<ThreadPoolExecutor>, in getDefaultExecutor()
133 ThreadPoolExecutor::Deleter> in getDefaultExecutor()
135 static std::unique_ptr<ThreadPoolExecutor> Exec(&(*ManagedExec)); in getDefaultExecutor()
|
| /third_party/python/Lib/concurrent/futures/ |
| D | __init__.py | 41 global ProcessPoolExecutor, ThreadPoolExecutor
49 from .thread import ThreadPoolExecutor as te
50 ThreadPoolExecutor = te
|
| /third_party/grpc/src/python/grpcio_tests/tests/unit/ |
| D | _server_wait_for_termination_test.py | 40 server = grpc.server(futures.ThreadPoolExecutor())
57 server = grpc.server(futures.ThreadPoolExecutor())
75 server = grpc.server(futures.ThreadPoolExecutor())
|
| D | thread_pool.py | 19 class RecordingThreadPool(futures.ThreadPoolExecutor):
23 self._tp_executor = futures.ThreadPoolExecutor(max_workers=max_workers)
|
| D | _server_test.py | 34 grpc.server(futures.ThreadPoolExecutor(max_workers=5),
43 server = grpc.server(futures.ThreadPoolExecutor(max_workers=5))
|
| D | _local_credentials_test.py | 18 from concurrent.futures import ThreadPoolExecutor
32 server = grpc.server(ThreadPoolExecutor())
|
| D | _xds_credentials_test.py | 37 server = grpc.server(futures.ThreadPoolExecutor())
90 server = grpc.server(futures.ThreadPoolExecutor(), xds=True)
|
| D | _channel_args_test.py | 52 grpc.server(futures.ThreadPoolExecutor(max_workers=1),
|
| /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/ejdb/src/bindings/ejdb2_react_native/binding/android/src/main/java/com/softmotions/ejdb2/ |
| D | EJDB2Package.java | 9 import java.util.concurrent.ThreadPoolExecutor;
20 private static final Executor executor = new ThreadPoolExecutor(0, 5, 60L, TimeUnit.SECONDS,
|
| /third_party/grpc/src/python/grpcio_tests/tests_py3_only/unit/ |
| D | _leak_test.py | 26 from concurrent.futures import ThreadPoolExecutor
61 server = grpc.server(ThreadPoolExecutor(max_workers=1),
|
| /third_party/python/Doc/library/ |
| D | concurrent.futures.rst | 18 :class:`ThreadPoolExecutor`, or separate processes, using
37 with ThreadPoolExecutor(max_workers=1) as executor:
65 :class:`ThreadPoolExecutor`, *chunksize* has no effect.
100 with ThreadPoolExecutor(max_workers=4) as e:
110 ThreadPoolExecutor chapter
113 :class:`ThreadPoolExecutor` is an :class:`Executor` subclass that uses a pool of
131 executor = ThreadPoolExecutor(max_workers=2)
143 executor = ThreadPoolExecutor(max_workers=1)
147 .. class:: ThreadPoolExecutor(max_workers=None, thread_name_prefix='', initializer=None, initargs=(…
161 multiplied by ``5``, assuming that :class:`ThreadPoolExecutor` is often
[all …]
|
| /third_party/grpc/examples/python/xds/ |
| D | server.py | 48 futures.ThreadPoolExecutor(max_workers=multiprocessing.cpu_count()))
57 experimental_thread_pool=futures.ThreadPoolExecutor(max_workers=1))
|
| /third_party/grpc/src/python/grpcio_tests/tests/qps/ |
| D | benchmark_client.py | 105 self._pool = futures.ThreadPoolExecutor(
182 self._pool = futures.ThreadPoolExecutor(
215 self._pool = futures.ThreadPoolExecutor(
|
| /third_party/grpc/examples/python/data_transmission/ |
| D | alts_server.py | 29 svr = grpc.server(futures.ThreadPoolExecutor())
|
| D | server.py | 97 server = grpc.server(futures.ThreadPoolExecutor())
|
| /third_party/grpc/examples/python/helloworld/ |
| D | greeter_server.py | 32 server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
|
| D | greeter_server_with_reflection.py | 33 server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
|
| /third_party/grpc/examples/python/interceptors/headers/ |
| D | greeter_server.py | 36 server = grpc.server(futures.ThreadPoolExecutor(max_workers=10),
|
| /third_party/grpc/examples/python/metadata/ |
| D | metadata_server.py | 40 server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
|
| /third_party/grpc/src/python/grpcio/grpc/framework/foundation/ |
| D | logging_pool.py | 72 return _LoggingPool(futures.ThreadPoolExecutor(max_workers))
|
| /third_party/grpc/examples/python/errors/ |
| D | server.py | 64 server = grpc.server(futures.ThreadPoolExecutor())
|
| /third_party/grpc/bazel/test/python_test_repo/ |
| D | helloworld_moved.py | 48 server = grpc.server(futures.ThreadPoolExecutor())
|
| D | helloworld.py | 48 server = grpc.server(futures.ThreadPoolExecutor())
|
| /third_party/grpc/examples/python/debug/ |
| D | debug_server.py | 50 server = grpc.server(futures.ThreadPoolExecutor())
|