Edit

kc3-lang/angle/src/libANGLE/WorkerThread_unittest.cpp

Branch :

  • Show log

    Commit

  • Author : Jamie Madill
    Date : 2018-11-27 11:34:27
    Hash : b980c563
    Message : Reformat all cpp and h files. This applies git cl format --full to all ANGLE sources. Bug: angleproject:2986 Change-Id: Ib504e618c1589332a37e97696cdc3515d739308f Reviewed-on: https://chromium-review.googlesource.com/c/1351367 Reviewed-by: Jamie Madill <jmadill@chromium.org> Reviewed-by: Shahbaz Youssefi <syoussefi@chromium.org>

  • src/libANGLE/WorkerThread_unittest.cpp
  • //
    // Copyright 2016 The ANGLE Project Authors. All rights reserved.
    // Use of this source code is governed by a BSD-style license that can be
    // found in the LICENSE file.
    //
    // WorkerThread_unittest:
    //   Simple tests for the worker thread class.
    
    #include <gtest/gtest.h>
    #include <array>
    
    #include "libANGLE/WorkerThread.h"
    
    using namespace angle;
    
    namespace
    {
    
    // Tests simple worker pool application.
    TEST(WorkerPoolTest, SimpleTask)
    {
        class TestTask : public Closure
        {
          public:
            void operator()() override { fired = true; }
    
            bool fired = false;
        };
    
        std::array<std::shared_ptr<WorkerThreadPool>, 2> pools = {
            {WorkerThreadPool::Create(false), WorkerThreadPool::Create(true)}};
        for (auto &pool : pools)
        {
            std::array<std::shared_ptr<TestTask>, 4> tasks = {
                {std::make_shared<TestTask>(), std::make_shared<TestTask>(),
                 std::make_shared<TestTask>(), std::make_shared<TestTask>()}};
            std::array<std::shared_ptr<WaitableEvent>, 4> waitables = {
                {pool->postWorkerTask(tasks[0]), pool->postWorkerTask(tasks[1]),
                 pool->postWorkerTask(tasks[2]), pool->postWorkerTask(tasks[3])}};
    
            WaitableEvent::WaitMany(&waitables);
    
            for (const auto &task : tasks)
            {
                EXPECT_TRUE(task->fired);
            }
        }
    }
    
    }  // anonymous namespace