Home
last modified time | relevance | path

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

12

/third_party/grpc/src/python/grpcio_tests/tests/unit/
Dthread_pool.py22 def __init__(self, max_workers): argument
23 self._tp_executor = futures.ThreadPoolExecutor(max_workers=max_workers)
Dtest_common.py103 def test_server(max_workers=10, reuse_port=False): argument
108 return grpc.server(futures.ThreadPoolExecutor(max_workers=max_workers),
D_server_test.py34 grpc.server(futures.ThreadPoolExecutor(max_workers=5),
43 server = grpc.server(futures.ThreadPoolExecutor(max_workers=5))
D_channel_connectivity_test.py89 max_workers=None)
134 max_workers=None)
D_channel_args_test.py52 grpc.server(futures.ThreadPoolExecutor(max_workers=1),
D_channel_ready_future_test.py67 max_workers=None)
/third_party/python/Lib/concurrent/futures/
Dthread.py123 def __init__(self, max_workers=None, thread_name_prefix='', argument
134 if max_workers is None:
142 max_workers = min(32, (os.cpu_count() or 1) + 4)
143 if max_workers <= 0:
149 self._max_workers = max_workers
Dprocess.py581 def __init__(self, max_workers=None, mp_context=None, argument
596 if max_workers is None:
602 if max_workers <= 0:
605 max_workers > _MAX_WINDOWS_WORKERS):
609 self._max_workers = max_workers
/third_party/grpc/src/python/grpcio/grpc/framework/foundation/
Dlogging_pool.py62 def pool(max_workers): argument
72 return _LoggingPool(futures.ThreadPoolExecutor(max_workers))
/third_party/python/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 …]
/third_party/grpc/examples/python/xds/
Dserver.py48 futures.ThreadPoolExecutor(max_workers=multiprocessing.cpu_count()))
57 experimental_thread_pool=futures.ThreadPoolExecutor(max_workers=1))
/third_party/python/Lib/test/
Dtest_concurrent_futures.py121 max_workers=self.worker_count,
126 max_workers=self.worker_count,
362 executor = self.executor_type(max_workers=3)
424 with futures.ThreadPoolExecutor(max_workers=5) as e:
433 executor = futures.ThreadPoolExecutor(max_workers=5)
448 executor = futures.ThreadPoolExecutor(max_workers=5)
462 max_workers=5, thread_name_prefix='SpecialPool')
473 executor = futures.ThreadPoolExecutor(max_workers=5)
524 with futures.ProcessPoolExecutor(max_workers=5) as e:
533 executor = futures.ProcessPoolExecutor(max_workers=5)
[all …]
/third_party/grpc/src/python/grpcio_tests/tests/qps/
Dbenchmark_client.py106 max_workers=config.outstanding_rpcs_per_channel)
183 max_workers=config.outstanding_rpcs_per_channel)
216 max_workers=config.outstanding_rpcs_per_channel)
/third_party/ltp/testcases/kernel/fs/read_all/
Dread_all.c80 static long max_workers = 15; variable
353 if (tst_parse_long(str_max_workers, &max_workers, 1, LONG_MAX)) { in setup()
369 worker_count = MIN(MAX(tst_ncpus() - 1, 1), max_workers); in setup()
/third_party/grpc/examples/python/helloworld/
Dgreeter_server.py32 server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
Dgreeter_server_with_reflection.py33 server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
/third_party/grpc/examples/python/interceptors/headers/
Dgreeter_server.py36 server = grpc.server(futures.ThreadPoolExecutor(max_workers=10),
/third_party/grpc/examples/python/metadata/
Dmetadata_server.py40 server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
/third_party/grpc/src/python/grpcio_tests/tests_py3_only/unit/
D_leak_test.py61 server = grpc.server(ThreadPoolExecutor(max_workers=1),
/third_party/flatbuffers/grpc/examples/python/greeter/
Dserver.py48 server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
/third_party/grpc/examples/python/multiprocessing/
Dserver.py71 max_workers=_THREAD_CONCURRENCY,),
/third_party/grpc/examples/python/cancellation/
Dserver.py92 server = grpc.server(futures.ThreadPoolExecutor(max_workers=1),
/third_party/grpc/examples/python/route_guide/
Droute_guide_server.py114 server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
/third_party/grpc/src/python/grpcio_tests/tests/stress/
Dclient.py125 server = grpc.server(futures.ThreadPoolExecutor(max_workers=25))
/third_party/grpc/examples/python/multiplex/
Dmultiplex_server.py122 server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))

12