Lines Matching refs:multiprocessing
43 import multiprocessing.connection
44 import multiprocessing.dummy
45 import multiprocessing.heap
46 import multiprocessing.managers
47 import multiprocessing.pool
48 import multiprocessing.queues
50 from multiprocessing import util
53 from multiprocessing import reduction
59 from multiprocessing.sharedctypes import Value, copy
65 from multiprocessing import shared_memory
87 if isinstance(queue, multiprocessing.queues.Queue):
99 from multiprocessing import resource_tracker
127 from multiprocessing.connection import wait
295 from multiprocessing.process import parent_process
331 from multiprocessing.process import parent_process
458 exitcode = self._kill_process(multiprocessing.Process.terminate)
463 exitcode = self._kill_process(multiprocessing.Process.kill)
469 cpus = multiprocessing.cpu_count()
581 sm = multiprocessing.get_start_method()
636 sm = multiprocessing.get_start_method()
745 sm = multiprocessing.get_start_method()
751 from multiprocessing.forkserver import _forkserver
791 class _UpperCaser(multiprocessing.Process):
794 multiprocessing.Process.__init__(self)
795 self.child_conn, self.parent_conn = multiprocessing.Pipe()
1147 q = multiprocessing.Queue()
1205 class SafeQueue(multiprocessing.queues.Queue):
1216 q = SafeQueue(ctx=multiprocessing.get_context())
1228 for q in multiprocessing.Queue(), multiprocessing.JoinableQueue():
1666 wrapper = multiprocessing.heap.BufferWrapper(struct.calcsize('i'))
1667 lock = multiprocessing.Lock()
2425 except multiprocessing.TimeoutError:
2463 self.assertRaises(multiprocessing.TimeoutError, get, timeout=TIMEOUT2)
2615 self.assertIs(type(cause), multiprocessing.pool.RemoteTraceback)
2709 pool._state = multiprocessing.pool.RUN
2726 p = multiprocessing.Pool(2)
2741 from multiprocessing.pool import MaybeEncodingError
2742 p = multiprocessing.Pool(2)
2766 p = multiprocessing.Pool(3, maxtasksperchild=10)
2797 p = multiprocessing.Pool(3, maxtasksperchild=1)
2829 from multiprocessing.managers import BaseManager, BaseProxy, RemoteError
3085 except multiprocessing.BufferTooShort as e:
3472 from multiprocessing import resource_sharer
3607 self.old_heap = multiprocessing.heap.BufferWrapper._heap
3608 multiprocessing.heap.BufferWrapper._heap = multiprocessing.heap.Heap()
3611 multiprocessing.heap.BufferWrapper._heap = self.old_heap
3620 heap = multiprocessing.heap.BufferWrapper._heap
3626 b = multiprocessing.heap.BufferWrapper(size)
3694 a = multiprocessing.heap.BufferWrapper(1)
3695 b = multiprocessing.heap.BufferWrapper(1)
4008 smm = multiprocessing.managers.SharedMemoryManager()
4050 smm1 = multiprocessing.managers.SharedMemoryManager()
4069 with multiprocessing.managers.SharedMemoryManager() as smm2:
4414 folder = os.path.dirname(multiprocessing.__file__)
4458 logger = multiprocessing.get_logger()
4467 logger = multiprocessing.get_logger()
4474 logger = multiprocessing.get_logger()
4478 reader, writer = multiprocessing.Pipe(duplex=False)
4560 conn = multiprocessing.connection.Connection(44977608)
4571 multiprocessing.connection.Connection, -1)
4584 self.assertRaises(multiprocessing.AuthenticationError,
4585 multiprocessing.connection.deliver_challenge,
4595 return multiprocessing.connection.CHALLENGE
4601 self.assertRaises(multiprocessing.AuthenticationError,
4602 multiprocessing.connection.answer_challenge,
4615 self.mgr = multiprocessing.Manager()
4624 m = multiprocessing.managers.SyncManager()
4632 self.assertRaises(TypeError, multiprocessing.Pool, initializer=1)
4633 p = multiprocessing.Pool(1, initializer, (self.ns,))
4650 queue = multiprocessing.Queue()
4651 subProc = multiprocessing.Process(target=_this_sub_process, args=(queue,))
4660 pool = multiprocessing.Pool(processes=4)
4689 proc = multiprocessing.Process(target=_test_process)
4694 p = multiprocessing.Process(target=pool_in_process)
4702 proc = multiprocessing.Process(target=lambda: flike.flush())
4718 from multiprocessing.connection import wait
4724 r, w = multiprocessing.Pipe(duplex=False)
4725 p = multiprocessing.Process(target=self._child_test_wait, args=(w, slow))
4758 from multiprocessing.connection import wait
4766 p = multiprocessing.Process(target=self._child_test_wait_socket,
4799 from multiprocessing.connection import wait
4802 a, b = multiprocessing.Pipe()
4827 from multiprocessing.connection import wait
4831 sem = multiprocessing.Semaphore(0)
4832 a, b = multiprocessing.Pipe()
4833 p = multiprocessing.Process(target=self.signal_and_sleep,
4870 from multiprocessing.connection import wait
4871 a, b = multiprocessing.Pipe()
4889 multiprocessing.connection.Listener(r'\\.\test')
4894 multiprocessing.connection.Listener('/var/test.pipe')
4908 r, w = multiprocessing.Pipe(duplex=False)
4909 p = multiprocessing.Process(target=cls.run_in_grandchild, args=(w,))
4938 conn = multiprocessing.connection.Client(address)
4946 parent, child = multiprocessing.Pipe(duplex=True)
4947 l = multiprocessing.connection.Listener(family='AF_INET')
4948 p = multiprocessing.Process(target=self._test_timeout,
4968 sm = multiprocessing.get_start_method()
4991 p = multiprocessing.Process(target=cls.child, args=(n-1, conn))
5000 r, w = multiprocessing.Pipe(False)
5003 p = multiprocessing.Process(target=self.child, args=(5, w))
5054 reader, writer = multiprocessing.Pipe()
5057 p = multiprocessing.Process(target=self._test_closefds,
5068 if multiprocessing.get_start_method() == 'fork':
5097 conn, child_conn = multiprocessing.Pipe()
5099 p = multiprocessing.Process(target=self._test_ignore,
5123 with multiprocessing.connection.Listener() as l:
5130 conn, child_conn = multiprocessing.Pipe()
5132 p = multiprocessing.Process(target=self._test_ignore_listener,
5141 client = multiprocessing.connection.Client(address)
5150 conn.send(multiprocessing.get_start_method())
5165 ctx = multiprocessing.get_context(method)
5175 multiprocessing.set_forkserver_preload(PRELOAD)
5177 old_method = multiprocessing.get_start_method()
5181 multiprocessing.set_start_method(method, force=True)
5184 self.assertEqual(multiprocessing.get_start_method(), method)
5185 ctx = multiprocessing.get_context()
5190 self.check_context(multiprocessing)
5193 multiprocessing.set_start_method(old_method, force=True)
5197 methods = multiprocessing.get_all_start_methods()
5207 if multiprocessing.get_start_method() != 'forkserver':
5300 from multiprocessing.resource_tracker import _resource_tracker
5313 ctx = multiprocessing.get_context("spawn")
5348 from multiprocessing.resource_tracker import _resource_tracker
5357 from multiprocessing.resource_tracker import _resource_tracker
5361 r, w = multiprocessing.Pipe(duplex=False)
5362 p = multiprocessing.Process(target=self._is_resource_tracker_reused,
5388 queue = multiprocessing.SimpleQueue()
5389 child_can_start = multiprocessing.Event()
5390 parent_can_continue = multiprocessing.Event()
5392 proc = multiprocessing.Process(
5412 queue = multiprocessing.SimpleQueue()
5420 queue = multiprocessing.SimpleQueue()
5459 p = multiprocessing.pool.Pool(5, context=unittest.mock.MagicMock(
5490 manager_class = multiprocessing.managers.SyncManager
5518 while len(multiprocessing.active_children()) > 1:
5530 self.proc = multiprocessing.Process(target=worker, args=(obj, ))
5705 support.check__all__(self, multiprocessing, extra=multiprocessing.__all__,
5716 cls.dangling = (multiprocessing.process._dangling.copy(),
5725 processes = set(multiprocessing.process._dangling) - set(cls.dangling[0])
5740 Process = multiprocessing.Process
5741 connection = multiprocessing.connection
5742 current_process = staticmethod(multiprocessing.current_process)
5743 parent_process = staticmethod(multiprocessing.parent_process)
5744 active_children = staticmethod(multiprocessing.active_children)
5745 Pool = staticmethod(multiprocessing.Pool)
5746 Pipe = staticmethod(multiprocessing.Pipe)
5747 Queue = staticmethod(multiprocessing.Queue)
5748 JoinableQueue = staticmethod(multiprocessing.JoinableQueue)
5749 Lock = staticmethod(multiprocessing.Lock)
5750 RLock = staticmethod(multiprocessing.RLock)
5751 Semaphore = staticmethod(multiprocessing.Semaphore)
5752 BoundedSemaphore = staticmethod(multiprocessing.BoundedSemaphore)
5753 Condition = staticmethod(multiprocessing.Condition)
5754 Event = staticmethod(multiprocessing.Event)
5755 Barrier = staticmethod(multiprocessing.Barrier)
5756 Value = staticmethod(multiprocessing.Value)
5757 Array = staticmethod(multiprocessing.Array)
5758 RawValue = staticmethod(multiprocessing.RawValue)
5759 RawArray = staticmethod(multiprocessing.RawArray)
5764 Process = multiprocessing.Process
5787 cls.manager = multiprocessing.Manager()
5796 while len(multiprocessing.active_children()) > 1:
5825 Process = multiprocessing.dummy.Process
5826 connection = multiprocessing.dummy.connection
5827 current_process = staticmethod(multiprocessing.dummy.current_process)
5828 active_children = staticmethod(multiprocessing.dummy.active_children)
5829 Pool = staticmethod(multiprocessing.dummy.Pool)
5830 Pipe = staticmethod(multiprocessing.dummy.Pipe)
5831 Queue = staticmethod(multiprocessing.dummy.Queue)
5832 JoinableQueue = staticmethod(multiprocessing.dummy.JoinableQueue)
5833 Lock = staticmethod(multiprocessing.dummy.Lock)
5834 RLock = staticmethod(multiprocessing.dummy.RLock)
5835 Semaphore = staticmethod(multiprocessing.dummy.Semaphore)
5836 BoundedSemaphore = staticmethod(multiprocessing.dummy.BoundedSemaphore)
5837 Condition = staticmethod(multiprocessing.dummy.Condition)
5838 Event = staticmethod(multiprocessing.dummy.Event)
5839 Barrier = staticmethod(multiprocessing.dummy.Barrier)
5840 Value = staticmethod(multiprocessing.dummy.Value)
5841 Array = staticmethod(multiprocessing.dummy.Array)
5880 multiprocessing.set_forkserver_preload(PRELOAD)
5881 multiprocessing.process._cleanup()
5882 dangling[0] = multiprocessing.process._dangling.copy()
5884 old_start_method[0] = multiprocessing.get_start_method(allow_none=True)
5886 multiprocessing.set_start_method(start_method, force=True)
5893 lock = multiprocessing.RLock()
5899 multiprocessing.get_logger().setLevel(LOG_LEVEL)
5908 multiprocessing.set_start_method(old_start_method[0], force=True)
5910 processes = set(multiprocessing.process._dangling) - set(dangling[0])
5928 multiprocessing.util._cleanup_tests()