Lines Matching refs:multiprocessing
2 # Unit tests for the multiprocessing package
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
79 # bpo-45200: Skip multiprocessing tests if Python is built with ASAN to
89 if isinstance(queue, multiprocessing.queues.Queue):
95 # Since multiprocessing.Process has the same API than threading.Thread
101 from multiprocessing import resource_tracker
132 from multiprocessing.connection import wait
339 from multiprocessing.process import parent_process
375 from multiprocessing.process import parent_process
502 exitcode = self._kill_process(multiprocessing.Process.terminate)
507 exitcode = self._kill_process(multiprocessing.Process.kill)
513 cpus = multiprocessing.cpu_count()
625 sm = multiprocessing.get_start_method()
680 sm = multiprocessing.get_start_method()
789 sm = multiprocessing.get_start_method()
795 from multiprocessing.forkserver import _forkserver
835 class _UpperCaser(multiprocessing.Process):
838 multiprocessing.Process.__init__(self)
839 self.child_conn, self.parent_conn = multiprocessing.Pipe()
1174 import multiprocessing
1176 q = multiprocessing.Queue()
1191 q = multiprocessing.Queue()
1249 class SafeQueue(multiprocessing.queues.Queue):
1260 q = SafeQueue(ctx=multiprocessing.get_context())
1272 for q in multiprocessing.Queue(), multiprocessing.JoinableQueue():
1723 wrapper = multiprocessing.heap.BufferWrapper(struct.calcsize('i'))
1724 lock = multiprocessing.Lock()
2080 self.skipTest("requires multiprocessing.sharedctypes")
2482 except multiprocessing.TimeoutError:
2520 self.assertRaises(multiprocessing.TimeoutError, get, timeout=TIMEOUT2)
2672 self.assertIs(type(cause), multiprocessing.pool.RemoteTraceback)
2766 pool._state = multiprocessing.pool.RUN
2769 ('unclosed running multiprocessing pool', ResourceWarning)):
2783 p = multiprocessing.Pool(2)
2798 from multiprocessing.pool import MaybeEncodingError
2799 p = multiprocessing.Pool(2)
2823 p = multiprocessing.Pool(3, maxtasksperchild=10)
2854 p = multiprocessing.Pool(3, maxtasksperchild=1)
2867 multiprocessing.Pool(3, maxtasksperchild=value)
2872 from multiprocessing import Pool
2891 from multiprocessing.managers import BaseManager, BaseProxy, RemoteError
3152 except multiprocessing.BufferTooShort as e:
3280 @unittest.skipUnless(HAS_REDUCTION, "test needs multiprocessing.reduction")
3299 @unittest.skipUnless(HAS_REDUCTION, "test needs multiprocessing.reduction")
3336 @unittest.skipUnless(HAS_REDUCTION, "test needs multiprocessing.reduction")
3531 @unittest.skipUnless(HAS_REDUCTION, "test needs multiprocessing.reduction")
3539 from multiprocessing import resource_sharer
3674 self.old_heap = multiprocessing.heap.BufferWrapper._heap
3675 multiprocessing.heap.BufferWrapper._heap = multiprocessing.heap.Heap()
3678 multiprocessing.heap.BufferWrapper._heap = self.old_heap
3687 heap = multiprocessing.heap.BufferWrapper._heap
3693 b = multiprocessing.heap.BufferWrapper(size)
3761 a = multiprocessing.heap.BufferWrapper(1)
3762 b = multiprocessing.heap.BufferWrapper(1)
3784 self.skipTest("requires multiprocessing.sharedctypes")
3834 @unittest.skipUnless(HAS_SHMEM, "requires multiprocessing.shared_memory")
3851 # running multiprocessing tests (test_multiprocessing_fork,
3894 'multiprocessing.shared_memory._make_filename') as mock_make_filename:
3971 'multiprocessing.shared_memory._make_filename') as mock_make_filename:
4045 # the failure when we run multiprocessing tests in parallel.
4075 smm = multiprocessing.managers.SharedMemoryManager()
4100 from multiprocessing.managers import SharedMemoryManager
4117 smm1 = multiprocessing.managers.SharedMemoryManager()
4136 with multiprocessing.managers.SharedMemoryManager() as smm2:
4303 from multiprocessing import shared_memory
4401 # call multiprocessing's cleanup function then exit process without
4481 folder = os.path.dirname(multiprocessing.__file__)
4485 modules = ['multiprocessing.' + m for m in modules]
4486 modules.remove('multiprocessing.__init__')
4487 modules.append('multiprocessing')
4493 modules.remove('multiprocessing.popen_fork')
4494 modules.remove('multiprocessing.popen_forkserver')
4495 modules.remove('multiprocessing.popen_spawn_posix')
4497 modules.remove('multiprocessing.popen_spawn_win32')
4499 modules.remove('multiprocessing.popen_forkserver')
4503 modules.remove('multiprocessing.sharedctypes')
4525 logger = multiprocessing.get_logger()
4534 logger = multiprocessing.get_logger()
4541 logger = multiprocessing.get_logger()
4545 reader, writer = multiprocessing.Pipe(duplex=False)
4569 # assert record.processName == multiprocessing.current_process().name
4578 # 'multiprocessing.test.TestLoggingProcessName')
4627 conn = multiprocessing.connection.Connection(44977608)
4638 multiprocessing.connection.Connection, -1)
4651 self.assertRaises(multiprocessing.AuthenticationError,
4652 multiprocessing.connection.deliver_challenge,
4662 return multiprocessing.connection.CHALLENGE
4668 self.assertRaises(multiprocessing.AuthenticationError,
4669 multiprocessing.connection.answer_challenge,
4682 self.mgr = multiprocessing.Manager()
4691 m = multiprocessing.managers.SyncManager()
4699 self.assertRaises(TypeError, multiprocessing.Pool, initializer=1)
4700 p = multiprocessing.Pool(1, initializer, (self.ns,))
4717 queue = multiprocessing.Queue()
4718 subProc = multiprocessing.Process(target=_this_sub_process, args=(queue,))
4727 pool = multiprocessing.Pool(processes=4)
4756 proc = multiprocessing.Process(target=_test_process)
4761 p = multiprocessing.Process(target=pool_in_process)
4769 proc = multiprocessing.Process(target=lambda: flike.flush())
4785 from multiprocessing.connection import wait
4791 r, w = multiprocessing.Pipe(duplex=False)
4792 p = multiprocessing.Process(target=self._child_test_wait, args=(w, slow))
4825 from multiprocessing.connection import wait
4833 p = multiprocessing.Process(target=self._child_test_wait_socket,
4866 from multiprocessing.connection import wait
4869 a, b = multiprocessing.Pipe()
4894 from multiprocessing.connection import wait
4898 sem = multiprocessing.Semaphore(0)
4899 a, b = multiprocessing.Pipe()
4900 p = multiprocessing.Process(target=self.signal_and_sleep,
4937 from multiprocessing.connection import wait
4938 a, b = multiprocessing.Pipe()
4956 multiprocessing.connection.Listener(r'\\.\test')
4961 multiprocessing.connection.Listener('/var/test.pipe')
4975 r, w = multiprocessing.Pipe(duplex=False)
4976 p = multiprocessing.Process(target=cls.run_in_grandchild, args=(w,))
5005 conn = multiprocessing.connection.Client(address)
5013 parent, child = multiprocessing.Pipe(duplex=True)
5014 l = multiprocessing.connection.Listener(family='AF_INET')
5015 p = multiprocessing.Process(target=self._test_timeout,
5035 sm = multiprocessing.get_start_method()
5058 p = multiprocessing.Process(target=cls.child, args=(n-1, conn))
5067 r, w = multiprocessing.Pipe(False)
5070 p = multiprocessing.Process(target=self.child, args=(5, w))
5121 reader, writer = multiprocessing.Pipe()
5124 p = multiprocessing.Process(target=self._test_closefds,
5135 if multiprocessing.get_start_method() == 'fork':
5149 # Sending CONN_MAX_SIZE bytes into a multiprocessing pipe must block
5164 conn, child_conn = multiprocessing.Pipe()
5166 p = multiprocessing.Process(target=self._test_ignore,
5190 with multiprocessing.connection.Listener() as l:
5197 conn, child_conn = multiprocessing.Pipe()
5199 p = multiprocessing.Process(target=self._test_ignore_listener,
5208 client = multiprocessing.connection.Client(address)
5217 conn.send(multiprocessing.get_start_method())
5232 ctx = multiprocessing.get_context(method)
5242 multiprocessing.set_forkserver_preload(PRELOAD)
5244 old_method = multiprocessing.get_start_method()
5248 multiprocessing.set_start_method(method, force=True)
5251 self.assertEqual(multiprocessing.get_start_method(), method)
5252 ctx = multiprocessing.get_context()
5257 self.check_context(multiprocessing)
5260 multiprocessing.set_start_method(old_method, force=True)
5264 methods = multiprocessing.get_all_start_methods()
5274 if multiprocessing.get_start_method() != 'forkserver':
5296 import multiprocessing as mp
5297 from multiprocessing import resource_tracker
5298 from multiprocessing.shared_memory import SharedMemory
5367 from multiprocessing.resource_tracker import _resource_tracker
5380 ctx = multiprocessing.get_context("spawn")
5415 from multiprocessing.resource_tracker import _resource_tracker
5424 from multiprocessing.resource_tracker import _resource_tracker
5428 r, w = multiprocessing.Pipe(duplex=False)
5429 p = multiprocessing.Process(target=self._is_resource_tracker_reused,
5463 queue = multiprocessing.SimpleQueue()
5464 child_can_start = multiprocessing.Event()
5465 parent_can_continue = multiprocessing.Event()
5467 proc = multiprocessing.Process(
5487 queue = multiprocessing.SimpleQueue()
5495 queue = multiprocessing.SimpleQueue()
5534 p = multiprocessing.pool.Pool(5, context=unittest.mock.MagicMock(
5565 manager_class = multiprocessing.managers.SyncManager
5593 while len(multiprocessing.active_children()) > 1:
5599 support.print_warning(f"multiprocessing.Manager still has "
5600 f"{multiprocessing.active_children()} "
5605 self.proc = multiprocessing.Process(target=worker, args=(obj, ))
5787 import multiprocessing as mp
5809 support.check__all__(self, multiprocessing, extra=multiprocessing.__all__,
5820 cls.dangling = (multiprocessing.process._dangling.copy(),
5825 # bpo-26762: Some multiprocessing objects like Pool create reference
5829 processes = set(multiprocessing.process._dangling) - set(cls.dangling[0])
5844 Process = multiprocessing.Process
5845 connection = multiprocessing.connection
5846 current_process = staticmethod(multiprocessing.current_process)
5847 parent_process = staticmethod(multiprocessing.parent_process)
5848 active_children = staticmethod(multiprocessing.active_children)
5849 set_executable = staticmethod(multiprocessing.set_executable)
5850 Pool = staticmethod(multiprocessing.Pool)
5851 Pipe = staticmethod(multiprocessing.Pipe)
5852 Queue = staticmethod(multiprocessing.Queue)
5853 JoinableQueue = staticmethod(multiprocessing.JoinableQueue)
5854 Lock = staticmethod(multiprocessing.Lock)
5855 RLock = staticmethod(multiprocessing.RLock)
5856 Semaphore = staticmethod(multiprocessing.Semaphore)
5857 BoundedSemaphore = staticmethod(multiprocessing.BoundedSemaphore)
5858 Condition = staticmethod(multiprocessing.Condition)
5859 Event = staticmethod(multiprocessing.Event)
5860 Barrier = staticmethod(multiprocessing.Barrier)
5861 Value = staticmethod(multiprocessing.Value)
5862 Array = staticmethod(multiprocessing.Array)
5863 RawValue = staticmethod(multiprocessing.RawValue)
5864 RawArray = staticmethod(multiprocessing.RawArray)
5869 Process = multiprocessing.Process
5892 cls.manager = multiprocessing.Manager()
5901 while len(multiprocessing.active_children()) > 1:
5907 support.print_warning(f"multiprocessing.Manager still has "
5908 f"{multiprocessing.active_children()} "
5930 Process = multiprocessing.dummy.Process
5931 connection = multiprocessing.dummy.connection
5932 current_process = staticmethod(multiprocessing.dummy.current_process)
5933 active_children = staticmethod(multiprocessing.dummy.active_children)
5934 Pool = staticmethod(multiprocessing.dummy.Pool)
5935 Pipe = staticmethod(multiprocessing.dummy.Pipe)
5936 Queue = staticmethod(multiprocessing.dummy.Queue)
5937 JoinableQueue = staticmethod(multiprocessing.dummy.JoinableQueue)
5938 Lock = staticmethod(multiprocessing.dummy.Lock)
5939 RLock = staticmethod(multiprocessing.dummy.RLock)
5940 Semaphore = staticmethod(multiprocessing.dummy.Semaphore)
5941 BoundedSemaphore = staticmethod(multiprocessing.dummy.BoundedSemaphore)
5942 Condition = staticmethod(multiprocessing.dummy.Condition)
5943 Event = staticmethod(multiprocessing.dummy.Event)
5944 Barrier = staticmethod(multiprocessing.dummy.Barrier)
5945 Value = staticmethod(multiprocessing.dummy.Value)
5946 Array = staticmethod(multiprocessing.dummy.Array)
5985 multiprocessing.set_forkserver_preload(PRELOAD)
5986 multiprocessing.process._cleanup()
5987 dangling[0] = multiprocessing.process._dangling.copy()
5989 old_start_method[0] = multiprocessing.get_start_method(allow_none=True)
5991 multiprocessing.set_start_method(start_method, force=True)
5998 lock = multiprocessing.RLock()
6004 multiprocessing.get_logger().setLevel(LOG_LEVEL)
6009 # bpo-26762: Some multiprocessing objects like Pool create reference
6013 multiprocessing.set_start_method(old_start_method[0], force=True)
6015 processes = set(multiprocessing.process._dangling) - set(dangling[0])
6033 multiprocessing.util._cleanup_tests()