Lines Matching refs:multiprocessing
37 import multiprocessing.connection
38 import multiprocessing.dummy
39 import multiprocessing.heap
40 import multiprocessing.managers
41 import multiprocessing.pool
42 import multiprocessing.queues
44 from multiprocessing import util
47 from multiprocessing import reduction
53 from multiprocessing.sharedctypes import Value, copy
75 if isinstance(queue, multiprocessing.queues.Queue):
108 from multiprocessing.connection import wait
359 exitcode = self._kill_process(multiprocessing.Process.terminate)
364 exitcode = self._kill_process(multiprocessing.Process.kill)
370 cpus = multiprocessing.cpu_count()
482 sm = multiprocessing.get_start_method()
536 sm = multiprocessing.get_start_method()
645 sm = multiprocessing.get_start_method()
651 from multiprocessing.forkserver import _forkserver
691 class _UpperCaser(multiprocessing.Process):
694 multiprocessing.Process.__init__(self)
695 self.child_conn, self.parent_conn = multiprocessing.Pipe()
1038 q = multiprocessing.Queue()
1098 class SafeQueue(multiprocessing.queues.Queue):
1109 q = SafeQueue(ctx=multiprocessing.get_context())
1551 wrapper = multiprocessing.heap.BufferWrapper(struct.calcsize('i'))
1552 lock = multiprocessing.Lock()
2300 except multiprocessing.TimeoutError:
2338 self.assertRaises(multiprocessing.TimeoutError, get, timeout=TIMEOUT2)
2490 self.assertIs(type(cause), multiprocessing.pool.RemoteTraceback)
2569 p = multiprocessing.Pool(2)
2584 from multiprocessing.pool import MaybeEncodingError
2585 p = multiprocessing.Pool(2)
2609 p = multiprocessing.Pool(3, maxtasksperchild=10)
2640 p = multiprocessing.Pool(3, maxtasksperchild=1)
2654 from multiprocessing.managers import BaseManager, BaseProxy, RemoteError
2907 except multiprocessing.BufferTooShort as e:
3280 from multiprocessing import resource_sharer
3422 b = multiprocessing.heap.BufferWrapper(size)
3429 heap = multiprocessing.heap.BufferWrapper._heap
3469 a = multiprocessing.heap.BufferWrapper(1)
3470 b = multiprocessing.heap.BufferWrapper(1)
3669 folder = os.path.dirname(multiprocessing.__file__)
3713 logger = multiprocessing.get_logger()
3722 logger = multiprocessing.get_logger()
3729 logger = multiprocessing.get_logger()
3733 reader, writer = multiprocessing.Pipe(duplex=False)
3815 conn = multiprocessing.connection.Connection(44977608)
3826 multiprocessing.connection.Connection, -1)
3838 self.assertRaises(multiprocessing.AuthenticationError,
3839 multiprocessing.connection.deliver_challenge,
3849 return multiprocessing.connection.CHALLENGE
3855 self.assertRaises(multiprocessing.AuthenticationError,
3856 multiprocessing.connection.answer_challenge,
3868 self.mgr = multiprocessing.Manager()
3877 m = multiprocessing.managers.SyncManager()
3885 self.assertRaises(TypeError, multiprocessing.Pool, initializer=1)
3886 p = multiprocessing.Pool(1, initializer, (self.ns,))
3903 queue = multiprocessing.Queue()
3904 subProc = multiprocessing.Process(target=_this_sub_process, args=(queue,))
3913 pool = multiprocessing.Pool(processes=4)
3942 proc = multiprocessing.Process(target=_test_process)
3947 p = multiprocessing.Process(target=pool_in_process)
3955 proc = multiprocessing.Process(target=lambda: flike.flush())
3971 from multiprocessing.connection import wait
3977 r, w = multiprocessing.Pipe(duplex=False)
3978 p = multiprocessing.Process(target=self._child_test_wait, args=(w, slow))
4011 from multiprocessing.connection import wait
4021 p = multiprocessing.Process(target=self._child_test_wait_socket,
4054 from multiprocessing.connection import wait
4057 a, b = multiprocessing.Pipe()
4082 from multiprocessing.connection import wait
4086 sem = multiprocessing.Semaphore(0)
4087 a, b = multiprocessing.Pipe()
4088 p = multiprocessing.Process(target=self.signal_and_sleep,
4125 from multiprocessing.connection import wait
4126 a, b = multiprocessing.Pipe()
4144 multiprocessing.connection.Listener(r'\\.\test')
4149 multiprocessing.connection.Listener('/var/test.pipe')
4163 r, w = multiprocessing.Pipe(duplex=False)
4164 p = multiprocessing.Process(target=cls.run_in_grandchild, args=(w,))
4193 conn = multiprocessing.connection.Client(address)
4201 parent, child = multiprocessing.Pipe(duplex=True)
4202 l = multiprocessing.connection.Listener(family='AF_INET')
4203 p = multiprocessing.Process(target=self._test_timeout,
4223 sm = multiprocessing.get_start_method()
4246 p = multiprocessing.Process(target=cls.child, args=(n-1, conn))
4255 r, w = multiprocessing.Pipe(False)
4258 p = multiprocessing.Process(target=self.child, args=(5, w))
4309 reader, writer = multiprocessing.Pipe()
4312 p = multiprocessing.Process(target=self._test_closefds,
4323 if multiprocessing.get_start_method() == 'fork':
4352 conn, child_conn = multiprocessing.Pipe()
4354 p = multiprocessing.Process(target=self._test_ignore,
4378 with multiprocessing.connection.Listener() as l:
4385 conn, child_conn = multiprocessing.Pipe()
4387 p = multiprocessing.Process(target=self._test_ignore_listener,
4396 client = multiprocessing.connection.Client(address)
4405 conn.send(multiprocessing.get_start_method())
4420 ctx = multiprocessing.get_context(method)
4430 multiprocessing.set_forkserver_preload(PRELOAD)
4432 old_method = multiprocessing.get_start_method()
4436 multiprocessing.set_start_method(method, force=True)
4439 self.assertEqual(multiprocessing.get_start_method(), method)
4440 ctx = multiprocessing.get_context()
4445 self.check_context(multiprocessing)
4448 multiprocessing.set_start_method(old_method, force=True)
4452 methods = multiprocessing.get_all_start_methods()
4460 if multiprocessing.get_start_method() != 'forkserver':
4516 from multiprocessing.semaphore_tracker import _semaphore_tracker
4522 ctx = multiprocessing.get_context("spawn")
4560 queue = multiprocessing.SimpleQueue()
4561 child_can_start = multiprocessing.Event()
4562 parent_can_continue = multiprocessing.Event()
4564 proc = multiprocessing.Process(
4606 manager_class = multiprocessing.managers.SyncManager
4634 while len(multiprocessing.active_children()) > 1:
4642 % (multiprocessing.active_children(), dt),
4647 self.proc = multiprocessing.Process(target=worker, args=(obj, ))
4826 cls.dangling = (multiprocessing.process._dangling.copy(),
4835 processes = set(multiprocessing.process._dangling) - set(cls.dangling[0])
4852 Process = multiprocessing.Process
4853 connection = multiprocessing.connection
4854 current_process = staticmethod(multiprocessing.current_process)
4855 active_children = staticmethod(multiprocessing.active_children)
4856 Pool = staticmethod(multiprocessing.Pool)
4857 Pipe = staticmethod(multiprocessing.Pipe)
4858 Queue = staticmethod(multiprocessing.Queue)
4859 JoinableQueue = staticmethod(multiprocessing.JoinableQueue)
4860 Lock = staticmethod(multiprocessing.Lock)
4861 RLock = staticmethod(multiprocessing.RLock)
4862 Semaphore = staticmethod(multiprocessing.Semaphore)
4863 BoundedSemaphore = staticmethod(multiprocessing.BoundedSemaphore)
4864 Condition = staticmethod(multiprocessing.Condition)
4865 Event = staticmethod(multiprocessing.Event)
4866 Barrier = staticmethod(multiprocessing.Barrier)
4867 Value = staticmethod(multiprocessing.Value)
4868 Array = staticmethod(multiprocessing.Array)
4869 RawValue = staticmethod(multiprocessing.RawValue)
4870 RawArray = staticmethod(multiprocessing.RawArray)
4875 Process = multiprocessing.Process
4898 cls.manager = multiprocessing.Manager()
4907 while len(multiprocessing.active_children()) > 1:
4915 % (multiprocessing.active_children(), dt),
4937 Process = multiprocessing.dummy.Process
4938 connection = multiprocessing.dummy.connection
4939 current_process = staticmethod(multiprocessing.dummy.current_process)
4940 active_children = staticmethod(multiprocessing.dummy.active_children)
4941 Pool = staticmethod(multiprocessing.dummy.Pool)
4942 Pipe = staticmethod(multiprocessing.dummy.Pipe)
4943 Queue = staticmethod(multiprocessing.dummy.Queue)
4944 JoinableQueue = staticmethod(multiprocessing.dummy.JoinableQueue)
4945 Lock = staticmethod(multiprocessing.dummy.Lock)
4946 RLock = staticmethod(multiprocessing.dummy.RLock)
4947 Semaphore = staticmethod(multiprocessing.dummy.Semaphore)
4948 BoundedSemaphore = staticmethod(multiprocessing.dummy.BoundedSemaphore)
4949 Condition = staticmethod(multiprocessing.dummy.Condition)
4950 Event = staticmethod(multiprocessing.dummy.Event)
4951 Barrier = staticmethod(multiprocessing.dummy.Barrier)
4952 Value = staticmethod(multiprocessing.dummy.Value)
4953 Array = staticmethod(multiprocessing.dummy.Array)
4990 multiprocessing.set_forkserver_preload(PRELOAD)
4991 multiprocessing.process._cleanup()
4992 dangling[0] = multiprocessing.process._dangling.copy()
4994 old_start_method[0] = multiprocessing.get_start_method(allow_none=True)
4996 multiprocessing.set_start_method(start_method, force=True)
5003 lock = multiprocessing.RLock()
5009 multiprocessing.get_logger().setLevel(LOG_LEVEL)
5018 multiprocessing.set_start_method(old_start_method[0], force=True)
5020 processes = set(multiprocessing.process._dangling) - set(dangling[0])
5039 multiprocessing.process._cleanup()