Lines Matching refs:multiprocessing
4 # Unit tests for the multiprocessing package
29 test_support.import_module('multiprocessing.synchronize')
31 import multiprocessing.dummy
32 import multiprocessing.connection
33 import multiprocessing.managers
34 import multiprocessing.heap
35 import multiprocessing.pool
37 from multiprocessing import util
40 from multiprocessing import reduction
46 from multiprocessing.sharedctypes import Value, copy
278 cpus = multiprocessing.cpu_count()
299 from multiprocessing import forking
363 class _UpperCaser(multiprocessing.Process):
366 multiprocessing.Process.__init__(self)
367 self.child_conn, self.parent_conn = multiprocessing.Pipe()
898 self.skipTest("requires multiprocessing.sharedctypes")
1123 except multiprocessing.TimeoutError:
1135 self.assertRaises(multiprocessing.TimeoutError, get, timeout=TIMEOUT2)
1160 self.assertRaises(ValueError, multiprocessing.Pool, -1)
1161 self.assertRaises(ValueError, multiprocessing.Pool, 0)
1163 p = multiprocessing.Pool(3)
1205 from multiprocessing.pool import MaybeEncodingError
1206 p = multiprocessing.Pool(2)
1220 p = multiprocessing.Pool(3, maxtasksperchild=10)
1251 p = multiprocessing.Pool(3, maxtasksperchild=1)
1275 multiprocessing.active_children() # discard dead process objs
1289 from multiprocessing.managers import BaseManager, BaseProxy, RemoteError
1502 except multiprocessing.BufferTooShort, e:
1627 @unittest.skipUnless(HAS_REDUCTION, "test needs multiprocessing.reduction")
1645 @unittest.skipUnless(HAS_REDUCTION, "test needs multiprocessing.reduction")
1681 @unittest.skipUnless(HAS_REDUCTION, "test needs multiprocessing.reduction")
1775 multiprocessing.allow_connection_pickling()
1837 b = multiprocessing.heap.BufferWrapper(size)
1844 heap = multiprocessing.heap.BufferWrapper._heap
1884 a = multiprocessing.heap.BufferWrapper(1)
1885 b = multiprocessing.heap.BufferWrapper(1)
1906 self.skipTest("requires multiprocessing.sharedctypes")
1990 # call multiprocessing's cleanup function then exit process without
2017 'multiprocessing', 'multiprocessing.connection',
2018 'multiprocessing.heap', 'multiprocessing.managers',
2019 'multiprocessing.pool', 'multiprocessing.process',
2020 'multiprocessing.synchronize', 'multiprocessing.util'
2024 modules.append('multiprocessing.reduction')
2028 modules.append('multiprocessing.sharedctypes')
2049 logger = multiprocessing.get_logger()
2058 logger = multiprocessing.get_logger()
2065 logger = multiprocessing.get_logger()
2069 reader, writer = multiprocessing.Pipe(duplex=False)
2091 # assert record.processName == multiprocessing.current_process().name
2100 # 'multiprocessing.test.TestLoggingProcessName')
2187 Process = multiprocessing.Process
2188 locals().update(get_attributes(multiprocessing, (
2201 Process = multiprocessing.Process
2202 manager = object.__new__(multiprocessing.managers.SyncManager)
2215 Process = multiprocessing.dummy.Process
2216 locals().update(get_attributes(multiprocessing.dummy, (
2234 self.assertRaises(multiprocessing.AuthenticationError,
2235 multiprocessing.connection.deliver_challenge,
2245 return multiprocessing.connection.CHALLENGE
2251 self.assertRaises(multiprocessing.AuthenticationError,
2252 multiprocessing.connection.answer_challenge,
2264 self.mgr = multiprocessing.Manager()
2272 m = multiprocessing.managers.SyncManager()
2279 self.assertRaises(TypeError, multiprocessing.Pool, initializer=1)
2280 p = multiprocessing.Pool(1, initializer, (self.ns,))
2297 queue = multiprocessing.Queue()
2298 subProc = multiprocessing.Process(target=_ThisSubProcess, args=(queue,))
2307 pool = multiprocessing.Pool(processes=4)
2334 queue = multiprocessing.Queue()
2335 proc = multiprocessing.Process(target=_TestProcess, args=(queue,))
2340 p = multiprocessing.Process(target=pool_in_process)
2348 proc = multiprocessing.Process(target=lambda: flike.flush())
2362 conn = multiprocessing.connection.Client(address)
2370 parent, child = multiprocessing.Pipe(duplex=True)
2371 l = multiprocessing.connection.Listener(family='AF_INET')
2372 p = multiprocessing.Process(target=self._test_timeout,
2414 r, w = multiprocessing.Pipe(duplex=False)
2415 p = multiprocessing.Process(target=cls.run_in_grandchild, args=(w,))
2446 p = multiprocessing.Process(target=cls.child, args=(n-1, conn))
2454 r, w = multiprocessing.Pipe(False)
2457 p = multiprocessing.Process(target=self.child, args=(5, w))
2478 lock = multiprocessing.RLock()
2489 multiprocessing.get_logger().setLevel(LOG_LEVEL)
2491 ProcessesMixin.pool = multiprocessing.Pool(4)
2492 ThreadsMixin.pool = multiprocessing.dummy.Pool(4)