Lines Matching defs:Process
213 p = self.Process(
254 p = self.Process(target=self._test_terminate)
287 p = self.Process(target=time.sleep, args=(DELTA,))
303 p = cls.Process(
343 p = self.Process(target=self._test_sys_exit, args=(reason, testfn))
353 p = self.Process(target=sys.exit, args=(reason,))
363 class _UpperCaser(multiprocessing.Process):
366 multiprocessing.Process.__init__(self)
431 proc = self.Process(
498 proc = self.Process(
550 # process cannot shutdown until the feeder thread has finished
555 # thread for a forked process if the original process had its
561 # put items on queue so that main process starts a feeder thread
565 # wait to make sure thread starts before we fork a new process
568 # fork process
569 p = self.Process(target=self._test_fork, args=(queue,))
607 workers = [self.Process
733 p = self.Process(target=self.f, args=(cond, sleeping, woken))
745 # check no process/thread has woken up
749 # wake up one process/thread
754 # check one process/thread has woken up
778 p = self.Process(target=self.f,
802 p = self.Process(target=self.f, args=(cond, sleeping, woken))
814 # check no process/thread has woken up
876 p = self.Process(target=self._test_event, args=(event,))
917 proc = self.Process(target=self._test, args=(values,))
981 p = self.Process(target=self.f, args=(arr,))
1170 # On Unix a forked process increfs each shared object to
1171 # which its parent process held a reference. If the
1172 # forked process gets terminated then there is likely to
1234 # (countdown * DELTA = 5 seconds max startup process time)
1275 multiprocessing.active_children() # discard dead process objs
1361 '''manager class used by server process'''
1392 p = self.Process(target=self._putter, args=(manager.address, authkey))
1434 p = self.Process(target=self._putter, args=(manager.address, authkey))
1465 p = self.Process(target=self._echo, args=(child_conn,))
1553 # process immediately after child is spawned. On Windows this
1559 p = self.Process(target=self._echo, args=(child_conn,))
1633 p = self.Process(target=self._writefd, args=(child_conn, b"foo"))
1658 p = self.Process(target=self._writefd, args=(child_conn, b"bar", True))
1690 p = self.Process(target=self._send_data_without_fd, args=(child_conn,))
1709 p = self.Process(target=self._test, args=(l.address,))
1719 p = self.Process(target=self._test, args=(l.address,))
1723 # On Windows the client process should by now have connected,
1782 lp = self.Process(target=self._listener, args=(lconn0, families))
1788 rp = self.Process(target=self._remote, args=(rconn0,))
1926 p = self.Process(target=self._double, args=(x, y, foo, arr, string))
1990 # call multiprocessing's cleanup function then exit process without
1999 p = self.Process(target=self._test_finalize, args=(child_conn,))
2019 'multiprocessing.pool', 'multiprocessing.process',
2072 p = self.Process(target=self._test_level, args=(writer,))
2079 p = self.Process(target=self._test_level, args=(writer,))
2108 # Check that Process.join() retries if os.waitpid() fails with EINTR
2128 killer = self.Process(target=self._killer, args=(pid,))
2130 p = self.Process(target=time.sleep, args=(1,))
2187 Process = multiprocessing.Process
2201 Process = multiprocessing.Process
2215 Process = multiprocessing.dummy.Process
2286 # Issue 5155, 5313, 5331: Test process in processes
2298 subProc = multiprocessing.Process(target=_ThisSubProcess, args=(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())
2372 p = multiprocessing.Process(target=self._test_timeout,
2415 p = multiprocessing.Process(target=cls.run_in_grandchild, args=(w,))
2426 # start child process using unusual flags
2446 p = multiprocessing.Process(target=cls.child, args=(n-1, conn))
2457 p = multiprocessing.Process(target=self.child, args=(5, w))
