Searched refs:ParallelTaskQueue (Results 1 – 3 of 3) sorted by relevance
38 struct ParallelTaskQueue::TaskState {44 class ParallelTaskQueue::Task final : public IThreadPool::ITask {63 void ParallelTaskQueue::Task::operator()() in operator ()()76 void ParallelTaskQueue::Task::Destroy() in Destroy()82 ParallelTaskQueue::ParallelTaskQueue(const IThreadPool::Ptr& threadPool) : TaskQueue(threadPool) {} in ParallelTaskQueue() function in ParallelTaskQueue84 ParallelTaskQueue::~ParallelTaskQueue() in ~ParallelTaskQueue()111 void ParallelTaskQueue::SubmitAfter( in SubmitAfter()128 void ParallelTaskQueue::Remove(uint64_t taskIdentifier) in Remove()136 void ParallelTaskQueue::Clear() in Clear()142 void ParallelTaskQueue::QueueTasks(vector<size_t>& waiting, TaskState& state) in QueueTasks()[all …]
28 class ParallelTaskQueue final : public TaskQueue { in CORE_BEGIN_NAMESPACE()33 explicit ParallelTaskQueue(const IThreadPool::Ptr& threadPool); in CORE_BEGIN_NAMESPACE()34 ParallelTaskQueue(const ParallelTaskQueue& other) = delete; in CORE_BEGIN_NAMESPACE()35 ~ParallelTaskQueue() override; in CORE_BEGIN_NAMESPACE()
43 ParallelTaskQueue queue_; in CORE_BEGIN_NAMESPACE()