(self)
| 52 | self.assertEqual(expect, results) |
| 53 | |
| 54 | def testAdd(self): |
| 55 | results = set() |
| 56 | pool = DefaultExecutionPool() |
| 57 | pool.init(3) |
| 58 | for result in pool.imap_unordered(Run, [[x] for x in range(0, 10)]): |
| 59 | if result.heartbeat: |
| 60 | # Any result can be a heartbeat due to timings. |
| 61 | continue |
| 62 | results.add(result.value) |
| 63 | if result.value < 30: |
| 64 | pool.add([result.value + 20]) |
| 65 | self.assertEqual( |
| 66 | set(range(0, 10)) | set(range(20, 30)) | set(range(40, 50)), results) |
| 67 | |
| 68 | |
| 69 | class QueueTest(unittest.TestCase): |
nothing calls this directly
no test coverage detected