Lines Matching defs:submit
225 futures = [self.executor.submit(get_init_status)
253 future = self.executor.submit(get_init_status)
266 # ... and from this point submit() is guaranteed to fail
268 self.executor.submit(get_init_status)
296 self.executor.submit,
313 t.submit(sleep_and_print, 1.0, "apple")
328 t.submit(id, None)
341 t.submit(id, 42).result()
350 fs = [self.executor.submit(time.sleep, 0.1) for _ in range(50)]
357 fs = [self.executor.submit(time.sleep, .1) for _ in range(50)]
393 t.submit(sleep_and_print, 1.0, "apple")
417 executor.submit(int).result()
421 executor.submit(int).cancel()
435 self.executor.submit(acquire_lock, sem)
513 t.submit(sleep_and_print, .1, "apple")
536 self.executor.submit(acquire_lock, sem)
610 future = self.executor.submit(time.sleep, 1.5)
618 future1 = self.executor.submit(mul, 21, 2)
619 future2 = self.executor.submit(time.sleep, 1.5)
629 future1 = self.executor.submit(time.sleep, 1.5)
641 future1 = self.executor.submit(mul, 2, 21)
642 future2 = self.executor.submit(sleep_and_raise, 1.5)
643 future3 = self.executor.submit(time.sleep, 3)
653 future1 = self.executor.submit(divmod, 21, 0)
654 future2 = self.executor.submit(time.sleep, 1.5)
669 future1 = self.executor.submit(time.sleep, 2)
679 future1 = self.executor.submit(divmod, 2, 0)
680 future2 = self.executor.submit(mul, 2, 21)
698 future1 = self.executor.submit(mul, 6, 7)
699 future2 = self.executor.submit(time.sleep, 6)
727 fs = {self.executor.submit(future_func) for i in range(100)}
743 future1 = self.executor.submit(mul, 2, 21)
744 future2 = self.executor.submit(mul, 7, 6)
759 future1 = self.executor.submit(time.sleep, 2)
781 future1 = self.executor.submit(time.sleep, 2)
829 future = self.executor.submit(pow, 2, 8)
833 future = self.executor.submit(mul, 2, y=8)
835 future = self.executor.submit(capture, 1, self=2, fn=3)
838 self.executor.submit(fn=capture, arg=1)
840 self.executor.submit(arg=1)
887 self.executor.submit(my_object.my_method)
934 executor.submit(acquire_lock, sem)
942 executor.submit(mul, 21, 2).result()
943 executor.submit(mul, 6, 7).result()
944 executor.submit(mul, 3, 14).result()
952 def submit(pool):
953 pool.submit(submit, pool)
956 pool.submit(submit, pool)
960 workers.submit(tuple)
974 # submit work to saturate the pool
975 fut = pool.submit(log_n_wait, ident="first")
1001 futures = [self.executor.submit(time.sleep, 3)]
1008 self.assertRaises(BrokenProcessPool, self.executor.submit, pow, 2, 8)
1033 future = self.executor.submit(self._test_traceback)
1058 future = self.executor.submit(id, obj)
1077 executor.submit(sem.acquire)
1087 executor.submit(mul, 21, 2).result()
1088 executor.submit(mul, 6, 7).result()
1089 executor.submit(mul, 3, 14).result()
1097 executor.submit(mul, 12, 7).result()
1098 executor.submit(mul, 33, 25)
1099 executor.submit(mul, 25, 26).result()
1100 executor.submit(mul, 18, 29)
1101 executor.submit(mul, 1, 2).result()
1102 executor.submit(mul, 0, 9)
1116 f1 = executor.submit(os.getpid)
1119 f2 = executor.submit(os.getpid)
1122 f3 = executor.submit(os.getpid)
1127 f4 = executor.submit(os.getpid)
1150 futures.append(executor.submit(mul, i, i))
1258 res = executor.submit(func, *args)
1338 f = executor.submit(_crash, delay=.1)
1355 executor.submit(id, 42).result()
1360 f = executor.submit(id, ErrorAtPickle())