Lines Matching refs:result
42 def create_future(state=PENDING, exception=None, result=None):
46 f._result = result
55 SUCCESSFUL_FUTURE = create_future(state=FINISHED, result=42)
229 self.assertEqual(f.result(), 'initialized')
259 future.result()
341 t.submit(id, 42).result()
353 f.result()
417 executor.submit(int).result()
792 futures_list.append(create_future(state=FINISHED, result=42))
830 self.assertEqual(256, future.result())
834 self.assertEqual(16, future.result())
836 self.assertEqual(future.result(), ((1,), {'self': 2, 'fn': 3}))
903 # reference to result objects.
942 executor.submit(mul, 21, 2).result()
943 executor.submit(mul, 6, 7).result()
944 executor.submit(mul, 3, 14).result()
984 fut.result()
985 # ident='second' is cancelled as a result of raising a TimeoutError
1006 self.assertRaises(BrokenProcessPool, fut.result)
1035 future.result()
1059 future.result()
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()
1099 executor.submit(mul, 25, 26).result()
1101 executor.submit(mul, 1, 2).result()
1117 original_pid = f1.result()
1120 self.assertEqual(f2.result(), original_pid)
1123 self.assertEqual(f3.result(), original_pid)
1128 new_pid = f4.result()
1153 self.assertEqual(future.result(), mul(i, i))
1268 res.result(timeout=self.TIMEOUT)
1305 # Check problem occurring while pickling a task result
1310 # Check problem occurring while pickling a task result
1315 # Check problem occurring while pickling a task result
1341 f.result()
1355 executor.submit(id, 42).result()
1363 f.result()
1381 callback_result = callback_future.result()
1436 callback_result = callback_future.result()
1472 # Set the result first to simulate a future that runs instantly,
1504 f6 = create_future(state=FINISHED, result=5)
1550 PENDING_FUTURE.result, timeout=0)
1552 RUNNING_FUTURE.result, timeout=0)
1554 CANCELLED_FUTURE.result, timeout=0)
1556 CANCELLED_AND_NOTIFIED_FUTURE.result, timeout=0)
1557 self.assertRaises(OSError, EXCEPTION_FUTURE.result, timeout=0)
1558 self.assertEqual(SUCCESSFUL_FUTURE.result(timeout=0), 42)
1563 # Wait until the main thread is waiting for the result.
1571 self.assertEqual(f1.result(timeout=5), 42)
1577 # Wait until the main thread is waiting for the result.
1586 f1.result, timeout=support.SHORT_TIMEOUT)
1630 self.assertEqual(f.result(), 1)