src/v8/src/libplatform/task-queue.h

   1 // Copyright 2013 the V8 project authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #ifndef V8_LIBPLATFORM_TASK_QUEUE_H_
   6 #define V8_LIBPLATFORM_TASK_QUEUE_H_
   7
   8 #include <queue>
   9
  10 #include "src/base/macros.h"
  11 #include "src/base/platform/mutex.h"
  12 #include "src/base/platform/semaphore.h"
  13
  14 namespace v8 {
  15
  16 class Task;
  17
  18 namespace platform {
  19
  20 class TaskQueue {
  21  public:
  22   TaskQueue();
  23   ~TaskQueue();
  24
  25   // Appends a task to the queue. The queue takes ownership of |task|.
  26   void Append(Task* task);
  27
  28   // Returns the next task to process. Blocks if no task is available. Returns
  29   // NULL if the queue is terminated.
  30   Task* GetNext();
  31
  32   // Terminate the queue.
  33   void Terminate();
  34
  35  private:
  36   base::Mutex lock_;
  37   base::Semaphore process_queue_semaphore_;
  38   std::queue<Task*> task_queue_;
  39   bool terminated_;
  40
  41   DISALLOW_COPY_AND_ASSIGN(TaskQueue);
  42 };
  43
  44 } }  // namespace v8::platform
  45
  46
  47 #endif  // V8_LIBPLATFORM_TASK_QUEUE_H_