public abstract class NewActor<T>

     {

         private readonly ActionBlock<T> _action;

         protected NewActor()

         {

             _action = new ActionBlock<T>(T => Receive(T));

         }

         // 接收并处理消息

         protected abstract void Receive(T message);

         public void Post(T message)

         {

             _action.Post(message);

         }

         public void Shutdown()

         {

             _action.Complete();

             _action.Completion.Wait();

         }

     }