एमएस ऑरलियन्स पर गेम सर्वर - भाग 1: अभिनेता क्या हैं

सामग्री

• एमएस ऑरलियन्स पर गेम सर्वर - भाग 1: अभिनेता क्या हैं

अभिनेता

उदाहरण

    class Program
    {
        interface IMessage { }

        class IncrementCommand : IMessage { }

        class TellCountCommand : IMessage { }

        class SaidCountEvent : IMessage
        {
            public int Count { get; }
            public int ActorId { get; }

            public SaidCountEvent(int count, int actorId)
            {
                Count = count;
                ActorId = actorId;
            }
        }

        class WriteMessageCommand : IMessage
        {
            public string Message { get; }

            public WriteMessageCommand(string message)
            {
                Message = message;
            }
        }

        static Task CreateCounterActor(
            BlockingCollection<IMessage> output,
            BlockingCollection<IMessage> input,
            int id
            )
        {
            return Task.Run(() =>
             {
                 var count = 0;

                 while (true)
                 {
                     var m = input.Take();
                     if (m is IncrementCommand)
                         count++;
                     if (m is TellCountCommand)
                         output.Add(new SaidCountEvent(count, id));
                 }
             });
        }

        static Task CreateWriterActor(BlockingCollection<IMessage> input)
        {
            return Task.Run(() =>
             {
                 while (true)
                 {
                     var m = input.Take();
                     if (m is WriteMessageCommand write)
                         Console.WriteLine(write.Message);
                     if (m is SaidCountEvent sc)
                         Console.WriteLine(
                             $"Counter   {sc.Count}   {sc.ActorId}"
                             );
                 }
             });
        }

        static void Main(string[] args)
        {
            var writerInput = new BlockingCollection<IMessage>();
            var firstInput = new BlockingCollection<IMessage>();
            var secondInput = new BlockingCollection<IMessage>();
            var writer = CreateWriterActor(writerInput);
            var firstCounter = CreateCounterActor(writerInput, firstInput, 1);
            var secondCounter = CreateCounterActor(writerInput, secondInput, 2);
            for (int i = 0; i < 5; i++)
            {
                firstInput.Add(new IncrementCommand());
            }
            for (int i = 0; i < 9; i++)
            {
                secondInput.Add(new IncrementCommand());
            }
            firstInput.Add(new TellCountCommand());
            secondInput.Add(new TellCountCommand());
            writerInput.Add(new WriteMessageCommand("  Main"));
            Console.ReadLine();
        }
    }

1. वह इंटरफ़ेस जिसके द्वारा हम उन संदेशों को चिह्नित करते हैं जिन्हें अभिनेता प्राप्त करता है या भेजता है:
   

   interface IMessage { }
   

   
   
2. वह कमांड जिसके साथ हम अभिनेता को अपना काउंटर (आंतरिक स्थिति) बढ़ाने के लिए कहते हैं:
   

   class IncrementCommand : IMessage { }
   

   
   
3. वह कमांड जिसकी मदद से हम अभिनेता को अपनी वर्तमान स्थिति (काउंटर) दूसरों को बताने के लिए कहते हैं:
   

   class TellCountCommand : IMessage { }
   

   
   
4. एक घटना जो अन्य अभिनेताओं को बताती है कि अभिनेता ने सभी को अपनी वर्तमान स्थिति (काउंटर) बताई है। जब TellCountCommand आदेश संसाधित होता है, तो उत्पन्न:
   

   class SaidCountEvent : IMessage
   {
       public int Count { get; }
       public int ActorId { get; }
   
       public SaidCountEvent(int count, int actorId)
       {
           Count = count;
           ActorId = actorId;
       }
   }
   

   
   गणना यह है कि अभिनेता के काउंटर पर अब एक्टरआईआरडी के बराबर एक पहचानकर्ता के साथ कितना डायल किया जाता है
   
5. यह कमांड एक्टर से कहता है कि इस संदेश को कंसोल में प्रिंट करें:
   

   class WriteMessageCommand : IMessage
   {
       public string Message { get; }
   
       public WriteMessageCommand(string message)
       {
           Message = message;
       }
   }
   

   
   
6. काउंटर की वर्तमान स्थिति को नियंत्रित करने वाला एक अभिनेता उदाहरण शुरू करता है:
   

           static Task CreateCounterActor(
            //   
               BlockingCollection<IMessage> output,
             // 
               BlockingCollection<IMessage> input,
            //              
               int id
               )
           {
               return Task.Run(() =>
                { 
                    //  .    
                    var count = 0;
   
                    while (true)
                    {
                      //     
                     //             
                        var m = input.Take();
                        if (m is IncrementCommand)
                            count++;
                        if (m is TellCountCommand)
                            output.Add(new SaidCountEvent(count, id));
                    }
                });
           }
   

   
   
7. एक अभिनेता बनाता है जो बस कंसोल को संदेश लिखता है:
   

           static Task CreateWriterActor(BlockingCollection<IMessage> input)
           {
               return Task.Run(() =>
                {
                    while (true)
                    {
                        var m = input.Take();
                        if (m is WriteMessageCommand write)
                            Console.WriteLine(write.Message);
                        if (m is SaidCountEvent sc)
                            Console.WriteLine(
                                $"Counter   {sc.Count}   {sc.ActorId}"
                                );
                    }
                });
           }
   

   
   

8.         static void Main(string[] args)
           {
               var writerInput = new BlockingCollection<IMessage>();
               var firstInput = new BlockingCollection<IMessage>();
               var secondInput = new BlockingCollection<IMessage>();
               var writer = CreateWriterActor(writerInput);
             //       
               var firstCounter = CreateCounterActor(writerInput, firstInput, 1);
               var secondCounter = CreateCounterActor(writerInput, secondInput, 2);
               //       
               for (int i = 0; i < 5; i++)
               {
                   firstInput.Add(new IncrementCommand());
               }
               //       .
               for (int i = 0; i < 9; i++)
               {
                   secondInput.Add(new IncrementCommand());
               }
               //         .
               //      writer      
               firstInput.Add(new TellCountCommand());
               secondInput.Add(new TellCountCommand());
              // writer     .
               writerInput.Add(new WriteMessageCommand("  Main"));
               Console.ReadLine();
           }
   

   
   

    public interface ICounterActor
    {
        void Increment();
        void TellCount();
    }

    public class CounterActor : ICounterActor
    {
        private readonly Task _taks;
        private readonly BlockingCollection<IMessage> _input;
        private readonly BlockingCollection<IMessage> _output;

        public CounterActor(BlockingCollection<IMessage> output)
        {
            _input = new BlockingCollection<IMessage>(); ;
            _output = output;
            _taks = Task.Run(() =>
            {
                //State
                var count = 0;

                while (true)
                {
                    var m = _input.Take();
                    if (m is IncrementCommand)
                        count++;
                    if (m is TellCountCommand)
                        _output.Add(new SaidCountEvent(count, _taks.Id));
                }
            });
        }

        public void Increment()
        {
            _input.Add(new IncrementCommand());
        }

        public void TellCount()
        {
            _input.Add(new TellCountCommand());
        }
    }