Lines Matching refs:multiprocessing
30 import multiprocessing.dummy
31 import multiprocessing.connection
32 import multiprocessing.managers
33 import multiprocessing.heap
34 import multiprocessing.pool
36 from multiprocessing import util
39 from multiprocessing import reduction
45 from multiprocessing.sharedctypes import Value, copy
283 cpus = multiprocessing.cpu_count()
304 from multiprocessing import forking
380 class _UpperCaser(multiprocessing.Process):
383 multiprocessing.Process.__init__(self)
384 self.child_conn, self.parent_conn = multiprocessing.Pipe()
1214 except multiprocessing.TimeoutError:
1226 self.assertRaises(multiprocessing.TimeoutError, get, timeout=TIMEOUT2)
1295 self.assertRaises(ValueError, multiprocessing.Pool, -1)
1296 self.assertRaises(ValueError, multiprocessing.Pool, 0)
1298 p = multiprocessing.Pool(3)
1347 from multiprocessing.pool import MaybeEncodingError
1348 p = multiprocessing.Pool(2)
1362 p = multiprocessing.Pool(3, maxtasksperchild=10)
1393 p = multiprocessing.Pool(3, maxtasksperchild=1)
1417 multiprocessing.active_children() # discard dead process objs
1431 from multiprocessing.managers import BaseManager, BaseProxy, RemoteError
1655 except multiprocessing.BufferTooShort, e:
1990 b = multiprocessing.heap.BufferWrapper(size)
1997 heap = multiprocessing.heap.BufferWrapper._heap
2037 a = multiprocessing.heap.BufferWrapper(1)
2038 b = multiprocessing.heap.BufferWrapper(1)
2263 logger = multiprocessing.get_logger()
2272 logger = multiprocessing.get_logger()
2279 logger = multiprocessing.get_logger()
2283 reader, writer = multiprocessing.Pipe(duplex=False)
2401 Process = multiprocessing.Process
2402 locals().update(get_attributes(multiprocessing, (
2415 Process = multiprocessing.Process
2416 manager = object.__new__(multiprocessing.managers.SyncManager)
2429 Process = multiprocessing.dummy.Process
2430 locals().update(get_attributes(multiprocessing.dummy, (
2448 self.assertRaises(multiprocessing.AuthenticationError,
2449 multiprocessing.connection.deliver_challenge,
2459 return multiprocessing.connection.CHALLENGE
2465 self.assertRaises(multiprocessing.AuthenticationError,
2466 multiprocessing.connection.answer_challenge,
2478 self.mgr = multiprocessing.Manager()
2486 m = multiprocessing.managers.SyncManager()
2493 self.assertRaises(TypeError, multiprocessing.Pool, initializer=1)
2494 p = multiprocessing.Pool(1, initializer, (self.ns,))
2511 queue = multiprocessing.Queue()
2512 subProc = multiprocessing.Process(target=_this_sub_process, args=(queue,))
2521 pool = multiprocessing.Pool(processes=4)
2548 queue = multiprocessing.Queue()
2549 proc = multiprocessing.Process(target=_test_process, args=(queue,))
2554 p = multiprocessing.Process(target=pool_in_process)
2562 proc = multiprocessing.Process(target=lambda: flike.flush())
2576 conn = multiprocessing.connection.Client(address)
2584 parent, child = multiprocessing.Pipe(duplex=True)
2585 l = multiprocessing.connection.Listener(family='AF_INET')
2586 p = multiprocessing.Process(target=self._test_timeout,
2628 r, w = multiprocessing.Pipe(duplex=False)
2629 p = multiprocessing.Process(target=cls.run_in_grandchild, args=(w,))
2661 p = multiprocessing.Process(target=cls.child, args=(n-1, conn))
2669 r, w = multiprocessing.Pipe(False)
2672 p = multiprocessing.Process(target=self.child, args=(5, w))
2699 conn, child_conn = multiprocessing.Pipe()
2701 p = multiprocessing.Process(target=self._test_ignore,
2725 l = multiprocessing.connection.Listener()
2732 conn, child_conn = multiprocessing.Pipe()
2734 p = multiprocessing.Process(target=self._test_ignore_listener,
2743 client = multiprocessing.connection.Client(address)
2764 lock = multiprocessing.RLock()
2775 multiprocessing.get_logger().setLevel(LOG_LEVEL)
2777 ProcessesMixin.pool = multiprocessing.Pool(4)
2778 ThreadsMixin.pool = multiprocessing.dummy.Pool(4)