Add the new task to task queue. Args: task (TaskInfo object): task object that contain the necessary information for action prediction. (e.g. frames)
(self, task)
| 76 | atexit.register(self.shutdown) |
| 77 | |
| 78 | def put(self, task): |
| 79 | """ |
| 80 | Add the new task to task queue. |
| 81 | Args: |
| 82 | task (TaskInfo object): task object that contain |
| 83 | the necessary information for action prediction. (e.g. frames) |
| 84 | """ |
| 85 | self.put_idx += 1 |
| 86 | self.task_queue.put(task) |
| 87 | |
| 88 | def get(self): |
| 89 | """ |