(self)
| 26 | class PoolTest(unittest.TestCase): |
| 27 | |
| 28 | def testNormal(self): |
| 29 | results = set() |
| 30 | pool = DefaultExecutionPool() |
| 31 | pool.init(3) |
| 32 | for result in pool.imap_unordered(Run, [[x] for x in range(0, 10)]): |
| 33 | if result.heartbeat: |
| 34 | # Any result can be a heartbeat due to timings. |
| 35 | continue |
| 36 | results.add(result.value) |
| 37 | self.assertEqual(set(range(0, 10)), results) |
| 38 | |
| 39 | def testException(self): |
| 40 | results = set() |
nothing calls this directly
no test coverage detected