| /external/python/cpython2/Doc/includes/ |
| D | mp_synchronize.py | 11 import multiprocessing # may get overwritten
21 print '\n\t\t\t' + str(multiprocessing.current_process()) + ' has finished'
27 running = multiprocessing.Value('i', TASKS)
28 mutex = multiprocessing.Lock()
31 p = multiprocessing.Process(target=value_func, args=(running, mutex))
54 q = multiprocessing.Queue()
56 p = multiprocessing.Process(target=queue_func, args=(q,))
83 cond = multiprocessing.Condition()
85 p = multiprocessing.Process(target=condition_func, args=(cond,))
123 print '%s has finished' % multiprocessing.current_process()
[all …]
|
| D | mp_benchmarks.py | 8 import time, sys, multiprocessing, threading, Queue, gc
72 c, d = multiprocessing.Pipe()
73 cond = multiprocessing.Condition()
80 p = multiprocessing.Process(target=pipe_func,
183 manager = multiprocessing.Manager()
191 test_queuespeed(multiprocessing.Process, multiprocessing.Queue(),
192 multiprocessing.Condition())
194 test_queuespeed(multiprocessing.Process, manager.Queue(),
206 test_seqspeed(multiprocessing.Array('i', range(10), lock=False))
208 test_seqspeed(multiprocessing.Array('i', range(10), lock=True))
[all …]
|
| D | mp_pool.py | 8 import multiprocessing
20 multiprocessing.current_process().name,
49 print 'cpu_count() = %d\n' % multiprocessing.cpu_count()
57 pool = multiprocessing.Pool(PROCESSES)
196 except multiprocessing.TimeoutError:
209 except multiprocessing.TimeoutError:
266 pool = multiprocessing.Pool(2)
284 pool = multiprocessing.Pool(2)
301 multiprocessing.freeze_support()
309 import multiprocessing.dummy as multiprocessing namespace
|
| /external/python/cpython2/Lib/multiprocessing/ |
| D | __init__.py | 64 from multiprocessing.process import Process, current_process, active_children
65 from multiprocessing.util import SUBDEBUG, SUBWARNING
97 from multiprocessing.managers import SyncManager
106 from multiprocessing.connection import Pipe
144 from multiprocessing.forking import freeze_support
151 from multiprocessing.util import get_logger
158 from multiprocessing.util import log_to_stderr
165 from multiprocessing import reduction
175 from multiprocessing.synchronize import Lock
182 from multiprocessing.synchronize import RLock
[all …]
|
| /external/grpc-grpc/tools/run_tests/ |
| D | run_microbenchmark.py | 17 import multiprocessing
87 '%d' % multiprocessing.cpu_count()
117 if len(benchmarks) >= min(16, multiprocessing.cpu_count()):
122 multiprocessing.cpu_count() / 2))
123 jobset.run(profile_analysis, maxjobs=multiprocessing.cpu_count())
124 jobset.run(cleanup, maxjobs=multiprocessing.cpu_count())
130 jobset.run(benchmarks, maxjobs=max(1, multiprocessing.cpu_count() / 2))
131 jobset.run(profile_analysis, maxjobs=multiprocessing.cpu_count())
132 jobset.run(cleanup, maxjobs=multiprocessing.cpu_count())
140 '%d' % multiprocessing.cpu_count()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/tools/run_tests/ |
| D | run_microbenchmark.py | 17 import multiprocessing
123 if len(benchmarks) >= min(16, multiprocessing.cpu_count()):
128 multiprocessing.cpu_count() / 2))
129 jobset.run(profile_analysis, maxjobs=multiprocessing.cpu_count())
130 jobset.run(cleanup, maxjobs=multiprocessing.cpu_count())
136 jobset.run(benchmarks, maxjobs=max(1, multiprocessing.cpu_count() / 2))
137 jobset.run(profile_analysis, maxjobs=multiprocessing.cpu_count())
138 jobset.run(cleanup, maxjobs=multiprocessing.cpu_count())
180 jobset.run(profile_analysis, maxjobs=multiprocessing.cpu_count())
181 jobset.run(cleanup, maxjobs=multiprocessing.cpu_count())
[all …]
|
| /external/toolchain-utils/bestflags/ |
| D | pipeline_process.py | 13 import multiprocessing
19 class PipelineProcess(multiprocessing.Process):
61 multiprocessing.Process.__init__(self)
75 manager = multiprocessing.Manager()
89 work_pool = multiprocessing.Pool(self._num_processes)
92 helper_process = multiprocessing.Process(
|
| D | steering_test.py | 11 import multiprocessing
107 manager = multiprocessing.Manager()
111 steering_process = multiprocessing.Process(
154 manager = multiprocessing.Manager()
158 steering_process = multiprocessing.Process(
|
| D | pipeline_worker_test.py | 13 import multiprocessing
46 manager = multiprocessing.Manager()
52 helper_process = multiprocessing.Process(
96 manager = multiprocessing.Manager()
|
| /external/python/cpython3/Lib/test/ |
| D | mp_fork_bomb.py | 1 import multiprocessing, sys
11 multiprocessing.set_start_method(sys.argv[1])
13 multiprocessing.set_start_method('spawn')
15 p = multiprocessing.Process(target=foo)
|
| D | _test_multiprocessing.py | 39 import multiprocessing.connection
40 import multiprocessing.dummy
41 import multiprocessing.heap
42 import multiprocessing.managers
43 import multiprocessing.pool
44 import multiprocessing.queues
46 from multiprocessing import util
49 from multiprocessing import reduction
55 from multiprocessing.sharedctypes import Value, copy
61 from multiprocessing import shared_memory
[all …]
|
| D | mp_preload.py | 1 import multiprocessing
3 multiprocessing.Lock()
11 ctx = multiprocessing.get_context("forkserver")
|
| /external/python/cpython3/Doc/includes/ |
| D | mp_pool.py | 1 import multiprocessing
13 multiprocessing.current_process().name,
45 with multiprocessing.Pool(PROCESSES) as pool:
132 except multiprocessing.TimeoutError:
145 except multiprocessing.TimeoutError:
152 multiprocessing.freeze_support()
|
| /external/tensorflow/tensorflow/python/distribute/ |
| D | multi_process_lib.py | 20 import multiprocessing
63 multiprocessing.context.ForkServerProcess):
69 class AbslForkServerContext(multiprocessing.context.ForkServerContext):
73 multiprocessing = AbslForkServerContext() variable
74 Process = multiprocessing.Process
129 multiprocessing.get_context().set_executable(sys.argv[0])
|
| /external/rust/crates/grpcio-sys/grpc/tools/distrib/python/grpcio_tools/ |
| D | _parallel_compile_patch.py | 27 import multiprocessing
28 BUILD_EXT_COMPILER_JOBS = multiprocessing.cpu_count()
55 import multiprocessing.pool
56 multiprocessing.pool.ThreadPool(BUILD_EXT_COMPILER_JOBS).map(
|
| /external/python/cpython2/Lib/test/ |
| D | test_multiprocessing.py | 30 import multiprocessing.dummy
31 import multiprocessing.connection
32 import multiprocessing.managers
33 import multiprocessing.heap
34 import multiprocessing.pool
36 from multiprocessing import util
39 from multiprocessing import reduction
45 from multiprocessing.sharedctypes import Value, copy
283 cpus = multiprocessing.cpu_count()
304 from multiprocessing import forking
[all …]
|
| D | mp_fork_bomb.py | 1 import multiprocessing
10 r, w = multiprocessing.Pipe(False)
11 p = multiprocessing.Process(target=foo, args=(w,))
|
| /external/llvm-project/llvm/tools/opt-viewer/ |
| D | optpmap.py | 2 import multiprocessing
40 _current = multiprocessing.Value('i', 0)
41 _total = multiprocessing.Value('i', len(iterable))
47 pool = multiprocessing.Pool(initializer=_init,
|
| /external/chromium-trace/catapult/common/py_utils/py_utils/ |
| D | lock_unittest.py | 9 import multiprocessing
64 p = multiprocessing.Process(
95 p = multiprocessing.Process(
116 p = multiprocessing.Process(
134 p = multiprocessing.Process(
153 p = multiprocessing.Process(
162 p = multiprocessing.Process(
|
| /external/vixl/tools/ |
| D | threaded_tests.py | 28 import multiprocessing
42 n_tests_passed = multiprocessing.Value('i', 0)
43 n_tests_failed = multiprocessing.Value('i', 0)
44 n_tests_skipped = multiprocessing.Value('i', 0)
45 manager = multiprocessing.Manager()
|
| D | thread_pool.py | 29 import multiprocessing
41 __run_tests_lock__ = multiprocessing.Lock()
49 pool = multiprocessing.Pool(num_threads)
|
| /external/python/cpython2/Doc/library/ |
| D | multiprocessing.rst | 1 :mod:`multiprocessing` --- Process-based "threading" interface
4 .. module:: multiprocessing
13 :mod:`multiprocessing` is a package that supports spawning processes using an
14 API similar to the :mod:`threading` module. The :mod:`multiprocessing` package
17 to this, the :mod:`multiprocessing` module allows the programmer to fully
21 The :mod:`multiprocessing` module also introduces APIs which do not have
30 from multiprocessing import Pool
47 In :mod:`multiprocessing`, processes are spawned by creating a :class:`Process`
52 from multiprocessing import Process
64 from multiprocessing import Process
[all …]
|
| /external/python/cpython3/Doc/library/ |
| D | multiprocessing.rst | 1 :mod:`multiprocessing` --- Process-based parallelism
4 .. module:: multiprocessing
7 **Source code:** :source:`Lib/multiprocessing/`
14 :mod:`multiprocessing` is a package that supports spawning processes using an
15 API similar to the :mod:`threading` module. The :mod:`multiprocessing` package
19 to this, the :mod:`multiprocessing` module allows the programmer to fully
23 The :mod:`multiprocessing` module also introduces APIs which do not have
25 :class:`~multiprocessing.pool.Pool` object which offers a convenient means of
30 of data parallelism using :class:`~multiprocessing.pool.Pool`, ::
32 from multiprocessing import Pool
[all …]
|
| /external/autotest/site_utils/tester_feedback/ |
| D | request_multiplexer.py | 7 from multiprocessing import reduction
10 import multiprocessing
34 self._request_queue = multiprocessing.Queue()
134 self._request_handling_process = multiprocessing.Process(
164 reply_pipe_send, reply_pipe_recv = multiprocessing.Pipe()
|
| /external/llvm/utils/lit/lit/ |
| D | run.py | 16 import multiprocessing
18 multiprocessing = None variable
118 self.queue = multiprocessing.Queue()
215 if jobs != 1 and use_processes and multiprocessing:
217 task_impl = multiprocessing.Process
218 queue_impl = multiprocessing.Queue
219 canceled_flag = multiprocessing.Value('i', 0)
|