| /third_party/boost/libs/python/src/object/ |
| D | pickle_support.cpp | 40 tuple initargs; in instance_reduce() local
42 initargs = tuple(getinitargs()); in instance_reduce()
44 result.append(initargs); in instance_reduce()
|
| /third_party/python/Lib/concurrent/futures/ |
| D | thread.py | 69 def _worker(executor_reference, work_queue, initializer, initargs): argument
72 initializer(*initargs)
124 initializer=None, initargs=()): argument
159 self._initargs = initargs
|
| D | process.py | 215 def _process_worker(call_queue, result_queue, initializer, initargs): argument
230 initializer(*initargs)
582 initializer=None, initargs=()): argument
618 self._initargs = initargs
|
| /third_party/python/Lib/multiprocessing/ |
| D | pool.py | 97 def worker(inqueue, outqueue, initializer=None, initargs=(), maxtasks=None, argument
109 initializer(*initargs)
183 def __init__(self, processes=None, initializer=None, initargs=(), argument
200 self._initargs = initargs
313 outqueue, initializer, initargs, argument
322 initargs, maxtasksperchild,
332 initializer, initargs, maxtasksperchild, argument
339 initargs, maxtasksperchild,
505 pool, inqueue, outqueue, initializer, initargs, argument
514 outqueue, initializer, initargs,
[all …]
|
| D | context.py | 115 def Pool(self, processes=None, initializer=None, initargs=(), argument
119 return Pool(processes, initializer, initargs, maxtasksperchild,
|
| D | managers.py | 535 def start(self, initializer=None, initargs=()): argument
558 self._serializer, writer, initializer, initargs),
580 initializer=None, initargs=()): argument
588 initializer(*initargs)
|
| /third_party/python/Lib/multiprocessing/dummy/ |
| D | __init__.py | 122 def Pool(processes=None, initializer=None, initargs=()): argument
124 return ThreadPool(processes, initializer, initargs)
|
| /third_party/grpc/examples/python/multiprocessing/ |
| D | client.py | 69 initargs=(server_address,))
|
| /third_party/python/Doc/library/ |
| D | concurrent.futures.rst | 147 .. class:: ThreadPoolExecutor(max_workers=None, thread_name_prefix='', initializer=None, initargs=(…
153 each worker thread; *initargs* is a tuple of arguments passed to the
172 Added the *initializer* and *initargs* arguments.
234 .. class:: ProcessPoolExecutor(max_workers=None, mp_context=None, initializer=None, initargs=())
250 each worker process; *initargs* is a tuple of arguments passed to the
265 Added the *initializer* and *initargs* arguments.
|
| D | multiprocessing.rst | 1672 .. method:: start([initializer[, initargs]])
1675 then the subprocess will call ``initializer(*initargs)`` when it starts.
2124 .. class:: Pool([processes[, initializer[, initargs[, maxtasksperchild [, context]]]]])
2134 ``initializer(*initargs)`` when it starts.
2682 .. class:: ThreadPool([processes[, initializer[, initargs]]])
2695 ``initializer(*initargs)`` when it starts.
|
| /third_party/python/Lib/test/ |
| D | test_concurrent_futures.py | 224 initargs=('initialized',))
244 initargs=(self.log_queue,))
|
| /third_party/mindspore/mindspore/dataset/engine/ |
| D | datasets.py | 2267 … initargs=([self.per_batch_map], arg_q_list, res_q_list))
2802 … initargs=(callable_list, arg_q_list, res_q_list))
|
| /third_party/python/Doc/whatsnew/ |
| D | 3.7.rst | 818 support the new *initializer* and *initargs* constructor arguments.
|