| 97 | } |
| 98 | |
| 99 | comm::RetCode Scheduler::Dispose() { |
| 100 | comm::SchedulerBP::GetThreadInstance()->OnDispose(); |
| 101 | |
| 102 | if (impl_->keep_master_thread) |
| 103 | impl_->keep_master_thread->Stop(); |
| 104 | if (impl_->load_balance_thread) |
| 105 | impl_->load_balance_thread->Stop(); |
| 106 | |
| 107 | return impl_->scheduler_mgr->Dispose(); |
| 108 | } |
| 109 | |
| 110 | const SchedulerOption *Scheduler::GetSchedulerOption() const { |
| 111 | return &impl_->opt; |