C#多线程-不同线程之间通过事件委托封送调用方法

2016-02-19 13:07 41 1 收藏

下面图老师小编要向大家介绍下C#多线程-不同线程之间通过事件委托封送调用方法,看起来复杂实则是简单的,掌握好技巧就OK,喜欢就赶紧收藏起来吧!

【 tulaoshi.com - 编程语言 】

前段时间做了一个自定义单件Timer,该Timer能够根据相应数据记录(Row)中的记录ID和设定分钟Minutes 做相应的事件调用,但是如果此事件处理程序在一Form中时则不能正确调用它,但是把82到93行的注释去掉就可以了。

    Timer大体定义如下:

(本文来源于图老师网站,更多请访问http://www.tulaoshi.com/bianchengyuyan/)

  1 using System;
  2 using System.Threading;
  3 using System.ComponentModel;
  4 using System.Windows.Forms;
  5
  6 /************************************************************
  7  * MyTimer.Timer能够根据同一Timer定时基准对不同的定时事件做定时。
  8  *
  9  * MyTimer.Timer包含一Hashtable和Threading.Timer,每次Timer定时回调
 10  * 遍历Hashtable并根据其中的TimerNode的定时周期值是否为零来判断是否调用
 11  * 相应的TimerCome事件。
 12  ************************************************************ */
 13 namespace MyTimer
 14 {
 15     /// summary
 16     /// 事件定时节点
 17     /// /summary
 18     internal class TimerNode
 19     {
 20         /// summary
 21         /// 构造函数
 22         /// /summary
 23         /// param name="TimeCount"定时周期数/param
 24         /// param name="EvtID"事件ID/param
 25         public TimerNode(long TimeCount,object EvtID)
 26         {
 27             this.mTimeCount=TimeCount;
 28             this.mEvtID=EvtID;
 29         }
 30         private long mTimeCount;
 31         private object mEvtID;
 32
 33         public long TimeCount
 34         {
 35             get{return mTimeCount;}
 36             set{mTimeCount=value;}
 37         }
 38         public object EvtID
 39         {
 40             get{return mEvtID;}
 41         }
 42     }
 43
 44     public class TimerEventArgs:EventArgs
 45     {
 46         private System.Collections.ArrayList mEvtIDs;
 47         public System.Collections.ArrayList EvtIDs
 48         {
 49             get{return mEvtIDs;}
 50         }
 51
 52         /// summary
 53         /// 构造
 54         /// /summary
 55         /// param name="EvtIDs"触发的事件ID列表/param
 56         public TimerEventArgs(System.Collections.ArrayList EvtIDs):base()
 57         {
 58             this.mEvtIDs=EvtIDs;
 59         }
 60     }
 61
 62     public delegate void TimerEventHandler(TimerEventArgs e);
 63
 64     /// summary
 65     /// Timer 单件模式,不能实例化。
 66     /// /summary
 67     public class Timer
 68     {
 69         /// summary
 70         /// 有节点定时到事件
 71         /// /summary
 72         public static event TimerEventHandler TimeCome;
 73
 74         /// summary
 75         /// 唤醒TimeCome事件。
 76         /// /summary
 77         /// param name="e"此参数包含定时到事件列表/param
 78         static void RaiseTimeCome(TimerEventArgs e)
 79         {
 80             if(TimeCome!=null)
 81             {
 82 //                if(TimeCome.Target is System.ComponentModel.ISynchronizeInvoke)
 83 //                {
 84 //                    System.ComponentModel.ISynchronizeInvoke aSynch=TimeCome.Target as System.ComponentModel.ISynchronizeInvoke;
 85 //                    if(aSynch.InvokeRequired)
 86 //                    {
 87 //                        object[] args=new object[1]{e};
 88 //                        aSynch.BeginInvoke(TimeCome,args);
 89 //                    }
 90 //                    else
 91 //                        TimeCome(e);
 92 //                }
 93 //                else
 94                     TimeCome(e);
 95             }
 96         }
 97         static readonly long mPeriod=1000*60;//定时间隔1分钟。
 98         static System.Threading.Timer mTimer;
 99         static Timer()
100         {
101             mTimer=new System.Threading.Timer(new TimerCallback(TimeArrive),null,Timeout.Infinite,mPeriod);
102         }
103
104         /// summary
105         /// 定时器开始运行
106         /// /summary
107         public static void Run()
108         {
109             mTimer.Change(0,mPeriod);
110         }
111
112         /// summary
113         /// 定时器停止。
114         /// /summary
115         public static void Stop()
116         {
117             mTimer.Change(Timeout.Infinite,mPeriod);
118         }
119
120         /// summary
121         /// 加入定时事件,如果此定时事件已存在则修改其定时周期。
122         /// /summary
123         /// param name="EvtID"事件ID/param
124         /// param name="TimeCount"周期数/param
125         public static void Add(object EvtID,long TimeCount)
126         {
127             if(mTimerNodes.ContainsKey(EvtID))
128             {
129                 ((TimerNode)mTimerNodes[EvtID]).TimeCount=TimeCount;
130             }
131             else
132                 mTimerNodes.Add(EvtID,new TimerNode(TimeCount,EvtID));
133         }
134
135         /// summary
136         /// 移除此定时事件
137         /// /summary
138         /// param name="EvtID"事件ID/param
139         public static void Remove(object EvtID)
140         {
141             if(mTimerNodes.ContainsKey(EvtID))
142                 mTimerNodes.Remove(EvtID);
143         }
144
145         /// summary
146         /// 此函数是基准定时器mTimer的回调函数,
147         /// 在此函数中将检查事件表,如期事件定时周期数已到则将其加入事件参数中
148         /// 并唤醒事件。
149         /// /summary
150         /// param name="state"/param
151         static void TimeArrive(object state)
152         {
153             System.Collections.ArrayList EvtIDs=new System.Collections.ArrayList();
154             foreach(TimerNode aNode in mTimerNodes.Values)
155             {
156                 aNode.TimeCount--;
157                 if(aNode.TimeCount=0)
158                 {
159                     EvtIDs.Add(aNode.EvtID);
160                 }
161             }
162             if(EvtIDs.Count0)
163             {
164                 for(int i=0;iEvtIDs.Count;i++)
165                 {
166                     mTimerNodes.Remove(EvtIDs[i]);
167                 }
168                 RaiseTimeCome(new TimerEventArgs(EvtIDs));
169             }
170         }
171
172         /// summary
173         /// 事件表
174         /// /summary
175         static System.Collections.Hashtable mTimerNodes=new System.Collections.Hashtable();
176     }
177
178
179 }
180

(本文来源于图老师网站,更多请访问http://www.tulaoshi.com/bianchengyuyan/)

来源:http://www.tulaoshi.com/n/20160219/1603025.html

延伸阅读
下面我们就动手来创建一个线程,使用Thread类创建线程时,只需提供线程入口即可。(线程入口使程序知道该让这个线程干什么事) 在C#中,线程入口是通过ThreadStart代理(delegate)来提供的,你可以把ThreadStart理解为一个函数指针,指向线程要执行的函数,当调用Thread.Start()方法后,线程就开始执行ThreadStart所代表或者说指向的函数。 ...
.NET将关于多线程的功能定义在System.Threading名字空间中。因此,要使用多线程,必须先声明引用此名字空间(using System.Threading;)。 即使你没有编写多线程应用程序的经验,也可能听说过“启动线程”“杀死线程”这些词,其实除了这两个外,涉及多线程方面的还有诸如“暂停线程”“优先级”“挂起线程”“恢复线程”等等。下面将一个...
标签: Java JAVA基础
不提倡使用的方法是为支持向后兼容性而保留的那些方法,它们在以后的版本中可能出现,也可能不出现。Java 多线程支持在版本 1.1 和版本 1.2 中做了重大修订,stop()、suspend() 和 resume() 函数已不提倡使用。这些函数在 JVM 中可能引入微妙的错误。虽然函数名可能听起来很诱人,但请抵制诱惑不要使用它们。 调试线程化...
委托 和 事件 在 .Net Framework中的应用非常广泛,然而,较好地理解委托和事件对很多接触 C# 时间不长的人来说并不容易。它们就像是一道槛儿,过了这个槛的人,觉得真是太容易了,而没有过去的人每次见到委托和事件就觉得心里憋得慌,混身不自在。本文中,我将通过两个范例由浅入深地讲述什么是委托、为什么要使用委托、事件的由来、...
摘要:本文论述了各种模式的线程(单线程、单元线程和自由线程)以及每种模式的使用方法。同时,还提供了一个使用线程的 C# 语言代码示例,以帮助您编写使用线程的应用程序。本文还讨论了多线程代码中的一些重要问题。 简介 编写多线程 Microsoft® 消息队列 (MSMQ) 触发器应用程序向来是一件让人畏惧的事情。不过,.NET 框架...

经验教程

858

收藏

74
微博分享 QQ分享 QQ空间 手机页面 收藏网站 回到头部