(self, done_callback)
| 258 | self._busy_lock.release() #p |
| 259 | |
| 260 | def _done_thread(self, done_callback): |
| 261 | done_popleft = self._done.popleft |
| 262 | while True: |
| 263 | # noinspection PyBroadException |
| 264 | try: |
| 265 | while True: |
| 266 | done_callback(done_popleft()) |
| 267 | except: |
| 268 | if self._shutdown: |
| 269 | break |
| 270 | self._done_cnt.acquire() |
| 271 | |
| 272 | #c cdef void _done_cnt_inc(self): |
| 273 | def _done_cnt_inc(self): #p |