#include "CGraph.h"

using namespace CGraph;

class MyNode1 : public GNode {
public:
    CStatus run() override {
        printf("[%s], sleep for 1 second ...\n", this->getName().c_str());
        CGRAPH_SLEEP_SECOND(1)
        return CStatus();
    }
};

class MyNode2 : public GNode {
public:
    CStatus run() override {
        printf("[%s], sleep for 2 second ...\n", this->getName().c_str());
        CGRAPH_SLEEP_SECOND(2)
        return CStatus();
    }
};


int main() {
    /* 创建一个流水线，用于设定和执行流图信息 */
    GPipelinePtr pipeline = GPipelineFactory::create();
    GElementPtr a, b, c, d = nullptr;

    /* 注册节点之间的依赖关系 */
    pipeline->registerGElement<MyNode1>(&a, {}, "nodeA");
    pipeline->registerGElement<MyNode2>(&b, {a}, "nodeB");
    pipeline->registerGElement<MyNode1>(&c, {a}, "nodeC");
    pipeline->registerGElement<MyNode2>(&d, {b, c}, "nodeD");

    /* 执行流图框架 */
    pipeline->process();

    /* 清空流水线中所有的资源 */
    GPipelineFactory::remove(pipeline);

    return 0;
}

# pip install pycgraph

import time
from datetime import datetime

from pycgraph import GNode, GPipeline, CStatus


class MyNode1(GNode):
    def run(self):
        print("[{0}] {1}, sleep for 1 second ... ".format(datetime.now(), self.getName()))
        time.sleep(1)
        return CStatus()

class MyNode2(GNode):
    def run(self):
        print("[{0}] {1}, sleep for 2 second ... ".format(datetime.now(), self.getName()))
        time.sleep(2)
        return CStatus()


if __name__ == '__main__':
    pipeline = GPipeline()
    a, b, c, d = MyNode1(), MyNode2(), MyNode1(), MyNode2()

    pipeline.registerGElement(a, set(), "nodeA")
    pipeline.registerGElement(b, {a}, "nodeB")
    pipeline.registerGElement(c, {a}, "nodeC")
    pipeline.registerGElement(d, {b, c}, "nodeD")

    pipeline.process()

• CsCGraph : A CSharp native, CGraph-API-liked DAG project
• JaCGraph : A Java native, CGraph-API-liked DAG project
• GoCGraph : A Go native, CGraph-API-liked DAG project
• CGraph-lite : A one-header-only, CGraph-API-liked DAG project, lite version by C++

[2021.05.04 - v1.0.0 - Chunel]

• 提供图化执行功能，支持非依赖节点并行计算

[2021.05.09 - v1.1.0 - Chunel]

• 优化图执行过程中的并发度

[2021.05.18 - v1.1.1 - Chunel]

• 添加节点name和session信息

[2021.05.23 - v1.2.0 - Chunel]

• 提供单节点循环执行功能

[2021.05.29 - v1.3.0 - Chunel]

• 提供cluster（簇）和region（区域）划分和循环执行功能
• 提供tutorial内容，包含多种使用样例

[2021.06.14 - v1.4.0 - Chunel]

• 提供param（参数）传递机制
• 提供group（组）功能，多节点模块统一继承自group模块
• 添加对Linux系统的的支持

[2021.06.20 - v1.4.1 - Chunel]

• 提供condition（条件）功能
• 添加对Windows系统的支持

[2021.06.24 - v1.5.0 - Chunel]

• 提供pipeline工厂创建方法
• 更新tutorial内容

[2021.07.07 - v1.5.1 - Chunel]

• 优化线程池功能。实现任务盗取机制

[2021.07.11 - v1.5.2 - Chunel]

• 优化线程池功能。实现线程数量自动调节机制

[2021.07.31 - v1.5.3 - Chunel]

• 优化线程池功能。实现任务批量获取功能，优化任务盗取机制

[2021.08.29 - v1.6.0 - Chunel]

• 提供多pipeline功能，优化底层逻辑
• 更新tutorial内容

[2021.09.19 - v1.6.1 - Chunel]

• 提供Lru算子、Trie算子和模板节点功能，优化底层逻辑
• 更新tutorial内容

