| 382 | } |
| 383 | |
| 384 | void ProducerWait() { |
| 385 | std::unique_lock<std::mutex> lock(prefetch_access_mutex_); |
| 386 | producer_.wait(lock, [&]() { return finished_ || !IsPrefetchQueueFull(); }); |
| 387 | } |
| 388 | |
| 389 | void ConsumerWait() { |
| 390 | DomainTimeRange tr("[DALI][DataReader] ConsumerWait #" + to_string(curr_batch_consumer_), |