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

• Show log

  Commit

• Hash : 025504b9
  Author :
  Date : 2022-10-17T17:03:03
  

  Pass worker pools to image load functions
  
  In preparation for the ASTC decoder using threaded decoding.
  
  Bug: b/250688943
  Change-Id: I70d669bcb57b900dbb633304182e174aec362203
  Reviewed-on: https://chromium-review.googlesource.com/c/angle/angle/+/3961339
  Reviewed-by: Jamie Madill <jmadill@chromium.org>
  Reviewed-by: Greg Schlomoff <gregschlom@google.com>
  Commit-Queue: Shahbaz Youssefi <syoussefi@chromium.org>
  

Download

• src/common/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 "common/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(1, ANGLEPlatformCurrent()),
           WorkerThreadPool::Create(0, ANGLEPlatformCurrent())}};
      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
  

Download