| 132 | } |
| 133 | |
| 134 | void ThreadPool::Schedule(std::function<void()> fn) { |
| 135 | CHECK(fn != nullptr); |
| 136 | underlying_threadpool_->Schedule(std::move(fn)); |
| 137 | } |
| 138 | |
| 139 | int ThreadPool::NumShardsUsedByTransformRangeConcurrently( |
| 140 | const int64 block_size, const int64 total) { |
no outgoing calls