()
| 217 | error_queue = queue.Queue(2) # Queue size must be the same as the # of worker threads! |
| 218 | |
| 219 | def check_error_queue(): |
| 220 | try: |
| 221 | return error_queue.get(block=False) |
| 222 | except queue.Empty: |
| 223 | pass |
| 224 | return None |
| 225 | |
| 226 | def launch_thread(callable, *args, **kwargs): |
| 227 | def capture_errors(callable, *args, **kwargs): |
nothing calls this directly
no outgoing calls
no test coverage detected