Lines Matching refs:cancelled
360 # guarantee that *some* were cancelled. With few workers, many of
361 # the submitted futures should have been cancelled.
362 cancelled = [fut for fut in fs if fut.cancelled()]
363 self.assertGreater(len(cancelled), 20)
366 # Use "not fut.cancelled()" instead of "fut.done()" to include futures
368 others = [fut for fut in fs if not fut.cancelled()]
373 # Similar to the number of cancelled futures, we can't guarantee the
985 # ident='second' is cancelled as a result of raising a TimeoutError
986 # ident='third' is cancelled because it remained in the collection of futures
1403 was_cancelled = callback_future.cancelled()
1458 was_cancelled = callback_future.cancelled()
1487 '<Future at 0x[0-9a-f]+ state=cancelled>')
1489 '<Future at 0x[0-9a-f]+ state=cancelled>')
1525 self.assertFalse(PENDING_FUTURE.cancelled())
1526 self.assertFalse(RUNNING_FUTURE.cancelled())
1527 self.assertTrue(CANCELLED_FUTURE.cancelled())
1528 self.assertTrue(CANCELLED_AND_NOTIFIED_FUTURE.cancelled())
1529 self.assertFalse(EXCEPTION_FUTURE.cancelled())
1530 self.assertFalse(SUCCESSFUL_FUTURE.cancelled())