(self, batch_size)
| 245 | thread1.start() |
| 246 | |
| 247 | def cache_to_cuda(self, batch_size): |
| 248 | self.sample_queue.queue.clear() |
| 249 | |
| 250 | for rollout_data in self.get(batch_size): |
| 251 | while self.sample_queue.qsize() >= 2: |
| 252 | time.sleep(0.01) |
| 253 | self.sample_queue.put(rollout_data) |
| 254 | |
| 255 | def size(self) -> int: |
| 256 | """ |