Index: runtime/vm/thread_pool.cc |
diff --git a/runtime/vm/thread_pool.cc b/runtime/vm/thread_pool.cc |
index 5b3a713d2d09b2c32be7605f622e7671669e36c6..87f441519e454e66bc4f3dd5c9c781089c511906 100644 |
--- a/runtime/vm/thread_pool.cc |
+++ b/runtime/vm/thread_pool.cc |
@@ -12,9 +12,6 @@ namespace dart { |
DEFINE_FLAG(int, worker_timeout_millis, 5000, |
"Free workers when they have been idle for this amount of time."); |
-Monitor* ThreadPool::exit_monitor_ = NULL; |
-int* ThreadPool::exit_count_ = NULL; |
- |
ThreadPool::ThreadPool() |
: shutting_down_(false), |
all_workers_(NULL), |
@@ -22,7 +19,8 @@ ThreadPool::ThreadPool() |
count_started_(0), |
count_stopped_(0), |
count_running_(0), |
- count_idle_(0) { |
+ count_idle_(0), |
+ shutting_down_workers_(NULL) { |
} |
@@ -94,14 +92,27 @@ void ThreadPool::Shutdown() { |
} |
// Release ThreadPool::mutex_ before calling Worker functions. |
- Worker* current = saved; |
- while (current != NULL) { |
- // We may access all_next_ without holding ThreadPool::mutex_ here |
- // because the worker is no longer owned by the ThreadPool. |
- Worker* next = current->all_next_; |
- current->all_next_ = NULL; |
- current->Shutdown(); |
- current = next; |
+ { |
+ MonitorLocker eml(&exit_monitor_); |
+ |
+ // First tell all the workers to shut down. |
+ Worker* current = saved; |
+ while (current != NULL) { |
+ Worker* next = current->all_next_; |
+ if (current->id_ != OSThread::GetCurrentThreadId()) { |
+ AddWorkerToShutdownList(current); |
+ } |
+ current->Shutdown(); |
+ current = next; |
+ } |
+ saved = NULL; |
+ |
+ // Wait until all workers have exited. |
+ while (shutting_down_workers_ != NULL) { |
+ // Here, we are waiting for workers to exit. When a worker exits we will |
+ // be notified. |
+ eml.Wait(); |
+ } |
} |
} |
@@ -157,6 +168,7 @@ bool ThreadPool::RemoveWorkerFromAllList(Worker* worker) { |
worker->all_next_ = NULL; |
worker->owned_ = false; |
worker->pool_ = NULL; |
+ worker->done_ = true; |
return true; |
} |
@@ -206,6 +218,38 @@ bool ThreadPool::ReleaseIdleWorker(Worker* worker) { |
} |
+// Only call while holding the exit_monitor_ |
+void ThreadPool::AddWorkerToShutdownList(Worker* worker) { |
+ worker->shutdown_next_ = shutting_down_workers_; |
+ shutting_down_workers_ = worker; |
+} |
+ |
+ |
+// Only call while holding the exit_monitor_ |
+bool ThreadPool::RemoveWorkerFromShutdownList(Worker* worker) { |
+ ASSERT(worker != NULL); |
+ ASSERT(shutting_down_workers_ != NULL); |
+ |
+ // Special case head of list. |
+ if (shutting_down_workers_ == worker) { |
+ shutting_down_workers_ = worker->shutdown_next_; |
+ worker->shutdown_next_ = NULL; |
+ return true; |
+ } |
+ |
+ for (Worker* current = shutting_down_workers_; |
+ current->shutdown_next_ != NULL; |
+ current = current->shutdown_next_) { |
+ if (current->shutdown_next_ == worker) { |
+ current->shutdown_next_ = worker->shutdown_next_; |
+ worker->shutdown_next_ = NULL; |
+ return true; |
+ } |
+ } |
+ return false; |
+} |
+ |
+ |
ThreadPool::Task::Task() { |
} |
@@ -216,10 +260,14 @@ ThreadPool::Task::~Task() { |
ThreadPool::Worker::Worker(ThreadPool* pool) |
: pool_(pool), |
+ done_(false), |
task_(NULL), |
+ id_(OSThread::kInvalidThreadId), |
+ started_(false), |
owned_(false), |
all_next_(NULL), |
- idle_next_(NULL) { |
+ idle_next_(NULL), |
+ shutdown_next_(NULL) { |
} |
@@ -264,7 +312,7 @@ static int64_t ComputeTimeout(int64_t idle_start) { |
} |
-void ThreadPool::Worker::Loop() { |
+bool ThreadPool::Worker::Loop() { |
MonitorLocker ml(&monitor_); |
int64_t idle_start; |
while (true) { |
@@ -281,9 +329,9 @@ void ThreadPool::Worker::Loop() { |
ASSERT(task_ == NULL); |
if (IsDone()) { |
- return; |
+ return false; |
} |
- ASSERT(pool_ != NULL); |
+ ASSERT(!done_); |
pool_->SetIdle(this); |
idle_start = OS::GetCurrentTimeMillis(); |
while (true) { |
@@ -294,21 +342,21 @@ void ThreadPool::Worker::Loop() { |
break; |
} |
if (IsDone()) { |
- return; |
+ return false; |
} |
- if (result == Monitor::kTimedOut && |
- pool_->ReleaseIdleWorker(this)) { |
- return; |
+ if ((result == Monitor::kTimedOut) && pool_->ReleaseIdleWorker(this)) { |
+ return true; |
} |
} |
} |
UNREACHABLE(); |
+ return false; |
} |
void ThreadPool::Worker::Shutdown() { |
MonitorLocker ml(&monitor_); |
- pool_ = NULL; // Fail fast if someone tries to access pool_. |
+ done_ = true; |
ml.Notify(); |
} |
@@ -317,20 +365,55 @@ void ThreadPool::Worker::Shutdown() { |
void ThreadPool::Worker::Main(uword args) { |
Thread::EnsureInit(); |
Worker* worker = reinterpret_cast<Worker*>(args); |
- worker->Loop(); |
+ bool delete_self = false; |
+ |
+ { |
+ MonitorLocker ml(&(worker->monitor_)); |
+ if (worker->IsDone()) { |
+ // id_ hasn't been set yet, but the ThreadPool is being shutdown. |
+ // Delete the task, and return. |
+ ASSERT(worker->task_); |
+ delete worker->task_; |
+ worker->task_ = NULL; |
+ delete_self = true; |
+ } else { |
+ worker->id_ = OSThread::GetCurrentThreadId(); |
+ worker->started_ = true; |
+ } |
+ } |
+ |
+ // We aren't able to delete the worker while holding the worker's monitor. |
+ // Now that we have released it, and we know that ThreadPool::Shutdown |
+ // won't touch it again, we can delete it and return. |
+ if (delete_self) { |
+ MonitorLocker eml(&worker->pool_->exit_monitor_); |
+ worker->pool_->RemoveWorkerFromShutdownList(worker); |
+ delete worker; |
+ eml.Notify(); |
+ return; |
+ } |
+ |
+ bool released = worker->Loop(); |
// It should be okay to access these unlocked here in this assert. |
- ASSERT(!worker->owned_ && |
- worker->all_next_ == NULL && |
- worker->idle_next_ == NULL); |
- |
- // The exit monitor is only used during testing. |
- if (ThreadPool::exit_monitor_) { |
- MonitorLocker ml(ThreadPool::exit_monitor_); |
- (*ThreadPool::exit_count_)++; |
- ml.Notify(); |
+ // worker->all_next_ is retained by the pool for shutdown monitoring. |
+ ASSERT(!worker->owned_ && (worker->idle_next_ == NULL)); |
+ |
+ if (!released) { |
+ // This worker is exiting because the thread pool is being shut down. |
+ // Inform the thread pool that we are exiting. We remove this worker from |
+ // shutting_down_workers_ list because there will be no need for the |
+ // ThreadPool to take action for this worker. |
+ MonitorLocker eml(&worker->pool_->exit_monitor_); |
+ worker->id_ = OSThread::kInvalidThreadId; |
+ worker->pool_->RemoveWorkerFromShutdownList(worker); |
+ delete worker; |
+ eml.Notify(); |
+ } else { |
+ // This worker is going down because it was idle for too long. This case |
+ // is not due to a ThreadPool Shutdown. Thus, we simply delete the worker. |
+ delete worker; |
} |
- delete worker; |
#if defined(TARGET_OS_WINDOWS) |
Thread::CleanUp(); |
#endif |