Home
last modified time | relevance | path

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

12

/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/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/cpython3/Lib/concurrent/futures/
Dthread.py113 def __init__(self, max_workers=None, thread_name_prefix='', argument
124 if max_workers is None:
127 max_workers = (os.cpu_count() or 1) * 5
128 if max_workers <= 0:
134 self._max_workers = max_workers
Dprocess.py490 def __init__(self, max_workers=None, mp_context=None, argument
505 if max_workers is None:
508 if max_workers <= 0:
511 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/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/Doc/library/
Dconcurrent.futures.rst37 with ThreadPoolExecutor(max_workers=1) as executor:
91 with ThreadPoolExecutor(max_workers=4) as e:
119 executor = ThreadPoolExecutor(max_workers=2)
131 executor = ThreadPoolExecutor(max_workers=1)
135 .. class:: ThreadPoolExecutor(max_workers=None, thread_name_prefix='', initializer=None, initargs=(…
137 An :class:`Executor` subclass that uses a pool of at most *max_workers*
147 If *max_workers* is ``None`` or
184 with concurrent.futures.ThreadPoolExecutor(max_workers=5) as executor:
212 .. class:: ProcessPoolExecutor(max_workers=None, mp_context=None, initializer=None, initargs=())
215 of at most *max_workers* processes. If *max_workers* is ``None`` or not
[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/python/cpython3/Lib/test/
Dtest_concurrent_futures.py115 max_workers=self.worker_count,
120 max_workers=self.worker_count,
355 with futures.ThreadPoolExecutor(max_workers=5) as e:
364 executor = futures.ThreadPoolExecutor(max_workers=5)
374 max_workers=5, thread_name_prefix='SpecialPool')
384 executor = futures.ThreadPoolExecutor(max_workers=5)
412 with futures.ProcessPoolExecutor(max_workers=5) as e:
421 executor = futures.ProcessPoolExecutor(max_workers=5)
719 self.executor_type(max_workers=number)
954 max_workers=2, mp_context=get_context(self.ctx))
[all …]
/external/ltp/testcases/kernel/fs/read_all/
Dread_all.c92 static long max_workers = 15; variable
335 if (tst_parse_long(str_max_workers, &max_workers, 1, LONG_MAX)) { in setup()
351 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/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/grpc-grpc/examples/python/interceptors/headers/
Dgreeter_server.py39 futures.ThreadPoolExecutor(max_workers=10),
/external/grpc-grpc/src/python/grpcio/grpc/
D_auth.py45 self._pool = futures.ThreadPoolExecutor(max_workers=1)
/external/tensorflow/tensorflow/contrib/rpc/python/kernel_tests/
Drpc_op_test.py54 server = grpc.server(logging_pool.pool(max_workers=25))
/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))
/external/grpc-grpc/examples/python/multiplex/
Dmultiplex_server.py124 server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))

12