kc3-lang/angle/src/libANGLE/WorkerThread.h

Branch : - branch - main - tag -

• Show log

  Commit

• Author : jchen10
  Date : 2019-02-15 21:06:42
  Hash : 7d53c60b
  Message : ParallelCompile: use the native extensions This enhances to use the native parallel compile extensions if available. Bug: 873724 Change-Id: I0aaed314accd75e1bfa596b322225b56d729d3a6 Reviewed-on: https://chromium-review.googlesource.com/c/angle/angle/+/1475234 Commit-Queue: Jie A Chen <jie.a.chen@intel.com> Reviewed-by: Jamie Madill <jmadill@chromium.org>

• src/libANGLE/WorkerThread.h

• //
  // 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:
  //   Asychronous tasks/threads for ANGLE, similar to a TaskRunner in Chromium.
  //   Can be implemented as different targets, depending on platform.
  //
  
  #ifndef LIBANGLE_WORKER_THREAD_H_
  #define LIBANGLE_WORKER_THREAD_H_
  
  #include <array>
  #include <memory>
  #include <vector>
  
  #include "common/debug.h"
  #include "libANGLE/features.h"
  
  namespace angle
  {
  
  class WorkerThreadPool;
  
  // A callback function with no return value and no arguments.
  class Closure
  {
    public:
      virtual ~Closure()        = default;
      virtual void operator()() = 0;
  };
  
  // An event that we can wait on, useful for joining worker threads.
  class WaitableEvent : angle::NonCopyable
  {
    public:
      WaitableEvent();
      virtual ~WaitableEvent();
  
      // Waits indefinitely for the event to be signaled.
      virtual void wait() = 0;
  
      // Peeks whether the event is ready. If ready, wait() will not block.
      virtual bool isReady() = 0;
      void setWorkerThreadPool(std::shared_ptr<WorkerThreadPool> pool) { mPool = pool; }
  
      template <size_t Count>
      static void WaitMany(std::array<std::shared_ptr<WaitableEvent>, Count> *waitables)
      {
          ASSERT(Count > 0);
          for (size_t index = 0; index < Count; ++index)
          {
              (*waitables)[index]->wait();
          }
      }
  
    private:
      std::shared_ptr<WorkerThreadPool> mPool;
  };
  
  // A dummy waitable event.
  class WaitableEventDone final : public WaitableEvent
  {
    public:
      void wait() override;
      bool isReady() override;
  };
  
  // Request WorkerThreads from the WorkerThreadPool. Each pool can keep worker threads around so
  // we avoid the costly spin up and spin down time.
  class WorkerThreadPool : angle::NonCopyable
  {
    public:
      WorkerThreadPool();
      virtual ~WorkerThreadPool();
  
      static std::shared_ptr<WorkerThreadPool> Create(bool multithreaded);
      static std::shared_ptr<WaitableEvent> PostWorkerTask(std::shared_ptr<WorkerThreadPool> pool,
                                                           std::shared_ptr<Closure> task);
  
      virtual void setMaxThreads(size_t maxThreads) = 0;
  
      virtual bool isAsync() = 0;
  
    private:
      // Returns an event to wait on for the task to finish.
      // If the pool fails to create the task, returns null.
      virtual std::shared_ptr<WaitableEvent> postWorkerTask(std::shared_ptr<Closure> task) = 0;
  };
  
  }  // namespace angle
  
  #endif  // LIBANGLE_WORKER_THREAD_H_