63 lines
1.4 KiB
Markdown
63 lines
1.4 KiB
Markdown
|
# TaskGroup::AddTask
|
|||
|
|
|
|||
|
|
```cpp
|
|||
|
|
uint64_t AddTask(std::unique_ptr<ITask> task);
|
|||
|
|
uint64_t AddTask(Callback&& func, TaskPriority priority = TaskPriority::Normal);
|
|||
|
|
```
|
|||
|
|
|
|||
|
|
将任务添加到任务组。支持两种添加方式：传入 ITask 对象或传入回调函数。
|
|||
|
|
|
|||
|
|
**参数：**
|
|||
|
|
- `task` - 唯一指针管理的 ITask 对象
|
|||
|
|
- `func` - 要执行的回调函数
|
|||
|
|
- `priority` - 任务优先级，默认为 `TaskPriority::Normal`
|
|||
|
|
|
|||
|
|
**返回：** 返回分配的任务 ID，可用于设置依赖关系
|
|||
|
|
|
|||
|
|
**线程安全：** ✅ 线程安全
|
|||
|
|
|
|||
|
|
**复杂度：** O(1)
|
|||
|
|
|
|||
|
|
**示例：**
|
|||
|
|
|
|||
|
|
```cpp
|
|||
|
|
#include "XCEngine/Threading/TaskGroup.h"
|
|||
|
|
#include "XCEngine/Threading/Task.h"
|
|||
|
|
#include <iostream>
|
|||
|
|
#include <memory>
|
|||
|
|
|
|||
|
|
using namespace XCEngine::Threading;
|
|||
|
|
|
|||
|
|
class MyTask : public ITask {
|
|||
|
|
public:
|
|||
|
|
explicit MyTask(const std::string& name) : m_name(name) {}
|
|||
|
|
|
|||
|
|
void Execute() override {
|
|||
|
|
std::cout << "Executing: " << m_name << "\n";
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
private:
|
|||
|
|
std::string m_name;
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
int main() {
|
|||
|
|
TaskGroup group;
|
|||
|
|
|
|||
|
|
auto task = std::make_unique<MyTask>("DataLoading");
|
|||
|
|
uint64_t taskId = group.AddTask(std::move(task));
|
|||
|
|
|
|||
|
|
uint64_t callbackId = group.AddTask([]() {
|
|||
|
|
std::cout << "Lambda task executing\n";
|
|||
|
|
}, TaskPriority::High);
|
|||
|
|
|
|||
|
|
group.AddDependency(callbackId, taskId);
|
|||
|
|
|
|||
|
|
group.Wait();
|
|||
|
|
return 0;
|
|||
|
|
}
|
|||
|
|
```
|
|||
|
|
|
|||
|
|
## 相关文档
|
|||
|
|
|
|||
|
|
- [TaskGroup 总览](task-group.md) - 返回类总览
|