(self)
| 349 | self._quick_get = self._outqueue._reader.recv |
| 350 | |
| 351 | def _check_running(self): |
| 352 | if self._state != RUN: |
| 353 | raise ValueError("Pool not running") |
| 354 | |
| 355 | def apply(self, func, args=(), kwds={}): |
| 356 | ''' |
no outgoing calls
no test coverage detected