notify to exit
(self)
| 186 | return self._source.drained() and self._produced == self._consumed |
| 187 | |
| 188 | def stop(self): |
| 189 | """ notify to exit |
| 190 | """ |
| 191 | self._exit = True |
| 192 | self._feeding_ev.set() |
| 193 | for _ in range(len(self._consumers)): |
| 194 | self._inq.put(EndSignal(0, "notify consumers to exit")) |
| 195 | |
| 196 | def _consumer_healthy(self): |
| 197 | abnormal_num = 0 |