using System.Threading.Tasks.Dataflow;

using System.Threading.Tasks;

using System;

using System.Threading;

public class Program

{

    public static void Main()

    {

        M().GetAwaiter().GetResult();

    }

    async static Task M() { 

        var actor = new Actor();

        await actor.Action.SendAsync(2);

        await actor.Action.SendAsync(2);

​

        actor.Action.Complete();

        await actor.Action.Completion;

​

        // State Будет = 4

        Console.WriteLine($"\n State = {actor.State}");

        Console.ReadLine();

​

    }

}

​

public class Actor

{

​

    int state;

    public int State { get { return state; } }

​

    public Actor() {

        Action = new (x =>

            {

                this.state = this.state + x;

            });

​

    }

​

    public ActionBlock<int> Action { get;} 

​

}

​