Lines Matching full:join
96 # (join() and is_alive(), the support function can be reused
273 p.join()
293 p.join()
331 p.join()
360 p.join()
377 parent_process().join(timeout=support.SHORT_TIMEOUT)
413 p.join()
432 p.join()
462 join = TimingWrapper(p.join)
464 self.assertEqual(join(0), None)
465 self.assertTimingAlmostEqual(join.elapsed, 0.0)
468 self.assertEqual(join(-1), None)
469 self.assertTimingAlmostEqual(join.elapsed, 0.0)
481 raise RuntimeError('join took too long: %s' % p)
485 self.assertEqual(join(), None)
490 self.assertEqual(join(), None)
492 self.assertTimingAlmostEqual(join.elapsed, 0.0)
497 p.join()
529 p.join()
541 p.join()
575 self.addCleanup(p.join)
580 p.join()
602 p.join()
609 p.join()
663 p.join()
702 p.join()
727 proc.join()
755 proc.join()
772 proc.join()
813 proc2.join()
817 proc.join()
868 uppercaser.join()
879 proc.join()
1023 proc.join()
1086 proc.join()
1122 p.join()
1160 queue.join()
1166 p.join()
1400 self.addCleanup(p.join)
1405 self.addCleanup(p.join)
1435 p.join()
1448 self.addCleanup(p.join)
1454 self.addCleanup(t.join)
1473 self.addCleanup(p.join)
1478 self.addCleanup(t.join)
1509 self.addCleanup(p.join)
1514 self.addCleanup(t.join)
1653 p.join()
1696 p.join()
1776 p.join()
2056 self.addCleanup(p.join)
2102 proc.join()
2166 p.join()
2423 cls.pool.join()
2619 p.join()
2626 join = TimingWrapper(self.pool.join)
2627 join()
2629 self.assertLess(join.elapsed, 2.0)
2641 p.join()
2650 p.join()
2668 p.join()
2693 p.join()
2704 p.join()
2708 # during map() would make Pool.join() deadlock, because a worker
2721 p.join()
2755 pool.join()
2763 pool.join()
2795 p.join()
2817 p.join()
2849 p.join()
2853 # before all the tasks completed would make join() hang.
2859 p.join()
3070 p.join()
3189 p.join()
3223 p.join()
3295 p.join()
3328 p.join()
3349 p.join()
3419 p.join()
3435 p.join()
3480 p.join()
3499 p.join()
3525 p.join()
3610 buf = b''.join(buf)
3619 lp.join()
3620 rp.join()
3661 p.join()
3809 p.join()
4056 p.join()
4066 p.join()
4413 p.join()
4482 pattern = os.path.join(glob.escape(folder), '*.py')
4551 p.join()
4559 p.join()
4586 # Check that Process.join() retries if os.waitpid() fails with EINTR
4611 p.join()
4613 killer.join()
4688 self.mgr.join()
4696 m.join()
4702 p.join()
4721 subProc.join()
4730 pool.join()
4750 self._delegate.write(''.join(self.cache))
4758 proc.join()
4763 p.join()
4798 self.addCleanup(p.join)
4838 self.addCleanup(p.join)
4855 expected = ''.join('%s\n' % i for i in range(10)).encode('ascii')
4857 self.assertEqual(b''.join(v), expected)
4934 p.join()
4979 p.join()
5036 name = os.path.join(os.path.dirname(__file__), 'mp_fork_bomb.py')
5181 p.join()
5210 p.join()
5226 p.join()
5276 name = os.path.join(os.path.dirname(__file__), 'mp_preload.py')
5435 p.join()
5484 proc.join()
5526 def join(self):
5537 p.join()
5575 self.proc.join()
5798 p.join()
5922 cls.manager.join()