Lines Matching refs:submit

147         futures = [self.executor.submit(time.sleep, 0.1)
213         futures = [self.executor.submit(get_init_status)
241                 future = self.executor.submit(get_init_status)
256                 self.executor.submit(get_init_status)
287                           self.executor.submit,
341         fs = [self.executor.submit(time.sleep, 0.1) for _ in range(50)]
348         fs = [executor.submit(time.sleep, .1) for _ in range(50)]
400             self.executor.submit(acquire_lock, sem)
496             self.executor.submit(acquire_lock, sem)
566         future1 = self.executor.submit(mul, 21, 2)
567         future2 = self.executor.submit(time.sleep, 1.5)
577         future1 = self.executor.submit(time.sleep, 1.5)
589         future1 = self.executor.submit(mul, 2, 21)
590         future2 = self.executor.submit(sleep_and_raise, 1.5)
591         future3 = self.executor.submit(time.sleep, 3)
601         future1 = self.executor.submit(divmod, 21, 0)
602         future2 = self.executor.submit(time.sleep, 1.5)
617         future1 = self.executor.submit(time.sleep, 2)
627         future1 = self.executor.submit(divmod, 2, 0)
628         future2 = self.executor.submit(mul, 2, 21)
646         future1 = self.executor.submit(mul, 6, 7)
647         future2 = self.executor.submit(time.sleep, 6)
675             fs = {self.executor.submit(future_func) for i in range(100)}
691         future1 = self.executor.submit(mul, 2, 21)
692         future2 = self.executor.submit(mul, 7, 6)
707         future1 = self.executor.submit(time.sleep, 2)
729         future1 = self.executor.submit(time.sleep, 2)
775         future = self.executor.submit(pow, 2, 8)
779         future = self.executor.submit(mul, 2, y=8)
781         future = self.executor.submit(capture, 1, self=2, fn=3)
784             self.executor.submit(fn=capture, arg=1)
786             self.executor.submit(arg=1)
833         self.executor.submit(my_object.my_method)
879             executor.submit(acquire_lock, sem)
887         executor.submit(mul, 21, 2).result()
888         executor.submit(mul, 6, 7).result()
889         executor.submit(mul, 3, 14).result()
905         futures = [self.executor.submit(time.sleep, 3)]
912         self.assertRaises(BrokenProcessPool, self.executor.submit, pow, 2, 8)
937         future = self.executor.submit(self._test_traceback)
962         future = self.executor.submit(id, obj)
982                 executor.submit(sem.acquire)
991         executor.submit(mul, 21, 2).result()
992         executor.submit(mul, 6, 7).result()
993         executor.submit(mul, 3, 14).result()
999         executor.submit(mul, 12, 7).result()
1000         executor.submit(mul, 33, 25)
1001         executor.submit(mul, 25, 26).result()
1002         executor.submit(mul, 18, 29)
1108         res = executor.submit(func, *args)
1188             f = executor.submit(_crash, delay=.1)
1205             executor.submit(id, 42).result()
1210             f = executor.submit(id, ErrorAtPickle())