Home
last modified time | relevance | path

Searched refs:IThreadPool (Results 1 – 25 of 46) sorted by relevance

12

/ohos5.0/foundation/graphic/graphic_3d/lume/LumeEngine/src/threading/
H A Dtask_queue.h30 class FunctionTask final : public IThreadPool::ITask { in CORE_BEGIN_NAMESPACE()
66 explicit TaskQueue(const IThreadPool::Ptr& threadPool);
76 virtual void Submit(uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& task) = 0;
101 class ExecuteAsyncTask final : public IThreadPool::ITask {
115 Entry(uint64_t identifier, IThreadPool::ITask::Ptr task);
119 IThreadPool::ITask::Ptr task;
124 IThreadPool::Ptr threadPool_;
125 IThreadPool::IResult::Ptr asyncOperation_;
H A Dparallel_task_queue.cpp44 class ParallelTaskQueue::Task final : public IThreadPool::ITask {
46 explicit Task(TaskState& state, IThreadPool::ITask& task, uint64_t id);
55 IThreadPool::ITask& task_;
59 ParallelTaskQueue::Task::Task(TaskState& state, IThreadPool::ITask& task, uint64_t id) in Task()
82 ParallelTaskQueue::ParallelTaskQueue(const IThreadPool::Ptr& threadPool) : TaskQueue(threadPool) {} in ParallelTaskQueue()
89 void ParallelTaskQueue::Submit(uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& task) in Submit()
96 void ParallelTaskQueue::SubmitAfter(uint64_t afterIdentifier, uint64_t taskIdentifier, IThreadPool:… in SubmitAfter()
112 …array_view<const uint64_t> afterIdentifiers, uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& ta… in SubmitAfter()
169 …threadPool_->PushNoWait(IThreadPool::ITask::Ptr { new Task(state, *entry.task, entry.identifier) }… in QueueTasks()
H A Dsequential_task_queue.h38 explicit SequentialTaskQueue(const IThreadPool::Ptr& threadPool); in CORE_BEGIN_NAMESPACE()
47 …void SubmitAfter(uint64_t afterIdentifier, uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& task… in CORE_BEGIN_NAMESPACE()
50 …BASE_NS::array_view<const uint64_t> afterIdentifiers, uint64_t taskIdentifier, IThreadPool::ITask:… in CORE_BEGIN_NAMESPACE()
57 …void SubmitBefore(uint64_t beforeIdentifier, uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& ta… in CORE_BEGIN_NAMESPACE()
59 void Submit(uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& task) override; in CORE_BEGIN_NAMESPACE()
H A Dparallel_impl.h30 explicit ParallelImpl(const IThreadPool::Ptr& threads); in CORE_BEGIN_NAMESPACE()
32 void Submit(uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& task) override; in CORE_BEGIN_NAMESPACE()
33 …void SubmitAfter(uint64_t afterIdentifier, uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& task… in CORE_BEGIN_NAMESPACE()
35 IThreadPool::ITask::Ptr&& task) override; in CORE_BEGIN_NAMESPACE()
H A Dsequential_impl.h30 explicit SequentialImpl(const IThreadPool::Ptr& threads); in CORE_BEGIN_NAMESPACE()
32 void Submit(uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& task) override; in CORE_BEGIN_NAMESPACE()
33 …void SubmitAfter(uint64_t afterIdentifier, uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& task… in CORE_BEGIN_NAMESPACE()
35 IThreadPool::ITask::Ptr&& task) override; in CORE_BEGIN_NAMESPACE()
H A Dtask_queue_factory.h28 IThreadPool::Ptr CreateThreadPool(const uint32_t threadCountconst) const override; in CORE_BEGIN_NAMESPACE()
30 …IDispatcherTaskQueue::Ptr CreateDispatcherTaskQueue(const IThreadPool::Ptr& threadPool) const over… in CORE_BEGIN_NAMESPACE()
31 …IParallelTaskQueue::Ptr CreateParallelTaskQueue(const IThreadPool::Ptr& threadPool) const override; in CORE_BEGIN_NAMESPACE()
32 …ISequentialTaskQueue::Ptr CreateSequentialTaskQueue(const IThreadPool::Ptr& threadPool) const over… in CORE_BEGIN_NAMESPACE()
H A Ddispatcher_impl.h30 explicit DispatcherImpl(const IThreadPool::Ptr& threads); in CORE_BEGIN_NAMESPACE()
34 void Submit(uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& task) override; in CORE_BEGIN_NAMESPACE()
35 …void SubmitAfter(uint64_t afterIdentifier, uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& task… in CORE_BEGIN_NAMESPACE()
37 IThreadPool::ITask::Ptr&& task) override; in CORE_BEGIN_NAMESPACE()
H A Dparallel_impl.cpp27 ParallelImpl::ParallelImpl(const IThreadPool::Ptr& threads) : queue_(threads) {} in ParallelImpl()
29 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()
40 …array_view<const uint64_t> afterIdentifiers, uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& ta… in SubmitAfter()
H A Dsequential_impl.cpp27 SequentialImpl::SequentialImpl(const IThreadPool::Ptr& threads) : queue_(threads) {} in SequentialImpl()
29 void SequentialImpl::Submit(uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& task) in Submit()
34 void SequentialImpl::SubmitAfter(uint64_t afterIdentifier, uint64_t taskIdentifier, IThreadPool::IT… in SubmitAfter()
40 …array_view<const uint64_t> afterIdentifiers, uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& ta… in SubmitAfter()
H A Ddispatcher_task_queue.h36 explicit DispatcherTaskQueue(const IThreadPool::Ptr& threadPool); in CORE_BEGIN_NAMESPACE()
45 void Submit(uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& task) override; in CORE_BEGIN_NAMESPACE()
46 …void SubmitAfter(uint64_t afterIdentifier, uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& task… in CORE_BEGIN_NAMESPACE()
48 …BASE_NS::array_view<const uint64_t> afterIdentifiers, uint64_t taskIdentifier, IThreadPool::ITask:… in CORE_BEGIN_NAMESPACE()
H A Dparallel_task_queue.h33 explicit ParallelTaskQueue(const IThreadPool::Ptr& threadPool); in CORE_BEGIN_NAMESPACE()
42 …void SubmitAfter(uint64_t afterIdentifier, uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& task… in CORE_BEGIN_NAMESPACE()
44 …BASE_NS::array_view<const uint64_t> afterIdentifiers, uint64_t taskIdentifier, IThreadPool::ITask:… in CORE_BEGIN_NAMESPACE()
46 void Submit(uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& task) override; in CORE_BEGIN_NAMESPACE()
H A Ddispatcher_impl.cpp27 DispatcherImpl::DispatcherImpl(const IThreadPool::Ptr& threads) : queue_(threads) {} in DispatcherImpl()
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()
45 …array_view<const uint64_t> afterIdentifiers, uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& ta… in SubmitAfter()
H A Dtask_queue_factory.cpp78 class TaskResult final : public IThreadPool::IResult {
137 class ThreadPool final : public IThreadPool {
194 if ((uid == IThreadPool::UID) || (uid == IInterface::UID)) { in GetInterface()
202 if ((uid == IThreadPool::UID) || (uid == IInterface::UID)) { in GetInterface()
406 IThreadPool::Ptr TaskQueueFactory::CreateThreadPool(const uint32_t threadCount) const in CreateThreadPool()
408 return IThreadPool::Ptr { new ThreadPool(threadCount) }; in CreateThreadPool()
411 IDispatcherTaskQueue::Ptr TaskQueueFactory::CreateDispatcherTaskQueue(const IThreadPool::Ptr& threa… in CreateDispatcherTaskQueue()
416 IParallelTaskQueue::Ptr TaskQueueFactory::CreateParallelTaskQueue(const IThreadPool::Ptr& threadPoo… in CreateParallelTaskQueue()
421 ISequentialTaskQueue::Ptr TaskQueueFactory::CreateSequentialTaskQueue(const IThreadPool::Ptr& threa… in CreateSequentialTaskQueue()
H A Dsequential_task_queue.cpp31 SequentialTaskQueue::SequentialTaskQueue(const IThreadPool::Ptr& threadPool) : TaskQueue(threadPool… in CORE_BEGIN_NAMESPACE()
46 void SequentialTaskQueue::Submit(uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& task) in Submit()
53 …kQueue::SubmitAfter(uint64_t afterIdentifier, uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& t… in SubmitAfter()
64 …BASE_NS::array_view<const uint64_t> afterIdentifiers, uint64_t taskIdentifier, IThreadPool::ITask:… in SubmitAfter()
81 uint64_t beforeIdentifier, uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& task) in SubmitBefore()
H A Dtask_queue.cpp46 TaskQueue::TaskQueue(const IThreadPool::Ptr& threadPool) : threadPool_(threadPool), isRunningAsync_… in TaskQueue()
58 … asyncOperation_ = threadPool_->Push(IThreadPool::ITask::Ptr { new ExecuteAsyncTask(*this) }); in ExecuteAsync()
76 TaskQueue::Entry::Entry(uint64_t identifier, IThreadPool::ITask::Ptr task) : task(move(task)), iden… in Entry()
H A Ddispatcher_task_queue.cpp34 DispatcherTaskQueue::DispatcherTaskQueue(const IThreadPool::Ptr& threadPool) : TaskQueue(threadPool… in DispatcherTaskQueue()
61 void DispatcherTaskQueue::Submit(uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& task) in Submit()
68 …kQueue::SubmitAfter(uint64_t afterIdentifier, uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& t… in SubmitAfter()
81 …BASE_NS::array_view<const uint64_t> afterIdentifiers, uint64_t taskIdentifier, IThreadPool::ITask:… in SubmitAfter()
/ohos5.0/foundation/graphic/graphic_3d/lume/LumeEngine/api/core/threading/
H A Dintf_thread_pool.h42 class IThreadPool : public IInterface { in CORE_BEGIN_NAMESPACE()
46 using Ptr = BASE_NS::refcnt_ptr<IThreadPool>; in CORE_BEGIN_NAMESPACE()
104 virtual ~IThreadPool() = default; in CORE_BEGIN_NAMESPACE()
113 virtual void Submit(uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& task) = 0;
121 …virtual void SubmitAfter(uint64_t afterIdentifier, uint64_t taskIdentifier, IThreadPool::ITask::Pt…
130 IThreadPool::ITask::Ptr&& task) = 0;
222 virtual IThreadPool::Ptr CreateThreadPool(const uint32_t threadCount) const = 0;
228 …virtual IDispatcherTaskQueue::Ptr CreateDispatcherTaskQueue(const IThreadPool::Ptr& threadPool) co…
234 …virtual IParallelTaskQueue::Ptr CreateParallelTaskQueue(const IThreadPool::Ptr& threadPool) const …
240 …virtual ISequentialTaskQueue::Ptr CreateSequentialTaskQueue(const IThreadPool::Ptr& threadPool) co…
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/
H A Dithread_pool.h26 class IThreadPool {
28 IThreadPool() = default;
29 virtual ~IThreadPool() = default;
/ohos5.0/foundation/graphic/graphic_3d/lume/Lume_3D/src/gltf/
H A Dgltf2_importer.h84 CORE_NS::IThreadPool& pool);
171 CORE_NS::IThreadPool::Ptr threadPool_;
181 BASE_NS::vector<CORE_NS::IThreadPool::IResult::Ptr> gatherTaskResults_;
197 CORE_NS::IThreadPool& pool);
H A Dgltf2.h49 … IGLTF2Importer::Ptr CreateGLTF2Importer(CORE_NS::IEcs& ecs, CORE_NS::IThreadPool& pool) override;
57 … ISceneImporter::Ptr CreateSceneImporter(CORE_NS::IEcs& ecs, CORE_NS::IThreadPool& pool) override;
/ohos5.0/foundation/graphic/graphic_3d/lume/LumeEngine/api/core/
H A Dintf_engine.h40 class IThreadPool; variable
100 virtual IEcs::Ptr CreateEcs(IThreadPool& threadPool) = 0;
/ohos5.0/foundation/graphic/graphic_3d/lume/LumeEngine/src/
H A Dengine.h46 class IThreadPool; variable
65 IEcs::Ptr CreateEcs(IThreadPool& threadPool) override;
H A Dengine.cpp124 CORE_NS::IEcs* IEcsInstance(IClassFactory&, const IThreadPool::Ptr&);
137 IEcs::Ptr Engine::CreateEcs(IThreadPool& threadPool) in CreateEcs()
139 return IEcs::Ptr { IEcsInstance(*this, IThreadPool::Ptr { &threadPool }) }; in CreateEcs()
/ohos5.0/foundation/graphic/graphic_3d/lume/LumeEngine/src/ecs/
H A Decs.cpp53 Ecs(IClassFactory&, const IThreadPool::Ptr& threadPool);
92 const IThreadPool::Ptr& GetThreadPool() const override;
110 IThreadPool::Ptr threadPool_;
273 Ecs::Ecs(IClassFactory& registry, const IThreadPool::Ptr& threadPool) in Ecs()
559 const IThreadPool::Ptr& Ecs::GetThreadPool() const in GetThreadPool()
660 IEcs* IEcsInstance(IClassFactory& registry, const IThreadPool::Ptr& threadPool) in IEcsInstance()
/ohos5.0/foundation/graphic/graphic_3d/lume/Lume_3D/src/ecs/systems/
H A Dskinning_system.h97 CORE_NS::IThreadPool::Ptr threadPool_;
100 BASE_NS::vector<CORE_NS::IThreadPool::IResult::Ptr> taskResults_;

12