首页 > 开发 > 综合 > 正文

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

2024-07-21 02:28:50
字体:
来源:转载
供稿:网友

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

    timer大体定义如下:

  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.count>0)
163             {
164                 for(int i=0;i<evtids.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

发表评论 共有条评论
用户名: 密码:
验证码: 匿名发表