| 63 | } |
| 64 | |
| 65 | void PrefetchRunner::Stop() { |
| 66 | if (coord_) |
| 67 | coord_->WaitForStop(); |
| 68 | |
| 69 | sess_->Run({}, {}, {params_.cancel_op()}, nullptr); |
| 70 | is_running_ = false; |
| 71 | } |
| 72 | |
| 73 | Status PrefetchRunner::Join() { |
| 74 | for (size_t i = 0; i < thread_pool_.size(); i++) { |
nothing calls this directly
no test coverage detected