Home | History | Annotate | Download | only in libplatform 
      1 // Copyright 2014 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 #include "include/v8-platform.h"
      6 #include "src/base/platform/platform.h"
      7 #include "src/libplatform/task-queue.h"
      8 #include "testing/gmock/include/gmock/gmock.h"
      9 
     10 using testing::InSequence;
     11 using testing::IsNull;
     12 using testing::StrictMock;
     13 
     14 namespace v8 {
     15 namespace platform {
     16 
     17 namespace {
     18 
     19 struct MockTask : public Task {
     20   MOCK_METHOD0(Run, void());
     21 };
     22 
     23 
     24 class TaskQueueThread FINAL : public base::Thread {
     25  public:
     26   explicit TaskQueueThread(TaskQueue* queue)
     27       : Thread(Options("libplatform TaskQueueThread")), queue_(queue) {}
     28 
     29   virtual void Run() OVERRIDE { EXPECT_THAT(queue_->GetNext(), IsNull()); }
     30 
     31  private:
     32   TaskQueue* queue_;
     33 };
     34 
     35 }  // namespace
     36 
     37 
     38 TEST(TaskQueueTest, Basic) {
     39   TaskQueue queue;
     40   MockTask task;
     41   queue.Append(&task);
     42   EXPECT_EQ(&task, queue.GetNext());
     43   queue.Terminate();
     44   EXPECT_THAT(queue.GetNext(), IsNull());
     45 }
     46 
     47 
     48 TEST(TaskQueueTest, TerminateMultipleReaders) {
     49   TaskQueue queue;
     50   TaskQueueThread thread1(&queue);
     51   TaskQueueThread thread2(&queue);
     52   thread1.Start();
     53   thread2.Start();
     54   queue.Terminate();
     55   thread1.Join();
     56   thread2.Join();
     57 }
     58 
     59 }  // namespace platform
     60 }  // namespace v8
     61