[2021.09.29 - v1.7.0 - Chunel]

• 提供aspect(切面)功能，用于横向扩展node或group功能
• 更新tutorial内容

[2021.10.07 - v1.7.1 - Chunel]

• 优化aspect(切面)实现逻辑，提供切面参数功能，提供批量添加切面功能
• 更新tutorial内容

[2021.11.01 - v1.8.0 - Chunel]

• 提供adapter(适配器)功能，提供singleton适配器功能
• 优化pipeline执行逻辑
• 更新tutorial内容

[2021.12.18 - v1.8.1 - Chunel]

• 优化了返回值CStatus信息

[2022.01.02 - v1.8.2 - Chunel]

• 提供节点执行超时自动退出功能，提供task group(任务组)功能
• 提供线程池配置参数设置方法

[2022.01.23 - v1.8.3 - Chunel]

• 提供function适配器，实现函数式编程功能
• 提供线程优先级调度功能，提供线程绑定cpu执行功能
• 更新tutorial内容

[2022.01.31 - v1.8.4 - Chunel]

• 提供node(节点)异步执行的功能

[2022.02.03 - v1.8.5 - Chunel]

• 提供daemon(守护)功能，用于定时执行非流图中任务
• 更新tutorial内容

[2022.04.03 - v1.8.6 - Chunel]

• 提供DistanceCalculator算子，用于实现任意数据类型、任意距离类型的计算
• 更新tutorial内容

[2022.04.05 - v2.0.0 - Chunel]

• 提供domain(领域)功能，提供Ann领域抽象模型，开始支持个别专业方向
• 提供hold执行机制
• 更新tutorial内容

[2022.05.01 - v2.0.1 - Chunel]

• 优化pipeline注册机制，支持init方法自定义顺序执行
• 提供一键编译脚本

[2022.05.29 - v2.1.0 - Chunel]

• 提供element参数写入方法
• 提供针对C++14版本的支持
• 更新tutorial内容

[2022.10.03 - v2.1.1 - Chunel]

• 提供线程池中的任务优先级机制
• 优化group执行逻辑

[2022.11.03 - v2.2.0 - Chunel]

• 提供message(消息)功能，主要用于完成不同pipeline之间的数据传递
• 更新tutorial内容

[2022.12.24 - v2.2.1 - Chunel]

• 提供TemplateNode(模板节点)功能，用于优化参数传参方式
• 更新tutorial内容

[2022.12.25 - v2.2.2 - yeshenyong]

• 优化图执行逻辑

[2022.12.30 - v2.2.3 - Chunel]

• 提供message发布订阅功能
• 提供执行引擎切换功能

[2023.01.21 - v2.3.0 - Chunel]

• 提供event(事件)功能
• 提供CGraph Intro.xmind文件，通过脑图的方式，介绍了CGraph的整体逻辑

[2023.01.25 - v2.3.1 - Chunel]

• 提供针对C++11版本的支持。感谢 MirrorYuChen 提供相关解决方案

[2023.02.10 - v2.3.2 - Chunel]

• 优化调度策略，提供调度参数配置接口
• 提供英文版本readme.md

[2023.02.12 - v2.3.3 - yeshenyong, Chunel]

• 提供graphviz可视化图展示功能
• 提供参数链路追踪功能

[2023.02.22 - v2.3.4 - Chunel]

• 优化Windows系统下调度机制
• 优化param机制和event(事件)机制

[2023.03.25 - v2.4.0 - woodx, Chunel]

• 提供可运行的docker环境，和构建docker环境的dockerfile文件
• 提供pipeline调度资源管控机制
• 优化调度性能

[2023.05.05 - v2.4.1 - Chunel]

• 提供线程绑定执行功能
• 提供pipeline最大并发度获取方法。感谢 Hanano-Yuuki 提供相关解决方案
• 提供pipeline异步执行功能和执行时退出功能

[2023.06.17 - v2.4.2 - Chunel]

• 提供MultiCondition(多条件)功能
• 提供pipeline暂停执行和恢复执行功能

[2023.07.12 - v2.4.3 - Chunel]

