diff options
Diffstat (limited to 'deps/v8/src/libplatform/task-queue.cc')
-rw-r--r-- | deps/v8/src/libplatform/task-queue.cc | 25 |
1 files changed, 12 insertions, 13 deletions
diff --git a/deps/v8/src/libplatform/task-queue.cc b/deps/v8/src/libplatform/task-queue.cc index 37cf1353e..7a9071f36 100644 --- a/deps/v8/src/libplatform/task-queue.cc +++ b/deps/v8/src/libplatform/task-queue.cc @@ -2,27 +2,26 @@ // Use of this source code is governed by a BSD-style license that can be // found in the LICENSE file. -#include "task-queue.h" +#include "src/libplatform/task-queue.h" -// TODO(jochen): We should have our own version of checks.h. -#include "../checks.h" +#include "src/base/logging.h" namespace v8 { -namespace internal { +namespace platform { TaskQueue::TaskQueue() : process_queue_semaphore_(0), terminated_(false) {} TaskQueue::~TaskQueue() { - LockGuard<Mutex> guard(&lock_); - ASSERT(terminated_); - ASSERT(task_queue_.empty()); + base::LockGuard<base::Mutex> guard(&lock_); + DCHECK(terminated_); + DCHECK(task_queue_.empty()); } void TaskQueue::Append(Task* task) { - LockGuard<Mutex> guard(&lock_); - ASSERT(!terminated_); + base::LockGuard<base::Mutex> guard(&lock_); + DCHECK(!terminated_); task_queue_.push(task); process_queue_semaphore_.Signal(); } @@ -31,7 +30,7 @@ void TaskQueue::Append(Task* task) { Task* TaskQueue::GetNext() { for (;;) { { - LockGuard<Mutex> guard(&lock_); + base::LockGuard<base::Mutex> guard(&lock_); if (!task_queue_.empty()) { Task* result = task_queue_.front(); task_queue_.pop(); @@ -48,10 +47,10 @@ Task* TaskQueue::GetNext() { void TaskQueue::Terminate() { - LockGuard<Mutex> guard(&lock_); - ASSERT(!terminated_); + base::LockGuard<base::Mutex> guard(&lock_); + DCHECK(!terminated_); terminated_ = true; process_queue_semaphore_.Signal(); } -} } // namespace v8::internal +} } // namespace v8::platform |