Return visualized frames/clips in the correct order based on task id if result(s) is available. Otherwise, raise queue.Empty exception.
(self)
| 191 | self.task_queue.put(task) |
| 192 | |
| 193 | def get(self): |
| 194 | """ |
| 195 | Return visualized frames/clips in the correct order based on task id if |
| 196 | result(s) is available. Otherwise, raise queue.Empty exception. |
| 197 | """ |
| 198 | get_idx = self.get_indices_ls[0] |
| 199 | if self.result_data.get(get_idx) is not None: |
| 200 | res = self.result_data[get_idx] |
| 201 | del self.result_data[get_idx] |
| 202 | del self.get_indices_ls[0] |
| 203 | return res |
| 204 | |
| 205 | while True: |
| 206 | res = self.result_queue.get(block=False) |
| 207 | idx = res.id |
| 208 | if idx == get_idx: |
| 209 | del self.get_indices_ls[0] |
| 210 | return res |
| 211 | self.result_data[idx] = res |
| 212 | |
| 213 | def __call__(self, task): |
| 214 | """ |