Lines Matching refs:multiprocessing
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
77 if isinstance(queue, multiprocessing.queues.Queue):
89 from multiprocessing import resource_tracker
117 from multiprocessing.connection import wait
285 from multiprocessing.process import parent_process
321 from multiprocessing.process import parent_process
448 exitcode = self._kill_process(multiprocessing.Process.terminate)
453 exitcode = self._kill_process(multiprocessing.Process.kill)
459 cpus = multiprocessing.cpu_count()
571 sm = multiprocessing.get_start_method()
625 sm = multiprocessing.get_start_method()
734 sm = multiprocessing.get_start_method()
740 from multiprocessing.forkserver import _forkserver
780 class _UpperCaser(multiprocessing.Process):
783 multiprocessing.Process.__init__(self)
784 self.child_conn, self.parent_conn = multiprocessing.Pipe()
1136 q = multiprocessing.Queue()
1194 class SafeQueue(multiprocessing.queues.Queue):
1205 q = SafeQueue(ctx=multiprocessing.get_context())
1217 for q in multiprocessing.Queue(), multiprocessing.JoinableQueue():
1655 wrapper = multiprocessing.heap.BufferWrapper(struct.calcsize('i'))
1656 lock = multiprocessing.Lock()
2404 except multiprocessing.TimeoutError:
2442 self.assertRaises(multiprocessing.TimeoutError, get, timeout=TIMEOUT2)
2594 self.assertIs(type(cause), multiprocessing.pool.RemoteTraceback)
2687 pool._state = multiprocessing.pool.RUN
2704 p = multiprocessing.Pool(2)
2719 from multiprocessing.pool import MaybeEncodingError
2720 p = multiprocessing.Pool(2)
2744 p = multiprocessing.Pool(3, maxtasksperchild=10)
2775 p = multiprocessing.Pool(3, maxtasksperchild=1)
2807 from multiprocessing.managers import BaseManager, BaseProxy, RemoteError
3063 except multiprocessing.BufferTooShort as e:
3450 from multiprocessing import resource_sharer
3585 self.old_heap = multiprocessing.heap.BufferWrapper._heap
3586 multiprocessing.heap.BufferWrapper._heap = multiprocessing.heap.Heap()
3589 multiprocessing.heap.BufferWrapper._heap = self.old_heap
3598 heap = multiprocessing.heap.BufferWrapper._heap
3604 b = multiprocessing.heap.BufferWrapper(size)
3672 a = multiprocessing.heap.BufferWrapper(1)
3673 b = multiprocessing.heap.BufferWrapper(1)
3911 smm = multiprocessing.managers.SharedMemoryManager()
3953 smm1 = multiprocessing.managers.SharedMemoryManager()
3972 with multiprocessing.managers.SharedMemoryManager() as smm2:
4273 folder = os.path.dirname(multiprocessing.__file__)
4317 logger = multiprocessing.get_logger()
4326 logger = multiprocessing.get_logger()
4333 logger = multiprocessing.get_logger()
4337 reader, writer = multiprocessing.Pipe(duplex=False)
4419 conn = multiprocessing.connection.Connection(44977608)
4430 multiprocessing.connection.Connection, -1)
4443 self.assertRaises(multiprocessing.AuthenticationError,
4444 multiprocessing.connection.deliver_challenge,
4454 return multiprocessing.connection.CHALLENGE
4460 self.assertRaises(multiprocessing.AuthenticationError,
4461 multiprocessing.connection.answer_challenge,
4474 self.mgr = multiprocessing.Manager()
4483 m = multiprocessing.managers.SyncManager()
4491 self.assertRaises(TypeError, multiprocessing.Pool, initializer=1)
4492 p = multiprocessing.Pool(1, initializer, (self.ns,))
4509 queue = multiprocessing.Queue()
4510 subProc = multiprocessing.Process(target=_this_sub_process, args=(queue,))
4519 pool = multiprocessing.Pool(processes=4)
4548 proc = multiprocessing.Process(target=_test_process)
4553 p = multiprocessing.Process(target=pool_in_process)
4561 proc = multiprocessing.Process(target=lambda: flike.flush())
4577 from multiprocessing.connection import wait
4583 r, w = multiprocessing.Pipe(duplex=False)
4584 p = multiprocessing.Process(target=self._child_test_wait, args=(w, slow))
4617 from multiprocessing.connection import wait
4625 p = multiprocessing.Process(target=self._child_test_wait_socket,
4658 from multiprocessing.connection import wait
4661 a, b = multiprocessing.Pipe()
4686 from multiprocessing.connection import wait
4690 sem = multiprocessing.Semaphore(0)
4691 a, b = multiprocessing.Pipe()
4692 p = multiprocessing.Process(target=self.signal_and_sleep,
4729 from multiprocessing.connection import wait
4730 a, b = multiprocessing.Pipe()
4748 multiprocessing.connection.Listener(r'\\.\test')
4753 multiprocessing.connection.Listener('/var/test.pipe')
4767 r, w = multiprocessing.Pipe(duplex=False)
4768 p = multiprocessing.Process(target=cls.run_in_grandchild, args=(w,))
4797 conn = multiprocessing.connection.Client(address)
4805 parent, child = multiprocessing.Pipe(duplex=True)
4806 l = multiprocessing.connection.Listener(family='AF_INET')
4807 p = multiprocessing.Process(target=self._test_timeout,
4827 sm = multiprocessing.get_start_method()
4850 p = multiprocessing.Process(target=cls.child, args=(n-1, conn))
4859 r, w = multiprocessing.Pipe(False)
4862 p = multiprocessing.Process(target=self.child, args=(5, w))
4913 reader, writer = multiprocessing.Pipe()
4916 p = multiprocessing.Process(target=self._test_closefds,
4927 if multiprocessing.get_start_method() == 'fork':
4956 conn, child_conn = multiprocessing.Pipe()
4958 p = multiprocessing.Process(target=self._test_ignore,
4982 with multiprocessing.connection.Listener() as l:
4989 conn, child_conn = multiprocessing.Pipe()
4991 p = multiprocessing.Process(target=self._test_ignore_listener,
5000 client = multiprocessing.connection.Client(address)
5009 conn.send(multiprocessing.get_start_method())
5024 ctx = multiprocessing.get_context(method)
5034 multiprocessing.set_forkserver_preload(PRELOAD)
5036 old_method = multiprocessing.get_start_method()
5040 multiprocessing.set_start_method(method, force=True)
5043 self.assertEqual(multiprocessing.get_start_method(), method)
5044 ctx = multiprocessing.get_context()
5049 self.check_context(multiprocessing)
5052 multiprocessing.set_start_method(old_method, force=True)
5056 methods = multiprocessing.get_all_start_methods()
5066 if multiprocessing.get_start_method() != 'forkserver':
5159 from multiprocessing.resource_tracker import _resource_tracker
5172 ctx = multiprocessing.get_context("spawn")
5207 from multiprocessing.resource_tracker import _resource_tracker
5216 from multiprocessing.resource_tracker import _resource_tracker
5220 r, w = multiprocessing.Pipe(duplex=False)
5221 p = multiprocessing.Process(target=self._is_resource_tracker_reused,
5247 queue = multiprocessing.SimpleQueue()
5248 child_can_start = multiprocessing.Event()
5249 parent_can_continue = multiprocessing.Event()
5251 proc = multiprocessing.Process(
5271 queue = multiprocessing.SimpleQueue()
5279 queue = multiprocessing.SimpleQueue()
5318 p = multiprocessing.pool.Pool(5, context=unittest.mock.MagicMock(
5349 manager_class = multiprocessing.managers.SyncManager
5377 while len(multiprocessing.active_children()) > 1:
5389 self.proc = multiprocessing.Process(target=worker, args=(obj, ))
5564 support.check__all__(self, multiprocessing, extra=multiprocessing.__all__,
5573 cls.dangling = (multiprocessing.process._dangling.copy(),
5582 processes = set(multiprocessing.process._dangling) - set(cls.dangling[0])
5597 Process = multiprocessing.Process
5598 connection = multiprocessing.connection
5599 current_process = staticmethod(multiprocessing.current_process)
5600 parent_process = staticmethod(multiprocessing.parent_process)
5601 active_children = staticmethod(multiprocessing.active_children)
5602 Pool = staticmethod(multiprocessing.Pool)
5603 Pipe = staticmethod(multiprocessing.Pipe)
5604 Queue = staticmethod(multiprocessing.Queue)
5605 JoinableQueue = staticmethod(multiprocessing.JoinableQueue)
5606 Lock = staticmethod(multiprocessing.Lock)
5607 RLock = staticmethod(multiprocessing.RLock)
5608 Semaphore = staticmethod(multiprocessing.Semaphore)
5609 BoundedSemaphore = staticmethod(multiprocessing.BoundedSemaphore)
5610 Condition = staticmethod(multiprocessing.Condition)
5611 Event = staticmethod(multiprocessing.Event)
5612 Barrier = staticmethod(multiprocessing.Barrier)
5613 Value = staticmethod(multiprocessing.Value)
5614 Array = staticmethod(multiprocessing.Array)
5615 RawValue = staticmethod(multiprocessing.RawValue)
5616 RawArray = staticmethod(multiprocessing.RawArray)
5621 Process = multiprocessing.Process
5644 cls.manager = multiprocessing.Manager()
5653 while len(multiprocessing.active_children()) > 1:
5682 Process = multiprocessing.dummy.Process
5683 connection = multiprocessing.dummy.connection
5684 current_process = staticmethod(multiprocessing.dummy.current_process)
5685 active_children = staticmethod(multiprocessing.dummy.active_children)
5686 Pool = staticmethod(multiprocessing.dummy.Pool)
5687 Pipe = staticmethod(multiprocessing.dummy.Pipe)
5688 Queue = staticmethod(multiprocessing.dummy.Queue)
5689 JoinableQueue = staticmethod(multiprocessing.dummy.JoinableQueue)
5690 Lock = staticmethod(multiprocessing.dummy.Lock)
5691 RLock = staticmethod(multiprocessing.dummy.RLock)
5692 Semaphore = staticmethod(multiprocessing.dummy.Semaphore)
5693 BoundedSemaphore = staticmethod(multiprocessing.dummy.BoundedSemaphore)
5694 Condition = staticmethod(multiprocessing.dummy.Condition)
5695 Event = staticmethod(multiprocessing.dummy.Event)
5696 Barrier = staticmethod(multiprocessing.dummy.Barrier)
5697 Value = staticmethod(multiprocessing.dummy.Value)
5698 Array = staticmethod(multiprocessing.dummy.Array)
5737 multiprocessing.set_forkserver_preload(PRELOAD)
5738 multiprocessing.process._cleanup()
5739 dangling[0] = multiprocessing.process._dangling.copy()
5741 old_start_method[0] = multiprocessing.get_start_method(allow_none=True)
5743 multiprocessing.set_start_method(start_method, force=True)
5750 lock = multiprocessing.RLock()
5756 multiprocessing.get_logger().setLevel(LOG_LEVEL)
5765 multiprocessing.set_start_method(old_start_method[0], force=True)
5767 processes = set(multiprocessing.process._dangling) - set(dangling[0])
5785 multiprocessing.util._cleanup_tests()