using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Threading.Tasks;using 設計模式講解.Command;namespace 設計模式講解{    class PRogram    {        static void Main(string[] args)        {            /*命令模式，場景使用不同的方式實現多線程編程             命令：用戶發送不同的命令，接收者執行對應的方法             接收者：負責接收命令并且執行命令             調用者：負責調用命令            */            List<int> caculateList = new List<int>();            for (int i = 0; i < 10; i++)            {                caculateList.Add(i);            }            MTReceiver _MTReceiver = new MTReceiver();            ThreadPoolCmd _ThreadPoolCmd = new ThreadPoolCmd(_MTReceiver);            ParallelCmd _ParallelCmd = new ParallelCmd(_MTReceiver);            TaskCmd _TaskCmd = new TaskCmd(_MTReceiver);            Invoker _Invoker = new Invoker();            _Invoker.SetCommand(_ParallelCmd);            _Invoker.ExcuteCommand(caculateList);            Console.ReadKey();        }    }}
MTReceiver
using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Threading.Tasks;using System.Threading;namespace 設計模式講解.Command{    public class MTReceiver    {        /// <summary>        /// 線程池        /// </summary>        /// <param name="caculateList"></param>        public void ThreadPoolMethod(List<int> caculateList)        {            foreach (var item in caculateList)            {                ThreadPool.QueueUserWorkItem(new WaitCallback(t =>                {                    Console.WriteLine("線程池計算：{0},線程ID：{1}", t, Thread.CurrentThread.ManagedThreadId);                }),item);            }        }        /// <summary>        /// 并行        /// </summary>        /// <param name="caculateList"></param>        public void ParallelMethod(List<int> caculateList)        {            Parallel.ForEach(caculateList, t =>            {                Console.WriteLine("線程池計算：{0},線程ID：{1}", t, Thread.CurrentThread.ManagedThreadId);            });        }        /// <summary>        /// 直接創建Task        /// </summary>        /// <param name="caculateList"></param>        public void TaskMethod(List<int> caculateList)        {            Task[] tasks = new Task[caculateList.Count];            for (int i = 0; i < tasks.Length; i++)            {                tasks[i] = Task.Factory.StartNew(() => {                    Console.WriteLine("線程池計算：{0},線程ID：{1}", i, Thread.CurrentThread.ManagedThreadId);                });            }                      Task.WaitAll(tasks);        }    }}
ICmd
using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Threading.Tasks;namespace 設計模式講解.Command{    public abstract class ICmd    {        protected MTReceiver _MTReceiver;        public ICmd(MTReceiver _MTReceiver)        {            this._MTReceiver = _MTReceiver;        }        public abstract void Excute(List<int> caculateList);    }}
ThreadPoolCmd
using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Threading.Tasks;namespace 設計模式講解.Command{    public class ThreadPoolCmd : ICmd    {        public ThreadPoolCmd(MTReceiver _MTReceiver) : base(_MTReceiver)        {        }        public override void Excute(List<int> caculateList)        {            this._MTReceiver.ThreadPoolMethod(caculateList);        }    }}
ParallelCmd
using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Threading.Tasks;namespace 設計模式講解.Command{    public class ParallelCmd : ICmd    {        public ParallelCmd(MTReceiver _MTReceiver) : base(_MTReceiver)        {        }        public override void Excute(List<int> caculateList)        {            this._MTReceiver.ParallelMethod(caculateList);        }    }}
TaskCmd
using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Threading.Tasks;namespace 設計模式講解.Command{    public class TaskCmd : ICmd    {        public TaskCmd(MTReceiver _MTReceiver) : base(_MTReceiver)        {        }        public override void Excute(List<int> caculateList)        {            this._MTReceiver.TaskMethod(caculateList);        }    }}
Invoker
using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Threading.Tasks;namespace 設計模式講解.Command{    public class Invoker    {        private ICmd cmd;        public void SetCommand(ICmd cmd)        {            this.cmd = cmd;        }        public void ExcuteCommand(List<int> caculateList)        {            cmd.Excute(caculateList);        }    }}