(self)
| 471 | |
| 472 | class TestBoundedExecutor(unittest.TestCase): |
| 473 | def setUp(self): |
| 474 | self.coordinator = TransferCoordinator() |
| 475 | self.tag_semaphores = {} |
| 476 | self.executor = self.get_executor() |
| 477 | |
| 478 | def get_executor(self, max_size=1, max_num_threads=1): |
| 479 | return BoundedExecutor(max_size, max_num_threads, self.tag_semaphores) |
nothing calls this directly
no test coverage detected