1// Copyright 2013 the V8 project authors. All rights reserved. 2// Redistribution and use in source and binary forms, with or without 3// modification, are permitted provided that the following conditions are 4// met: 5// 6// * Redistributions of source code must retain the above copyright 7// notice, this list of conditions and the following disclaimer. 8// * Redistributions in binary form must reproduce the above 9// copyright notice, this list of conditions and the following 10// disclaimer in the documentation and/or other materials provided 11// with the distribution. 12// * Neither the name of Google Inc. nor the names of its 13// contributors may be used to endorse or promote products derived 14// from this software without specific prior written permission. 15// 16// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS 17// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT 18// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR 19// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT 20// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, 21// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT 22// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, 23// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY 24// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT 25// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE 26// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 27 28#include "src/v8.h" 29 30#include "src/libplatform/task-queue.h" 31#include "test/cctest/cctest.h" 32#include "test/cctest/test-libplatform.h" 33 34using namespace v8::internal; 35 36 37TEST(TaskQueueBasic) { 38 TaskCounter task_counter; 39 40 TaskQueue queue; 41 42 TestTask* task = new TestTask(&task_counter); 43 queue.Append(task); 44 CHECK_EQ(1, task_counter.GetCount()); 45 CHECK_EQ(task, queue.GetNext()); 46 delete task; 47 CHECK_EQ(0, task_counter.GetCount()); 48 49 queue.Terminate(); 50 CHECK_EQ(NULL, queue.GetNext()); 51} 52 53 54class ReadQueueTask : public TestTask { 55 public: 56 ReadQueueTask(TaskCounter* task_counter, TaskQueue* queue) 57 : TestTask(task_counter, true), queue_(queue) {} 58 virtual ~ReadQueueTask() {} 59 60 virtual void Run() V8_OVERRIDE { 61 TestTask::Run(); 62 CHECK_EQ(NULL, queue_->GetNext()); 63 } 64 65 private: 66 TaskQueue* queue_; 67 68 DISALLOW_COPY_AND_ASSIGN(ReadQueueTask); 69}; 70 71 72TEST(TaskQueueTerminateMultipleReaders) { 73 TaskQueue queue; 74 TaskCounter task_counter; 75 ReadQueueTask* read1 = new ReadQueueTask(&task_counter, &queue); 76 ReadQueueTask* read2 = new ReadQueueTask(&task_counter, &queue); 77 78 TestWorkerThread thread1(read1); 79 TestWorkerThread thread2(read2); 80 81 thread1.Start(); 82 thread2.Start(); 83 84 CHECK_EQ(2, task_counter.GetCount()); 85 86 thread1.Signal(); 87 thread2.Signal(); 88 89 queue.Terminate(); 90 91 thread1.Join(); 92 thread2.Join(); 93 94 CHECK_EQ(0, task_counter.GetCount()); 95} 96