blob: a5b566d5887d0a1b7efb91348accbb11a37a1496 [file] [log] [blame]
//
// 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 <array>
#include <gtest/gtest.h>
#include "libANGLE/WorkerThread.h"
using namespace angle;
namespace
{
template <typename T>
class WorkerPoolTest : public ::testing::Test
{
public:
T workerPool = {4};
};
#if (ANGLE_STD_ASYNC_WORKERS == ANGLE_ENABLED)
using WorkerPoolTypes = ::testing::Types<priv::AsyncWorkerPool, priv::SingleThreadedWorkerPool>;
#else
using WorkerPoolTypes = ::testing::Types<priv::SingleThreadedWorkerPool>;
#endif // (ANGLE_STD_ASYNC_WORKERS == ANGLE_ENABLED)
TYPED_TEST_CASE(WorkerPoolTest, WorkerPoolTypes);
// Tests simple worker pool application.
TYPED_TEST(WorkerPoolTest, SimpleTask)
{
class TestTask : public Closure
{
public:
void operator()() override { fired = true; }
bool fired = false;
};
std::array<TestTask, 4> tasks;
std::array<typename TypeParam::WaitableEventType, 4> waitables = {{
this->workerPool.postWorkerTask(&tasks[0]), this->workerPool.postWorkerTask(&tasks[1]),
this->workerPool.postWorkerTask(&tasks[2]), this->workerPool.postWorkerTask(&tasks[3]),
}};
TypeParam::WaitableEventType::WaitMany(&waitables);
for (const auto &task : tasks)
{
EXPECT_TRUE(task.fired);
}
}
} // anonymous namespace