diff options
| author | Antoine Pitrou <solipsis@pitrou.net> | 2011-03-22 17:30:30 (GMT) |
|---|---|---|
| committer | Antoine Pitrou <solipsis@pitrou.net> | 2011-03-22 17:30:30 (GMT) |
| commit | 8e5e942c594aa29351cdc8ce5802159700cd2dc6 (patch) | |
| tree | 51b876746b118552cb7cf0435b352265ac3e4ff6 /Lib/test | |
| parent | 608aba301e62fe0c926d453d168a38c0ed3a46e8 (diff) | |
| download | cpython-8e5e942c594aa29351cdc8ce5802159700cd2dc6.zip cpython-8e5e942c594aa29351cdc8ce5802159700cd2dc6.tar.gz cpython-8e5e942c594aa29351cdc8ce5802159700cd2dc6.tar.bz2 | |
Use shorter timings in test_concurrent_futures to make it a bit faster
(it's still very slow)
Diffstat (limited to 'Lib/test')
| -rw-r--r-- | Lib/test/test_concurrent_futures.py | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/Lib/test/test_concurrent_futures.py b/Lib/test/test_concurrent_futures.py index 06cdf0b..f639eec 100644 --- a/Lib/test/test_concurrent_futures.py +++ b/Lib/test/test_concurrent_futures.py @@ -155,7 +155,7 @@ class ProcessPoolShutdownTest(ProcessPoolMixin, ExecutorShutdownTest): class WaitTests(unittest.TestCase): def test_first_completed(self): future1 = self.executor.submit(mul, 21, 2) - future2 = self.executor.submit(time.sleep, 5) + future2 = self.executor.submit(time.sleep, 1.5) done, not_done = futures.wait( [CANCELLED_FUTURE, future1, future2], @@ -165,7 +165,7 @@ class WaitTests(unittest.TestCase): self.assertEqual(set([CANCELLED_FUTURE, future2]), not_done) def test_first_completed_some_already_completed(self): - future1 = self.executor.submit(time.sleep, 2) + future1 = self.executor.submit(time.sleep, 1.5) finished, pending = futures.wait( [CANCELLED_AND_NOTIFIED_FUTURE, SUCCESSFUL_FUTURE, future1], @@ -178,8 +178,8 @@ class WaitTests(unittest.TestCase): def test_first_exception(self): future1 = self.executor.submit(mul, 2, 21) - future2 = self.executor.submit(sleep_and_raise, 5) - future3 = self.executor.submit(time.sleep, 10) + future2 = self.executor.submit(sleep_and_raise, 1.5) + future3 = self.executor.submit(time.sleep, 3) finished, pending = futures.wait( [future1, future2, future3], @@ -190,7 +190,7 @@ class WaitTests(unittest.TestCase): def test_first_exception_some_already_complete(self): future1 = self.executor.submit(divmod, 21, 0) - future2 = self.executor.submit(time.sleep, 5) + future2 = self.executor.submit(time.sleep, 1.5) finished, pending = futures.wait( [SUCCESSFUL_FUTURE, @@ -235,14 +235,14 @@ class WaitTests(unittest.TestCase): def test_timeout(self): future1 = self.executor.submit(mul, 6, 7) - future2 = self.executor.submit(time.sleep, 10) + future2 = self.executor.submit(time.sleep, 3) finished, pending = futures.wait( [CANCELLED_AND_NOTIFIED_FUTURE, EXCEPTION_FUTURE, SUCCESSFUL_FUTURE, future1, future2], - timeout=5, + timeout=1.5, return_when=futures.ALL_COMPLETED) self.assertEqual(set([CANCELLED_AND_NOTIFIED_FUTURE, @@ -332,8 +332,8 @@ class ExecutorTest(unittest.TestCase): results = [] try: for i in self.executor.map(time.sleep, - [0, 0, 10], - timeout=5): + [0, 0, 3], + timeout=1.5): results.append(i) except futures.TimeoutError: pass |