| /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/python/cpython3/Lib/test/ |
| D | _test_multiprocessing.py | 37 import multiprocessing.connection
38 import multiprocessing.dummy
39 import multiprocessing.heap
40 import multiprocessing.managers
41 import multiprocessing.pool
42 import multiprocessing.queues
44 from multiprocessing import util
47 from multiprocessing import reduction
53 from multiprocessing.sharedctypes import Value, copy
75 if isinstance(queue, multiprocessing.queues.Queue):
[all …]
|
| 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 | mp_preload.py | 1 import multiprocessing
3 multiprocessing.Lock()
11 ctx = multiprocessing.get_context("forkserver")
|
| /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/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/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/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
18 to this, the :mod:`multiprocessing` module allows the programmer to fully
22 The :mod:`multiprocessing` module also introduces APIs which do not have
24 :class:`~multiprocessing.pool.Pool` object which offers a convenient means of
29 of data parallelism using :class:`~multiprocessing.pool.Pool`, ::
31 from multiprocessing import Pool
[all …]
|
| /external/chromium-trace/catapult/common/py_utils/py_utils/ |
| D | lock_unittest.py | 5 import multiprocessing
59 p = multiprocessing.Process(
90 p = multiprocessing.Process(
111 p = multiprocessing.Process(
129 p = multiprocessing.Process(
148 p = multiprocessing.Process(
157 p = multiprocessing.Process(
|
| /external/swiftshader/third_party/llvm-7.0/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/vixl/tools/ |
| D | threaded_tests.py | 27 import multiprocessing
64 n_tests_passed = multiprocessing.Value('i', 0)
65 n_tests_failed = multiprocessing.Value('i', 0)
114 __run_tests_lock__ = multiprocessing.Lock()
144 pool = multiprocessing.Pool(jobs)
|
| /external/python/cpython2/Doc/tools/ |
| D | susp-ignored.csv | 80 library/multiprocessing,,:queue,">>> QueueManager.register('get_queue', callable=lambda:queue)"
81 library/multiprocessing,,`,">>> l._callmethod('__getitem__', (20,)) # equiv to `l[20]`"
82 library/multiprocessing,,`,">>> l._callmethod('__getslice__', (2, 7)) # equiv to `l[2:7]`"
83 library/multiprocessing,,`,# `BaseManager`.
84 library/multiprocessing,,`,# `Pool.imap()` (which will save on the amount of code needed anyway).
85 library/multiprocessing,,`,# A test file for the `multiprocessing` package
86 library/multiprocessing,,`,# A test of `multiprocessing.Pool` class
87 library/multiprocessing,,`,# Add more tasks using `put()`
88 library/multiprocessing,,`,# in the original order then consider using `Pool.map()` or
89 library/multiprocessing,,`,# Not sure if we should synchronize access to `socket.accept()` method by
[all …]
|
| /external/python/cpython3/Lib/test/libregrtest/ |
| D | save_env.py | 12 import _multiprocessing, multiprocessing.process
14 multiprocessing = None variable
189 if not multiprocessing:
192 multiprocessing.process._cleanup()
194 return multiprocessing.process._dangling.copy()
196 if not multiprocessing:
198 multiprocessing.process._dangling.clear()
199 multiprocessing.process._dangling.update(saved)
|
| /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)
|
| /external/autotest/site_utils/ |
| D | rpc_flight_recorder.py | 10 import multiprocessing
96 pool = multiprocessing.Pool(processes=multiprocessing.cpu_count() * 4)
123 self._manager = multiprocessing.Manager()
135 self._stop_event = multiprocessing.Event()
142 self._update_shards_ps = multiprocessing.Process(
154 self._poll_rpc_server_ps = multiprocessing.Process(
|
| /external/chromium-trace/catapult/common/py_trace_event/py_trace_event/trace_event_impl/ |
| D | multiprocessing_shim.py | 4 import multiprocessing
9 _RealProcess = multiprocessing.Process
91 if multiprocessing.Process != ProcessShim:
92 multiprocessing.Process = ProcessShim
|