Start threads to read and write frames.
(self)
| 333 | self.write_queue[task.id] = (True, task) |
| 334 | |
| 335 | def start(self): |
| 336 | """ |
| 337 | Start threads to read and write frames. |
| 338 | """ |
| 339 | self.put_thread = threading.Thread( |
| 340 | target=self.put_fn, args=(), name="VidRead-Thread", daemon=True |
| 341 | ) |
| 342 | self.put_thread.start() |
| 343 | self.get_thread = threading.Thread( |
| 344 | target=self.get_fn, args=(), name="VidDisplay-Thread", daemon=True |
| 345 | ) |
| 346 | self.get_thread.start() |
| 347 | |
| 348 | return self |
| 349 | |
| 350 | def join(self): |
| 351 | self.get_thread.join() |