Home
last modified time | relevance | path

Searched refs:multiprocessing (Results 1 – 25 of 129) sorted by relevance

123456

/external/python/cpython2/Doc/includes/
Dmp_synchronize.py11 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 …]
Dmp_benchmarks.py8 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 …]
Dmp_pool.py8 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__.py64 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/toolchain-utils/bestflags/
Dpipeline_process.py13 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(
Dsteering_test.py11 import multiprocessing
107 manager = multiprocessing.Manager()
111 steering_process = multiprocessing.Process(
154 manager = multiprocessing.Manager()
158 steering_process = multiprocessing.Process(
Dpipeline_worker_test.py13 import multiprocessing
46 manager = multiprocessing.Manager()
52 helper_process = multiprocessing.Process(
96 manager = multiprocessing.Manager()
/external/python/cpython2/Lib/test/
Dtest_multiprocessing.py29 import multiprocessing.dummy
30 import multiprocessing.connection
31 import multiprocessing.managers
32 import multiprocessing.heap
33 import multiprocessing.pool
35 from multiprocessing import util
38 from multiprocessing import reduction
44 from multiprocessing.sharedctypes import Value, copy
276 cpus = multiprocessing.cpu_count()
297 from multiprocessing import forking
[all …]
Dmp_fork_bomb.py1 import multiprocessing
10 r, w = multiprocessing.Pipe(False)
11 p = multiprocessing.Process(target=foo, args=(w,))
/external/chromium-trace/catapult/common/py_utils/py_utils/
Dlock_unittest.py5 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/python/cpython2/Doc/library/
Dmultiprocessing.rst1 :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/vixl/tools/
Dthreaded_tests.py27 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)
Dprinter.py32 import multiprocessing
51 __print_lock__ = multiprocessing.Lock()
52 __last_overwritable_line_length__ = multiprocessing.Value('i', 0)
53 __last_line_type__ = multiprocessing.Value('i', LINE_TYPE_NONE)
Dclang_format.py31 import multiprocessing
64 default = multiprocessing.cpu_count(),
65 const = multiprocessing.cpu_count(),
139 pool = multiprocessing.Pool(jobs)
/external/autotest/site_utils/tester_feedback/
Drequest_multiplexer.py7 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/v8/tools/gcmole/
Dparallel.py24 import multiprocessing
37 processes = multiprocessing.cpu_count()
38 pool = multiprocessing.Pool(processes=processes)
/external/autotest/site_utils/
Drpc_flight_recorder.py9 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(
Dgs_offloader.py172 def _get_cmd_list(multiprocessing, dir_entry, gs_path): argument
184 if multiprocessing:
379 def _upload_cts_testresult(dir_entry, multiprocessing): argument
400 _upload_files(host, path, result_pattern, multiprocessing)
433 def _upload_files(host, path, result_pattern, multiprocessing): argument
463 multiprocessing, zip_file, cts_apfe_gs_path)))
474 multiprocessing, test_result_file_gz, test_result_gs_path)))
511 def __init__(self, gs_uri, multiprocessing, delete_age, argument
521 self._multiprocessing = multiprocessing
796 multiprocessing = False
[all …]
Dlog_socket_server.py16 import multiprocessing
125 server_started = multiprocessing.Value(ctypes.c_bool, False)
126 port = multiprocessing.Value(ctypes.c_int, 0)
127 LogSocketServer.process = multiprocessing.Process(
Drpc_logserver.py12 import multiprocessing
47 server_started = multiprocessing.Value(ctypes.c_bool, False)
48 LogServer.process = multiprocessing.Process(
/external/llvm/utils/lit/lit/
Drun.py16 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/chromium-trace/catapult/common/py_trace_event/py_trace_event/trace_event_impl/
Dmultiprocessing_shim.py4 import multiprocessing
9 _RealProcess = multiprocessing.Process
91 if multiprocessing.Process != ProcessShim:
92 multiprocessing.Process = ProcessShim
/external/python/cpython2/Doc/tools/
Dsusp-ignored.csv80 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/webrtc/webrtc/tools/barcode_tools/
Dhelper_functions.py10 import multiprocessing
86 process_pool = multiprocessing.Pool(processes=multiprocessing.cpu_count())
/external/autotest/client/cros/cellular/mbim_compliance/
Dmbim_channel.py6 import multiprocessing
77 self._stop_request_event = multiprocessing.Event()
78 self._request_queue = multiprocessing.Queue()
79 self._response_queue = multiprocessing.Queue()
84 process_class = multiprocessing.Process

123456