Home
last modified time | relevance | path

Searched refs:max_workers (Results 1 – 25 of 43) sorted by relevance

12

/external/grpc-grpc/src/python/grpcio_tests/tests/unit/
D_thread_pool.py22 def __init__(self, max_workers): argument
23 self._tp_executor = futures.ThreadPoolExecutor(max_workers=max_workers)
Dtest_common.py102 def test_server(max_workers=10): argument
108 futures.ThreadPoolExecutor(max_workers=max_workers),
D_server_test.py32 futures.ThreadPoolExecutor(max_workers=5),
41 server = grpc.server(futures.ThreadPoolExecutor(max_workers=5))
D_channel_connectivity_test.py85 thread_pool = _thread_pool.RecordingThreadPool(max_workers=None)
127 thread_pool = _thread_pool.RecordingThreadPool(max_workers=None)
D_channel_args_test.py44 futures.ThreadPoolExecutor(max_workers=1),
D_channel_ready_future_test.py63 thread_pool = _thread_pool.RecordingThreadPool(max_workers=None)
/external/python/futures/concurrent/futures/
Dthread.py98 def __init__(self, max_workers=None, thread_name_prefix=''): argument
106 if max_workers is None:
109 max_workers = (cpu_count() or 1) * 5
110 if max_workers <= 0:
113 self._max_workers = max_workers
Dprocess.py267 def __init__(self, max_workers=None): argument
277 if max_workers is None:
280 if max_workers <= 0:
283 self._max_workers = max_workers
/external/python/cpython3/Lib/concurrent/futures/
Dthread.py117 def __init__(self, max_workers=None, thread_name_prefix='', argument
128 if max_workers is None:
136 max_workers = min(32, (os.cpu_count() or 1) + 4)
137 if max_workers <= 0:
143 self._max_workers = max_workers
Dprocess.py573 def __init__(self, max_workers=None, mp_context=None, argument
588 if max_workers is None:
594 if max_workers <= 0:
597 max_workers > _MAX_WINDOWS_WORKERS):
601 self._max_workers = max_workers
/external/grpc-grpc/src/python/grpcio/grpc/framework/foundation/
Dlogging_pool.py62 def pool(max_workers): argument
72 return _LoggingPool(futures.ThreadPoolExecutor(max_workers))
/external/python/cpython3/Doc/library/
Dconcurrent.futures.rst37 with ThreadPoolExecutor(max_workers=1) as executor:
100 with ThreadPoolExecutor(max_workers=4) as e:
131 executor = ThreadPoolExecutor(max_workers=2)
143 executor = ThreadPoolExecutor(max_workers=1)
147 .. class:: ThreadPoolExecutor(max_workers=None, thread_name_prefix='', initializer=None, initargs=(…
149 An :class:`Executor` subclass that uses a pool of at most *max_workers*
159 If *max_workers* is ``None`` or
175 Default value of *max_workers* is changed to ``min(32, os.cpu_count() + 4)``.
181 *max_workers* worker threads too.
205 with concurrent.futures.ThreadPoolExecutor(max_workers=5) as executor:
[all …]
/external/python/futures/docs/
Dindex.rst29 with ThreadPoolExecutor(max_workers=1) as executor:
66 with ThreadPoolExecutor(max_workers=4) as e:
96 executor = ThreadPoolExecutor(max_workers=2)
110 executor = ThreadPoolExecutor(max_workers=1)
113 .. class:: ThreadPoolExecutor(max_workers)
115 Executes calls asynchronously using a pool of at most *max_workers* threads.
135 with futures.ThreadPoolExecutor(max_workers=5) as executor:
159 .. class:: ProcessPoolExecutor(max_workers=None)
161 Executes calls asynchronously using a pool of at most *max_workers*
162 processes. If *max_workers* is ``None`` or not given then as many worker
/external/python/cpython3/Lib/test/
Dtest_concurrent_futures.py121 max_workers=self.worker_count,
126 max_workers=self.worker_count,
347 executor = self.executor_type(max_workers=3)
409 with futures.ThreadPoolExecutor(max_workers=5) as e:
418 executor = futures.ThreadPoolExecutor(max_workers=5)
433 executor = futures.ThreadPoolExecutor(max_workers=5)
447 max_workers=5, thread_name_prefix='SpecialPool')
457 executor = futures.ThreadPoolExecutor(max_workers=5)
507 with futures.ProcessPoolExecutor(max_workers=5) as e:
516 executor = futures.ProcessPoolExecutor(max_workers=5)
[all …]
/external/python/futures/
Dtest_futures.py142 self.executor = self.executor_type(max_workers=self.worker_count)
215 with futures.ThreadPoolExecutor(max_workers=5) as e:
224 executor = futures.ThreadPoolExecutor(max_workers=5)
235 max_workers=5, thread_name_prefix='SpecialPool')
246 executor = futures.ThreadPoolExecutor(max_workers=5)
275 with futures.ProcessPoolExecutor(max_workers=5) as e:
284 executor = futures.ProcessPoolExecutor(max_workers=5)
511 self.executor_type(max_workers=number)
/external/ltp/testcases/kernel/fs/read_all/
Dread_all.c80 static long max_workers = 15; variable
370 if (tst_parse_long(str_max_workers, &max_workers, 1, LONG_MAX)) { in setup()
386 worker_count = MIN(MAX(tst_ncpus() - 1, 1), max_workers); in setup()
/external/grpc-grpc/examples/python/helloworld/
Dgreeter_server.py34 server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
Dgreeter_server_with_reflection.py35 server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
/external/grpc-grpc/examples/python/interceptors/headers/
Dgreeter_server.py39 futures.ThreadPoolExecutor(max_workers=10),
/external/grpc-grpc/src/python/grpcio_tests/tests/qps/
Dbenchmark_client.py102 max_workers=config.outstanding_rpcs_per_channel)
179 max_workers=config.outstanding_rpcs_per_channel)
/external/oss-fuzz/infra/build/functions/
Dupdate_build_status.py178 with concurrent.futures.ThreadPoolExecutor(max_workers=8) as executor:
291 with concurrent.futures.ThreadPoolExecutor(max_workers=32) as executor:
/external/grpc-grpc/src/python/grpcio/grpc/
D_auth.py45 self._pool = futures.ThreadPoolExecutor(max_workers=1)
/external/llvm-project/llvm/utils/
Dupdate_test_prefix.py42 with ThreadPoolExecutor(max_workers=32) as e:
/external/grpc-grpc/examples/python/route_guide/
Droute_guide_server.py116 server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
/external/grpc-grpc/src/python/grpcio_tests/tests/stress/
Dclient.py128 server = grpc.server(futures.ThreadPoolExecutor(max_workers=25))

12