| 77 | } |
| 78 | |
| 79 | void DataLoader::join() { |
| 80 | for (int i = 0; i < mConfig->numWorkers; i++) { |
| 81 | Job j; |
| 82 | j.quit = true; |
| 83 | mJobs->push(std::move(j)); |
| 84 | } |
| 85 | for (auto& worker : mWorkers) { |
| 86 | worker.join(); |
| 87 | } |
| 88 | } |
| 89 | |
| 90 | void DataLoader::reset() { |
| 91 | clean(); |