Home
last modified time | relevance | path

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

/external/fio/
Dworkqueue.c46 assert(next < wq->max_workers); in get_submit_worker()
48 sw = __get_submit_worker(wq, next, wq->max_workers - 1, &best); in get_submit_worker()
59 if (sw->index + 1 < wq->max_workers) in get_submit_worker()
72 for (i = 0; i < wq->max_workers; i++) { in all_sw_idle()
240 for (i = 0; i < wq->max_workers; i++) { in workqueue_exit()
251 for (i = 0; i < wq->max_workers; i++) { in workqueue_exit()
261 } while (shutdown && shutdown != wq->max_workers); in workqueue_exit()
305 struct workqueue_ops *ops, unsigned int max_workers, in workqueue_init() argument
312 wq->max_workers = max_workers; in workqueue_init()
325 wq->workers = smalloc(wq->max_workers * sizeof(struct submit_worker)); in workqueue_init()
[all …]
Dworkqueue.h49 unsigned int max_workers; member
64 …ata *td, struct workqueue *wq, struct workqueue_ops *ops, unsigned int max_workers, struct sk_out …
/external/python/cpython3/Lib/concurrent/futures/
Dthread.py84 def __init__(self, max_workers=None, thread_name_prefix=''): argument
92 if max_workers is None:
95 max_workers = (os.cpu_count() or 1) * 5
96 if max_workers <= 0:
99 self._max_workers = max_workers
Dprocess.py368 def __init__(self, max_workers=None): argument
378 if max_workers is None:
381 if max_workers <= 0:
384 self._max_workers = max_workers
/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/autotest/site_utils/lxc/container_pool/
Dpool_unittest.py309 max_workers = pool._MAX_CONCURRENT_WORKERS
311 test_factory.pause(max_workers*2)
312 test_pool = pool.Pool(test_factory, size=max_workers*2)
316 test_factory.wait(max_workers)
323 self.assertEquals(max_workers, test_pool.worker_count)
335 self.assertEquals(max_workers, test_pool.worker_count)
/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:
83 with ThreadPoolExecutor(max_workers=4) as e:
111 executor = ThreadPoolExecutor(max_workers=2)
123 executor = ThreadPoolExecutor(max_workers=1)
127 .. class:: ThreadPoolExecutor(max_workers=None, thread_name_prefix='')
129 An :class:`Executor` subclass that uses a pool of at most *max_workers*
133 If *max_workers* is ``None`` or
166 with concurrent.futures.ThreadPoolExecutor(max_workers=5) as executor:
194 .. class:: ProcessPoolExecutor(max_workers=None)
197 of at most *max_workers* processes. If *max_workers* is ``None`` or not
[all …]
Dasyncio-eventloop.rst715 ``max_workers`` of the thread pool executor it creates, instead
/external/python/cpython3/Lib/test/
Dtest_concurrent_futures.py68 self.executor = self.executor_type(max_workers=self.worker_count)
140 with futures.ThreadPoolExecutor(max_workers=5) as e:
149 executor = futures.ThreadPoolExecutor(max_workers=5)
159 max_workers=5, thread_name_prefix='SpecialPool')
169 executor = futures.ThreadPoolExecutor(max_workers=5)
198 with futures.ProcessPoolExecutor(max_workers=5) as e:
207 executor = futures.ProcessPoolExecutor(max_workers=5)
458 self.executor_type(max_workers=number)
/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/
Dcompileall.py79 with ProcessPoolExecutor(max_workers=workers) as executor:
/external/tensorflow/tensorflow/python/debug/lib/
Dgrpc_debug_server.py349 self.server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
/external/python/cpython3/Lib/distutils/command/
Dbuild_ext.py463 with ThreadPoolExecutor(max_workers=workers) as executor:
/external/python/cpython3/Doc/whatsnew/
D3.2.rst270 with concurrent.futures.ThreadPoolExecutor(max_workers=4) as e: