| /ohos5.0/foundation/graphic/graphic_3d/lume/LumeEngine/src/threading/ |
| H A D | sequential_task_queue.cpp | 46 void SequentialTaskQueue::Submit(uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& task) in Submit() argument
48 CORE_ASSERT(std::find(tasks_.cbegin(), tasks_.cend(), taskIdentifier) == tasks_.cend()); in Submit()
50 tasks_.emplace_back(taskIdentifier, std::move(task)); in Submit()
57 tasks_.emplace(++it, taskIdentifier, std::move(task)); in SubmitAfter()
59 tasks_.emplace_back(taskIdentifier, std::move(task)); in SubmitAfter()
74 tasks_.emplace(tasks_.begin() + (pos + 1), taskIdentifier, std::move(task)); in SubmitAfter()
76 tasks_.emplace_back(taskIdentifier, std::move(task)); in SubmitAfter()
81 uint64_t beforeIdentifier, uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& task) in SubmitBefore() argument
87 tasks_.emplace(it, taskIdentifier, std::move(task)); in SubmitBefore()
91 void SequentialTaskQueue::Remove(uint64_t taskIdentifier) in Remove() argument
[all …]
|
| H A D | dispatcher_task_queue.cpp | 41 void DispatcherTaskQueue::Remove(uint64_t taskIdentifier) in Remove() argument
45 auto it = std::find(tasks_.begin(), tasks_.end(), taskIdentifier); in Remove()
61 void DispatcherTaskQueue::Submit(uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& task) in Submit() argument
65 tasks_.emplace_back(taskIdentifier, move(task)); in Submit()
68 void DispatcherTaskQueue::SubmitAfter(uint64_t afterIdentifier, uint64_t taskIdentifier, IThreadPoo… in SubmitAfter() argument
74 tasks_.emplace(++it, taskIdentifier, move(task)); in SubmitAfter()
76 tasks_.emplace_back(taskIdentifier, move(task)); in SubmitAfter()
81 …BASE_NS::array_view<const uint64_t> afterIdentifiers, uint64_t taskIdentifier, IThreadPool::ITask:… in SubmitAfter() argument
91 tasks_.emplace(tasks_.begin() + (pos + 1), taskIdentifier, move(task)); in SubmitAfter()
93 tasks_.emplace_back(taskIdentifier, move(task)); in SubmitAfter()
|
| H A D | parallel_task_queue.cpp | 89 void ParallelTaskQueue::Submit(uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& task) in Submit() argument
91 CORE_ASSERT(std::find(tasks_.cbegin(), tasks_.cend(), taskIdentifier) == tasks_.cend()); in Submit()
93 tasks_.emplace_back(taskIdentifier, std::move(task)); in Submit()
98 CORE_ASSERT(std::find(tasks_.cbegin(), tasks_.cend(), taskIdentifier) == tasks_.cend()); in SubmitAfter()
102 Entry entry(taskIdentifier, std::move(task)); in SubmitAfter()
107 tasks_.emplace_back(taskIdentifier, std::move(task)); in SubmitAfter()
112 …array_view<const uint64_t> afterIdentifiers, uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& ta… in SubmitAfter() argument
119 Entry entry(taskIdentifier, std::move(task)); in SubmitAfter()
124 tasks_.emplace_back(taskIdentifier, std::move(task)); in SubmitAfter()
128 void ParallelTaskQueue::Remove(uint64_t taskIdentifier) in Remove() argument
[all …]
|
| H A D | parallel_impl.cpp | 29 void ParallelImpl::Submit(uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& task) in Submit() argument
31 queue_.Submit(taskIdentifier, move(task)); in Submit()
34 void ParallelImpl::SubmitAfter(uint64_t afterIdentifier, uint64_t taskIdentifier, IThreadPool::ITas… in SubmitAfter() argument
36 queue_.SubmitAfter(afterIdentifier, taskIdentifier, move(task)); in SubmitAfter()
40 …array_view<const uint64_t> afterIdentifiers, uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& ta… in SubmitAfter() argument
42 queue_.SubmitAfter(afterIdentifiers, taskIdentifier, move(task)); in SubmitAfter()
|
| H A D | sequential_impl.cpp | 29 void SequentialImpl::Submit(uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& task) in Submit() argument
31 queue_.Submit(taskIdentifier, move(task)); in Submit()
34 void SequentialImpl::SubmitAfter(uint64_t afterIdentifier, uint64_t taskIdentifier, IThreadPool::IT… in SubmitAfter() argument
36 queue_.SubmitAfter(afterIdentifier, taskIdentifier, move(task)); in SubmitAfter()
40 …array_view<const uint64_t> afterIdentifiers, uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& ta… in SubmitAfter() argument
42 queue_.SubmitAfter(afterIdentifiers, taskIdentifier, move(task)); in SubmitAfter()
|
| H A D | dispatcher_impl.cpp | 34 void DispatcherImpl::Submit(uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& task) in Submit() argument
36 queue_.Submit(taskIdentifier, move(task)); in Submit()
39 void DispatcherImpl::SubmitAfter(uint64_t afterIdentifier, uint64_t taskIdentifier, IThreadPool::IT… in SubmitAfter() argument
41 queue_.SubmitAfter(afterIdentifier, taskIdentifier, move(task)); in SubmitAfter()
45 …array_view<const uint64_t> afterIdentifiers, uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& ta… in SubmitAfter() argument
47 queue_.SubmitAfter(afterIdentifiers, taskIdentifier, move(task)); in SubmitAfter()
|
| H A D | sequential_task_queue.h | 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()
60 void Remove(uint64_t taskIdentifier) override; in CORE_BEGIN_NAMESPACE()
|
| H A D | dispatcher_task_queue.h | 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()
49 void Remove(uint64_t taskIdentifier) override; in CORE_BEGIN_NAMESPACE()
|
| H A D | parallel_task_queue.h | 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()
47 void Remove(uint64_t taskIdentifier) override; in CORE_BEGIN_NAMESPACE()
|
| H A D | parallel_impl.h | 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()
34 void SubmitAfter(BASE_NS::array_view<const uint64_t> afterIdentifiers, uint64_t taskIdentifier, in CORE_BEGIN_NAMESPACE()
|
| H A D | sequential_impl.h | 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()
34 void SubmitAfter(BASE_NS::array_view<const uint64_t> afterIdentifiers, uint64_t taskIdentifier, in CORE_BEGIN_NAMESPACE()
|
| H A D | dispatcher_impl.h | 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()
36 void SubmitAfter(BASE_NS::array_view<const uint64_t> afterIdentifiers, uint64_t taskIdentifier, in CORE_BEGIN_NAMESPACE()
|
| H A D | task_queue.h | 76 virtual void Submit(uint64_t taskIdentifier, IThreadPool::ITask::Ptr&& task) = 0;
81 virtual void Remove(uint64_t taskIdentifier) = 0;
|
| /ohos5.0/foundation/graphic/graphic_3d/lume/LumeEngine/api/core/threading/ |
| H A D | intf_thread_pool.h | 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…
129 …ual void SubmitAfter(BASE_NS::array_view<const uint64_t> afterIdentifiers, uint64_t taskIdentifier,
|