• 优化CStatus功能，添加了异常定位信息

[2023.09.05 - v2.5.0 - Chunel]

• 提供perf功能，用于做pipeline的性能分析
• 提供element的超时机制
• 提供some(部分)功能，优化pipeline的异步执行方式

[2023.09.15 - v2.5.1 - Chunel]

• 提供fence(栅栏)功能
• 提供coordinator(协调)功能

[2023.11.06 - v2.5.2 - Chunel]

• 优化message(消息)功能，可以设定写入阻塞时的处理方式，减少内存copy次数
• 添加example相关内容，针对不同行业，提供一些简单实现
• 优化调度性能

[2023.11.15 - v2.5.3 - Chunel]

• 提供proto定义文件
• 添加mutable(异变)功能，提供依赖关系注册语法糖

[2024.01.05 - v2.5.4 - Chunel]

• 提供test内容，包含性能和功能方面的测试用例
• 优化event(事件)机制，支持异步等待功能

[2024.07.18 - v2.6.0 - PaPaPig-Melody, Chunel]

• 提供pipeline的拓扑执行的方式
• 提供判定element之间是否有依赖关系的方法
• 提供bazel编译方式
• 优化perf功能

[2024.09.17 - v2.6.1 - Chunel]

• 提供pipeline的静态执行的方式，提供基于静态执行的微任务机制
• 提供pipeline剪裁功能，用于删除element之间重复的依赖
• 提供element删除依赖的方法
• 优化event(事件)机制，异步事件可以等待结束
• 发布 CGraph-lite 项目，提供简单DAG构图和参数传递功能。接口完全兼容，可无缝切换至本项目

[2024.11.16 - v2.6.2 - Chunel]

• 优化参数互斥机制和获取性能
• 修复辅助线程异常等待问题
• 更新tutorial内容

[2025.03.16 - v3.0.0 - Chunel]

• 提供 Python 版本
• 提供stage(阶段)功能，用于element之间同步运行
• 更新tutorial内容

[2025.05.04 - v3.1.0 - Chunel]

• 提供 全量功能 Python 版本
• 提供 Python 和 C++ 混合编程功能
• 提供 Python 打包功能，支持 pip3 install PyCGraph 安装

[2025.06.15 - v3.1.1 - Chunel]

• 提供 C# 和 Java 版本
• 提供 CODE_OF_CONDUCT.md 文档

[2025.09.06 - v3.1.2 - Chunel]

• 提供 Go 版本
• 优化 message 功能
• 优化 aspect 功能

[2025.11.08 - v3.2.2 - Chunel]

• 提供 本地保存和加载 功能
• 修改 PyCGraph 为 pycgraph，支持 pip3 install pycgraph 安装

[2026.03.24 - v3.2.3 - Chunel]

• 优化 message 功能
• 优化 稳定性

[2026.05.10 - v3.2.4 - Chunel]

• 优化 pycgraph 功能

[2026.08.15 - v3.2.5 - Chunel]

• 优化调度性能
• 优化 pycgraph 功能
• 提供 lite 运行模式
• 修改 GSome 使用方式

[2026.08.22 - v3.3.0 - Chunel]

• 优化 GParam 的 trace 功能
• 优化 pycgraph 功能

• 感谢 Doocs 微信公众号 刊登相关介绍文档，欢迎加入 Doocs 开源社区
• 感谢《HelloGithub》期刊介绍和推荐：HelloGithub 第70期

• Thanks to the recommendation from awesome-cpp, we all know, it is the most authoritative recommendation list for cpp project in the world
• Thanks to the recommendation from Taskflow Group: awesome-parallel-computing, and we always treat taskflow as a role model
• Thanks to the recommendation from awesome-workflow-engines
• 感谢各位开发者 CONTRIBUTORS 为项目做出的贡献
• 感谢所有为CGraph项目提出的意见和建议的朋友，在此不一一提及。随时欢迎大家加入，一起共建

• 微信： ChunelFeng (欢迎扫描上方二维码，添加作者为好友。请简单备注个人信息^_^)
• 邮箱： [email protected]
• 源码： https://github.com/ChunelFeng/CGraph
• 论坛： www.chunel.cn