Searched refs:DispatcherImpl (Results 1 – 3 of 3) sorted by relevance
25 DispatcherImpl::~DispatcherImpl() = default;27 DispatcherImpl::DispatcherImpl(const IThreadPool::Ptr& threads) : queue_(threads) {} in DispatcherImpl() function in DispatcherImpl29 vector<uint64_t> DispatcherImpl::CollectFinishedTasks() in CollectFinishedTasks()34 void DispatcherImpl::Submit(uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& task) in Submit()39 void DispatcherImpl::SubmitAfter(uint64_t afterIdentifier, uint64_t taskIdentifier, IThreadPool::IT… in SubmitAfter()44 void DispatcherImpl::SubmitAfter( in SubmitAfter()50 void DispatcherImpl::Execute() in Execute()55 void DispatcherImpl::Clear() in Clear()60 void DispatcherImpl::Destroy() in Destroy()
27 class DispatcherImpl final : public IDispatcherTaskQueue { in CORE_BEGIN_NAMESPACE()29 ~DispatcherImpl(); in CORE_BEGIN_NAMESPACE()30 explicit DispatcherImpl(const IThreadPool::Ptr& threads); in CORE_BEGIN_NAMESPACE()
413 return IDispatcherTaskQueue::Ptr { make_unique<DispatcherImpl>(threadPool).release() }; in CreateDispatcherTaskQueue()