class Program
{
    private class MyNode1 : GNode
    {
        protected override CStatus Run()
        {
            Console.WriteLine($"[{DateTime.Now:yyyy-MM-dd HH:mm:ss.fff}] [{GetName()}], sleep for 1s.");
            Thread.Sleep(1000);
            return new CStatus();
        }
    }
    private class MyNode2 : GNode
    {
        protected override CStatus Run()
        {
            Console.WriteLine($"[{DateTime.Now:yyyy-MM-dd HH:mm:ss.fff}] [{GetName()}], sleep for 2s.");
            Thread.Sleep(2000);
            return new CStatus();
        }
    }
    private static void Main(string[] args)
    {
        var pipeline = new GPipeline();
        pipeline.RegisterGElement<MyNode1>(out var a, Array.Empty<GElement>(), "nodeA");
        pipeline.RegisterGElement<MyNode2>(out var b, new [] {a}, "nodeB");
        pipeline.RegisterGElement<MyNode1>(out var c, new [] {a}, "nodeC");
        pipeline.RegisterGElement<MyNode2>(out var d, new [] {b, c}, "nodeD");
        pipeline.Process();
    }
}

class Program
{
    private class MyParam : GParam
    {
        protected override void Reset(CStatus curStatus)
        {
            Val = 0;
        }
        public int Val { set; get; } = 0;
        public int Loop { set; get; } = 0;
    }
    private class MyReadParamNode : GNode
    {
        protected override CStatus Init()
        {
            var status = CreateGParam<MyParam>("param1");
            return status;
        }
        protected override CStatus Run()
        {
            var param = GetGParamWithNoEmpty<MyParam>("param1");
            Console.WriteLine($"[read] [{GetName()}] loop = {param.Loop}, val = {param.Val}");
            return new CStatus();
        }
    }
    private class MyWriteParamNode : GNode
    {
        protected override CStatus Run()
        {
            var param = GetGParam<MyParam>("param1");
            if (null == param)
            {
                return new CStatus("get param1 failed");
            }
            param.Val += 1;
            param.Loop += 1;
            return new CStatus();
        }
    }
    private static void Main(string[] args)
    {
        var pipeline = new GPipeline();
        pipeline.RegisterGElement<MyWriteParamNode>(out var a, Array.Empty<GElement>(), "writeNodeA");
        pipeline.RegisterGElement<MyReadParamNode>(out var b, new[] { a }, "readNodeB");
        pipeline.Process(3);
    }
}