| 64 | } |
| 65 | |
| 66 | ThreadPool* Env::IntraThreadPool() { |
| 67 | if (intra_tp_ == nullptr) { |
| 68 | intra_tp_.reset(new ThreadPool(GLOBAL_FLAG(IntraThreadNum))); |
| 69 | intra_tp_->Startup(); |
| 70 | } |
| 71 | return intra_tp_.get(); |
| 72 | } |
| 73 | |
| 74 | ThreadPool* Env::ReservedThreadPool() { |
| 75 | if (reserved_tp_ == nullptr) { |
no test coverage detected