|
|
@ -58,8 +58,7 @@ void ThreadPool::SharedThreadPoolConstructor() { |
|
|
|
threads_ = static_cast<ThreadPoolWorker**>( |
|
|
|
threads_ = static_cast<ThreadPoolWorker**>( |
|
|
|
gpr_zalloc(num_threads_ * sizeof(ThreadPoolWorker*))); |
|
|
|
gpr_zalloc(num_threads_ * sizeof(ThreadPoolWorker*))); |
|
|
|
for (int i = 0; i < num_threads_; ++i) { |
|
|
|
for (int i = 0; i < num_threads_; ++i) { |
|
|
|
threads_[i] = |
|
|
|
threads_[i] = New<ThreadPoolWorker>(thd_name_, queue_, thread_options_, i); |
|
|
|
New<ThreadPoolWorker>(thd_name_, queue_, thread_options_, i); |
|
|
|
|
|
|
|
threads_[i]->Start(); |
|
|
|
threads_[i]->Start(); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|