Searched refs:ParallelImpl (Results 1 – 3 of 3) sorted by relevance
25 ParallelImpl::~ParallelImpl() = default;27 ParallelImpl::ParallelImpl(const IThreadPool::Ptr& threads) : queue_(threads) {} in ParallelImpl() function in ParallelImpl29 void ParallelImpl::Submit(uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& task) in Submit()34 void ParallelImpl::SubmitAfter(uint64_t afterIdentifier, uint64_t taskIdentifier, IThreadPool::ITas… in SubmitAfter()39 void ParallelImpl::SubmitAfter( in SubmitAfter()45 void ParallelImpl::Execute() in Execute()50 void ParallelImpl::Clear() in Clear()55 void ParallelImpl::Destroy() in Destroy()
27 class ParallelImpl final : public IParallelTaskQueue { in CORE_BEGIN_NAMESPACE()29 ~ParallelImpl(); in CORE_BEGIN_NAMESPACE()30 explicit ParallelImpl(const IThreadPool::Ptr& threads); in CORE_BEGIN_NAMESPACE()
418 return IParallelTaskQueue::Ptr { make_unique<ParallelImpl>(threadPool).release() }; in CreateParallelTaskQueue()