| /aosp_15_r20/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
|
| /aosp_15_r20/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 …]
|
| /aosp_15_r20/external/python/cpython3/Lib/test/ |
| D | _test_multiprocessing.py | 45 import multiprocessing.connection
46 import multiprocessing.dummy
47 import multiprocessing.heap
48 import multiprocessing.managers
49 import multiprocessing.pool
50 import multiprocessing.queues
52 from multiprocessing import util
55 from multiprocessing import reduction
61 from multiprocessing.sharedctypes import Value, copy
67 from multiprocessing import shared_memory
[all …]
|
| D | _test_venv_multiprocessing.py | 1 import multiprocessing
17 queue = multiprocessing.Queue()
18 fill_pool = multiprocessing.Process(
22 drain_pool = multiprocessing.Process(
33 test_pool = multiprocessing.Process(target=test_func)
|
| /aosp_15_r20/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 …]
|
| /aosp_15_r20/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 …]
|
| /aosp_15_r20/external/python/cpython3/Doc/library/ |
| D | multiprocessing.rst | 1 :mod:`multiprocessing` --- Process-based parallelism
4 .. module:: multiprocessing
7 **Source code:** :source:`Lib/multiprocessing/`
16 :mod:`multiprocessing` is a package that supports spawning processes using an
17 API similar to the :mod:`threading` module. The :mod:`multiprocessing` package
21 to this, the :mod:`multiprocessing` module allows the programmer to fully
25 The :mod:`multiprocessing` module also introduces APIs which do not have
27 :class:`~multiprocessing.pool.Pool` object which offers a convenient means of
32 of data parallelism using :class:`~multiprocessing.pool.Pool`, ::
34 from multiprocessing import Pool
[all …]
|
| D | multiprocessing.shared_memory.rst | 1 :mod:`multiprocessing.shared_memory` --- Shared memory for direct access across processes
4 .. module:: multiprocessing.shared_memory
7 **Source code:** :source:`Lib/multiprocessing/shared_memory.py`
22 processes, a :class:`~multiprocessing.managers.BaseManager` subclass,
24 ``multiprocessing.managers`` module.
104 >>> from multiprocessing import shared_memory
137 >>> from multiprocessing import shared_memory
153 >>> from multiprocessing import shared_memory
179 :module: multiprocessing.managers
181 A subclass of :class:`~multiprocessing.managers.BaseManager` which can be
[all …]
|
| /aosp_15_r20/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 …]
|
| /aosp_15_r20/external/pytorch/docs/source/ |
| H A D | multiprocessing.rst | 5 Multiprocessing package - torch.multiprocessing
8 .. automodule:: torch.multiprocessing
9 .. currentmodule:: torch.multiprocessing
14 Python's ``multiprocessing`` sometimes fails to clean up its children.
142 To counter the problem of shared memory file leaks, :mod:`torch.multiprocessing`
160 ``multiprocessing`` package.
177 .. automodule:: torch.multiprocessing.spawn
178 .. currentmodule:: torch.multiprocessing.spawn
182 .. currentmodule:: torch.multiprocessing
194 .. py:module:: torch.multiprocessing.pool
[all …]
|
| /aosp_15_r20/external/pytorch/docs/source/notes/ |
| H A D | multiprocessing.rst | 6 :mod:`torch.multiprocessing` is a drop in replacement for Python's
7 :mod:`python:multiprocessing` module. It supports the exact same operations,
9 :class:`python:multiprocessing.Queue`, will have their data moved into shared
27 CUDA in multiprocessing
35 ``multiprocessing.get_context(...)`` or directly using
36 ``multiprocessing.set_start_method(...)``.
44 :ref:`this section <multiprocessing-cuda-sharing-details>`.
60 libraries do - no need to look further than :mod:`python:multiprocessing`.
61 :class:`python:multiprocessing.Queue` is actually a very complex class, that
64 try using a :class:`~python:multiprocessing.queues.SimpleQueue`, that doesn't
[all …]
|
| /aosp_15_r20/external/toolchain-utils/bestflags/ |
| H A D | pipeline_process.py | 13 import multiprocessing
20 class PipelineProcess(multiprocessing.Process):
71 multiprocessing.Process.__init__(self)
85 manager = multiprocessing.Manager()
99 work_pool = multiprocessing.Pool(self._num_processes)
102 helper_process = multiprocessing.Process(
|
| H A D | steering_test.py | 11 import multiprocessing
112 manager = multiprocessing.Manager()
116 steering_process = multiprocessing.Process(
162 manager = multiprocessing.Manager()
166 steering_process = multiprocessing.Process(
|
| /aosp_15_r20/external/pytorch/test/distributed/rpc/ |
| H A D | test_share_memory.py | 18 import torch.multiprocessing.reductions as TorchMpReductions
19 from torch import multiprocessing
27 prev_strategy = multiprocessing.get_sharing_strategy()
28 multiprocessing.set_sharing_strategy("file_system")
32 multiprocessing.set_sharing_strategy(prev_strategy)
68 r = multiprocessing.spawn(worker_loop, join=False)
|
| /aosp_15_r20/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()
|
| /aosp_15_r20/external/tensorflow/tensorflow/python/distribute/ |
| H A D | multi_process_lib.py | 17 import multiprocessing
60 multiprocessing.context.ForkServerProcess):
66 class AbslForkServerContext(multiprocessing.context.ForkServerContext):
70 multiprocessing = AbslForkServerContext() variable
71 Process = multiprocessing.Process
126 multiprocessing.get_context().set_executable(sys.argv[0])
|
| /aosp_15_r20/external/pytorch/docs/source/elastic/ |
| H A D | subprocess_handler.rst | 6 .. automodule:: torch.distributed.elastic.multiprocessing.subprocess_handler
7 .. automodule:: torch.distributed.elastic.multiprocessing.subprocess_handler.subprocess_handler
8 .. automodule:: torch.distributed.elastic.multiprocessing.subprocess_handler.handlers
13 .. autofunction:: torch.distributed.elastic.multiprocessing.subprocess_handler.handlers.get_subproc…
18 .. currentmodule:: torch.distributed.elastic.multiprocessing.subprocess_handler.subprocess_handler
|
| /aosp_15_r20/external/chromium-trace/catapult/common/py_utils/py_utils/ |
| H A 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(
|
| /aosp_15_r20/external/llvm/utils/lit/lit/ |
| H A 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)
|
| /aosp_15_r20/external/autotest/site_utils/ |
| H A D | rpc_flight_recorder.py | 12 import multiprocessing
98 pool = multiprocessing.Pool(processes=multiprocessing.cpu_count() * 4)
125 self._manager = multiprocessing.Manager()
137 self._stop_event = multiprocessing.Event()
144 self._update_shards_ps = multiprocessing.Process(
156 self._poll_rpc_server_ps = multiprocessing.Process(
|
| /aosp_15_r20/external/grpc-grpc/examples/python/multiprocessing/ |
| H A D | README.md | 5 Unfortunately, using multiprocessing and gRPC Python is not yet as simple as
27 _PROCESS_COUNT = multiprocessing.cpu_count()
41 bazel run //examples/python/multiprocessing:server &
59 bazel run //examples/python/multiprocessing:client -- [SERVER_ADDRESS]
65 bazel run //examples/python/multiprocessing:client -- [::]:33915
72 cd examples/python/multiprocessing
|
| /aosp_15_r20/external/autotest/utils/frozen_chromite/lib/ |
| H A D | parallel.py | 15 import multiprocessing
16 from multiprocessing.managers import SyncManager
124 class _BackgroundTask(multiprocessing.Process):
176 multiprocessing.Process.__init__(self)
180 self._started = multiprocessing.Event()
181 self._killing = multiprocessing.Event()
392 return multiprocessing.Process.start(self)
534 semaphore = multiprocessing.Semaphore(max_parallel)
749 processes = multiprocessing.cpu_count()
805 processes = min(max(16, multiprocessing.cpu_count()), len(inputs))
|
| /aosp_15_r20/external/vixl/tools/ |
| H A 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()
|