Lines Matching refs:multiprocessing
29 import multiprocessing.dummy
30 import multiprocessing.connection
31 import multiprocessing.managers
32 import multiprocessing.heap
33 import multiprocessing.pool
35 from multiprocessing import util
38 from multiprocessing import reduction
44 from multiprocessing.sharedctypes import Value, copy
276 cpus = multiprocessing.cpu_count()
297 from multiprocessing import forking
361 class _UpperCaser(multiprocessing.Process):
364 multiprocessing.Process.__init__(self)
365 self.child_conn, self.parent_conn = multiprocessing.Pipe()
1160 except multiprocessing.TimeoutError:
1172 self.assertRaises(multiprocessing.TimeoutError, get, timeout=TIMEOUT2)
1241 self.assertRaises(ValueError, multiprocessing.Pool, -1)
1242 self.assertRaises(ValueError, multiprocessing.Pool, 0)
1244 p = multiprocessing.Pool(3)
1278 from multiprocessing.pool import MaybeEncodingError
1279 p = multiprocessing.Pool(2)
1293 p = multiprocessing.Pool(3, maxtasksperchild=10)
1324 p = multiprocessing.Pool(3, maxtasksperchild=1)
1348 multiprocessing.active_children() # discard dead process objs
1362 from multiprocessing.managers import BaseManager, BaseProxy, RemoteError
1585 except multiprocessing.BufferTooShort, e:
1920 b = multiprocessing.heap.BufferWrapper(size)
1927 heap = multiprocessing.heap.BufferWrapper._heap
1967 a = multiprocessing.heap.BufferWrapper(1)
1968 b = multiprocessing.heap.BufferWrapper(1)
2132 logger = multiprocessing.get_logger()
2141 logger = multiprocessing.get_logger()
2148 logger = multiprocessing.get_logger()
2152 reader, writer = multiprocessing.Pipe(duplex=False)
2270 Process = multiprocessing.Process
2271 locals().update(get_attributes(multiprocessing, (
2284 Process = multiprocessing.Process
2285 manager = object.__new__(multiprocessing.managers.SyncManager)
2298 Process = multiprocessing.dummy.Process
2299 locals().update(get_attributes(multiprocessing.dummy, (
2317 self.assertRaises(multiprocessing.AuthenticationError,
2318 multiprocessing.connection.deliver_challenge,
2328 return multiprocessing.connection.CHALLENGE
2334 self.assertRaises(multiprocessing.AuthenticationError,
2335 multiprocessing.connection.answer_challenge,
2347 self.mgr = multiprocessing.Manager()
2355 m = multiprocessing.managers.SyncManager()
2362 self.assertRaises(TypeError, multiprocessing.Pool, initializer=1)
2363 p = multiprocessing.Pool(1, initializer, (self.ns,))
2380 queue = multiprocessing.Queue()
2381 subProc = multiprocessing.Process(target=_this_sub_process, args=(queue,))
2390 pool = multiprocessing.Pool(processes=4)
2417 queue = multiprocessing.Queue()
2418 proc = multiprocessing.Process(target=_test_process, args=(queue,))
2423 p = multiprocessing.Process(target=pool_in_process)
2431 proc = multiprocessing.Process(target=lambda: flike.flush())
2445 conn = multiprocessing.connection.Client(address)
2453 parent, child = multiprocessing.Pipe(duplex=True)
2454 l = multiprocessing.connection.Listener(family='AF_INET')
2455 p = multiprocessing.Process(target=self._test_timeout,
2497 r, w = multiprocessing.Pipe(duplex=False)
2498 p = multiprocessing.Process(target=cls.run_in_grandchild, args=(w,))
2530 p = multiprocessing.Process(target=cls.child, args=(n-1, conn))
2538 r, w = multiprocessing.Pipe(False)
2541 p = multiprocessing.Process(target=self.child, args=(5, w))
2565 conn, child_conn = multiprocessing.Pipe()
2567 p = multiprocessing.Process(target=self._test_ignore,
2591 l = multiprocessing.connection.Listener()
2598 conn, child_conn = multiprocessing.Pipe()
2600 p = multiprocessing.Process(target=self._test_ignore_listener,
2609 client = multiprocessing.connection.Client(address)
2630 lock = multiprocessing.RLock()
2641 multiprocessing.get_logger().setLevel(LOG_LEVEL)
2643 ProcessesMixin.pool = multiprocessing.Pool(4)
2644 ThreadsMixin.pool = multiprocessing.dummy.Pool(4)