天天向上

   1: using System.Timers;

   2: using System.Threading;

   1: class WorkTimer

   2:     {

   3:         protected System.Timers.Timer aTimer;

   4:         private int count = 0;

   5:         private int interval = 1000;

   6:         private int totalCount;

   7:         private int jobID;

   8:         private string workerName;

   9:         public int JobID { get { return jobID; } }

  10:         public bool IsBusy { get; set; }

  11:         public WorkTimer(string workerName, int jobID, int totalCount)

  12:         {

  13:             this.workerName = workerName;

  14:             this.totalCount = totalCount;

  15:             this.jobID = jobID;

  16:             SetTimer();

  17:         }

  18:         private void SetTimer()

  19:         {

  20:             IsBusy = true;

  21:             // Create a timer with a two second interval.

  22:             aTimer = new System.Timers.Timer(interval);

  23:             // Hook up the Elapsed event for the timer. 

  24:             aTimer.Elapsed += OnTimedEvent;

  25:             aTimer.AutoReset = true;

  26:             aTimer.Enabled = true;

  27:         }

  28:         private void OnTimedEvent(Object source, ElapsedEventArgs e)

  29:         {

  30:             count++;

  31:             Console.WriteLine("{0}, jobID {1} ({2}/{3}) {4:HH:mm:ss.fff}", workerName, 

  32:                               jobID, count, totalCount, e.SignalTime);

  33:             if(count>=totalCount)

  34:             {

  35:                 aTimer.Stop();

  36:                 aTimer.Dispose();

  37:                 IsBusy = false;

  38:             }

  39:         }

  40:     }

   1: abstract class Handler

   2:    {

   3:        public bool IsBusy

   4:        {

   5:            get {

   6:                if (wt == null) return false;

   7:                else return wt.IsBusy;

   8:            }

   9:        }

  10:        protected WorkTimer wt;

  11:        protected Handler nextHandler;

  12:        public int JobID { get { return wt.JobID; } }

  13:        public void SetNextHandler(Handler handler)

  14:        {

  15:            this.nextHandler = handler;

  16:        }

  17:        public abstract void Request(int jobID);     

  18:    }

   1: class Worker1Handler : Handler

   2:    {

   3:        public override void Request(int jobID)

   4:        {

   5:            if(jobID >= 0 && jobID < 5)

   6:            {

   7:                int totalCount = jobID;

   8:                if (!IsBusy)

   9:                {

  10:                    Console.WriteLine("----------");

  11:                    Console.WriteLine("{0} 開始處理 jobID = {1}", this.GetType().Name, jobID);

  12:                    Console.WriteLine("----------");

  13:                    wt = new WorkTimer(this.GetType().Name, jobID, totalCount);

  14:                }else if (nextHandler != null)

  15:                {

  16:                    Console.WriteLine("***");

  17:                    Console.WriteLine("{0} 正在處理jobID {1}中，無法處理 jobID = {2}", this.GetType().Name, this.JobID, jobID);

  18:                    Console.WriteLine("***");

  19:                    Thread.Sleep(1000);

  20:                    nextHandler.Request(jobID);

  21:                }

  22:            }

  23:            else if(nextHandler !=null)

  24:            {

  25:                nextHandler.Request(jobID);

  26:            }

  27:        }

  28:    }

  29:    class Worker2Handler : Handler

  30:    {

  31:        public override void Request(int jobID)

  32:        {

  33:            if (jobID >= 5 && jobID < 10)

  34:            {

  35:                int totalCount = jobID;

  36:                if (!IsBusy)

  37:                {

  38:                    Console.WriteLine("{0} 開始處理 jobID = {1}", this.GetType().Name, jobID);

  39:                    wt = new WorkTimer(this.GetType().Name, jobID, totalCount);

  40:                }

  41:                else if (nextHandler != null)

  42:                {

  43:                    Console.WriteLine("{0} 正在處理jobID {1}中，無法處理 jobID = {2}", this.GetType().Name, this.JobID, jobID);

  44:                    Thread.Sleep(1000);

  45:                    nextHandler.Request(jobID);

  46:                }

  47:            }

  48:            else if (nextHandler != null)

  49:            {

  50:                nextHandler.Request(jobID);

  51:            }

  52:        }

  53:    }

  54:    class Worker3Handler : Handler

  55:    {

  56:        public override void Request(int jobID)

  57:        {

  58:            if (jobID >= 10 && jobID < 15)

  59:            {

  60:                int totalCount = jobID;

  61:                if (!IsBusy)

  62:                {

  63:                    Console.WriteLine("{0} 開始處理 jobID = {1}", this.GetType().Name, jobID);

  64:                    wt = new WorkTimer(this.GetType().Name, jobID, totalCount);

  65:                }

  66:                else if (nextHandler != null)

  67:                {

  68:                    Console.WriteLine("{0} 正在處理jobID {1}中，無法處理 jobID = {2}", this.GetType().Name, this.JobID, jobID);

  69:                    Thread.Sleep(1000);

  70:                    nextHandler.Request(jobID);

  71:                }

  72:            }

  73:            else if (nextHandler != null)

  74:            {

  75:                nextHandler.Request(jobID);

  76:            }

  77:        }

  78:    }

   1: Handler work1 = new Worker1Handler();

   2: Handler work2 = new Worker2Handler();

   3: Handler work3 = new Worker3Handler();

   4: work1.SetNextHandler(work2);

   5: work2.SetNextHandler(work3);

   6: work3.SetNextHandler(work1);

   7:  

   8: int[] jobIDs = new int[] { 2, 3, 12, 5, 7, 3, 6, 10 };

   9: foreach (int jobID in jobIDs)

  10: {

  11:     work1.Request(jobID);

  12: }

  13: Console.Read();