Return True if the read thread should be still active.
(self)
| 213 | return os.getpid() == self.parent_pid |
| 214 | |
| 215 | def _is_thread_active(self): |
| 216 | """Return True if the read thread should be still active.""" |
| 217 | return self.read_thread is not None or not self.queue.empty() |
| 218 | |
| 219 | def _read_thread_func(self): |
| 220 | """Read results from the queue and add to self.results in a thread stared by `__enter__`.""" |