bahman/scylla
1
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

tasks: add task_manager::module::make_and_start_task method

Browse Source 
In most cases, tasks manager's tasks are started just after they are
created. Thus, to reduce boilerplate required for creating and starting
tasks, make_and_start_task method is added.
This commit is contained in:
Aleksandra Martyniuk
2023-02-03 17:16:33 +01:00
parent 53366db6c6
commit cb3b6cdc1a
1 changed files with 13 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
tasks/task_manager.hh
View File

@@ -187,6 +187,19 @@ public:
// If task has a parent, data concerning its children is updated and sequence number is inherited
// from a parent and set. Otherwise, it must be set by caller.
future<task_ptr> make_task(task::task_impl_ptr task_impl_ptr, task_info parent_d = task_info{});
// Must be called on target shard.
template<typename TaskImpl, typename... Args>
requires std::is_base_of_v<task::impl, TaskImpl> &&
requires (module_ptr module, Args&&... args) {
{TaskImpl(module, std::forward<Args>(args)...)} -> std::same_as<TaskImpl>;
}
future<task_ptr> make_and_start_task(tasks::task_info parent_info, Args&&... args) {
auto task_impl_ptr = std::make_unique<TaskImpl>(shared_from_this(), std::forward<Args>(args)...);
auto task = co_await make_task(std::move(task_impl_ptr), parent_info);
task->start();
co_return task;
}
};
public:
task_manager(config cfg, abort_source& as) noexcept;