Lines Matching defs:wait
132 from multiprocessing.connection import wait
137 return wait([handle], timeout)
565 event.wait(10.0)
672 evt.wait()
719 # A child process should wait for non-daemonic threads to end
962 child_can_start.wait()
1018 parent_can_continue.wait()
1028 child_can_start.wait()
1051 parent_can_continue.wait()
1109 # wait to make sure thread starts before we fork a new process
1366 cond.wait(timeout)
1407 # wait for both children to start sleeping
1456 # wait for them all to sleep
1480 # wait for them to all sleep
1516 # wait for them to all sleep
1551 wait = TimingWrapper(cond.wait)
1553 res = wait(TIMEOUT1)
1556 self.assertTimingAlmostEqual(wait.elapsed, TIMEOUT1)
1643 self.assertFalse(c.wait(0))
1644 self.assertFalse(c.wait(0.1))
1649 self.assertTrue(c.wait(60))
1651 self.assertRaises(KeyboardInterrupt, c.wait, 60)
1665 wait = TimingWrapper(event.wait)
1671 # Removed, threading.Event.wait() will return the value of the __flag
1673 self.assertEqual(wait(0.0), False)
1674 self.assertTimingAlmostEqual(wait.elapsed, 0.0)
1675 self.assertEqual(wait(TIMEOUT1), False)
1676 self.assertTimingAlmostEqual(wait.elapsed, TIMEOUT1)
1682 self.assertEqual(wait(), True)
1683 self.assertTimingAlmostEqual(wait.elapsed, 0.0)
1684 self.assertEqual(wait(TIMEOUT1), True)
1685 self.assertTimingAlmostEqual(wait.elapsed, 0.0)
1695 self.assertEqual(wait(), True)
1744 # A crude wait/yield function not relying on synchronization primitives.
1787 self._can_exit.wait(30)
1849 barrier.wait()
1852 barrier.wait()
1874 res = barrier.wait()
1879 test the return value from barrier.wait
1889 barrier.wait()
1905 i = barrier.wait()
1908 barrier.wait()
1929 i = barrier.wait()
1937 barrier.wait()
1942 barrier.wait()
1962 i = barrier.wait()
1965 barrier.wait()
1974 if barrier2.wait() == cls.N//2:
1976 barrier2.wait()
1977 barrier.wait()
1997 i = barrier.wait()
2002 barrier.wait(0.5)
2008 Test wait(timeout)
2016 i = barrier.wait(cls.defaultTimeout)
2021 barrier.wait()
2036 b.wait()
2037 b.wait()
2042 barrier.wait()
2378 def sqr(x, wait=0.0):
2379 time.sleep(wait)
2385 def raise_large_valuerror(wait):
2386 time.sleep(wait)
2460 error_callback=call_args.append).wait()
2465 error_callback=call_args.append).wait()
2628 # Sanity check the pool didn't wait for all tasks to finish
4319 p.wait()
4785 from multiprocessing.connection import wait
4801 for r in wait(readers):
4825 from multiprocessing.connection import wait
4847 for r in wait(readers):
4866 from multiprocessing.connection import wait
4872 res = wait([a, b], expected)
4882 res = wait([a, b], 20)
4894 from multiprocessing.connection import wait
4908 res = wait([a, p.sentinel, b], expected + 20)
4918 res = wait([a, p.sentinel, b], 20)
4927 res = wait([a, p.sentinel, b], 20)
4937 from multiprocessing.connection import wait
4940 res = wait([a], timeout=-1)
5340 p.wait()
5454 child_can_start.wait()
5477 parent_can_continue.wait()
5588 # but this can take a bit on slow machines, so wait a few seconds
5614 obj.wait()
5616 obj.wait(0.001)
5623 o.wait(0.001)
5897 # but this can take a bit on slow machines, so wait a few seconds