C# Timer 最简单形象的教程

Posted 2023-04-25

参考技术A System.Threading.Timer是使用多线程时间定时类：

调用方法：

参数有4个：

TimerCallback 是委托类型方法，我们只需new TimerCallback(定时运行的方法名)就可以了；
state 是回调函数的参数，可以传null；
dueTime 是触发回调函数等待的时间间隔，如果为0则不等待；
period 是回调函数再次被触发的时间间隔；

dueTime 和 period 是否觉得很茫然？怎么定义两个时间间隔参数呢？ 其实System.Threading.Timer是多线程触发回调函数的，也就是说第一次触发的事件不会影响下一次运行回调函数的时间。像车站，1号车在等待 dueTime 时间后发车，并承诺一定的时间后到站， 2号车将在1号车出发后 period 的时间发车，3号车也将在2号车出发后 period 的时间发车，也就是说就算1号车还未到目的地站点也会不断发车，如果1号车最后到了目的站点然后返回出发站点就可以再次被安排第二次发车了。线程就相当于车，车站就相当于System.Threading.Timer这个实例化的类。

运行结果如下：

这里有个缺点，行李都是一个相同人的，能不能是动态的，也就是能不能载其他人的行李呢？这里可以的，就是再创建一个车站，如何？呵呵

你们开车开过瘾了没？

C# System.Timers.Timer 奇怪的行为？

【中文标题】C# System.Timers.Timer 奇怪的行为？

【英文标题】：C# System.Timers.Timer odd behavior?

【发布时间】：2019-04-10 20:11:14

【问题描述】：

我的目标是编写一个代码 sn-p，让我可以在并发环境中独占访问对象（f.ex 一个 txt 文件）。考虑到这一点，我正在测试使用两个 System.Timers 计时器构建的简单程序。两个计时器的事件处理程序共享同一个锁对象（请参阅下面的代码）。 定时器以不同的时间间隔同时启动，定时器 1 为 3 秒，定时器 2 为 1 秒。 Timer1 应该只工作一个周期，在此期间它的事件处理程序将休眠 10 秒，从而保持锁定。 令我惊讶的是，当锁被释放时，我并没有把所有的事件都堆积在内存中 timer2 事件（只有应用程序。每个其他事件）。我想，虽然 timer1 的事件处理程序有锁，但 timer2 的事件在内存中堆叠。但这显然不是真的。为什么一些 timer2 事件消失了？

class Program

    static int counter = 0;
    static readonly object locker = new object();
    System.Timers.Timer timer1;
    System.Timers.Timer timer2;

    static void Main(string[] args)
    
        Program p = new Program();

        p.timer1 = new System.Timers.Timer(3000);
        p.timer1.Elapsed += new ElapsedEventHandler(p.Timer1EventHandler);
        p.timer1.Start();
        p.timer2 = new System.Timers.Timer(1000);
        p.timer2.Elapsed += new ElapsedEventHandler(p.Timer2EventHandler);
        p.timer2.Start();
        ThreadPool.SetMaxThreads(50, 50);
        Console.ReadLine();
    

    void Timer1EventHandler(object sender, ElapsedEventArgs e)
    
        timer1.Stop();
        DoThingsForTimer1Event();
    

    void DoThingsForTimer1Event()
    
        lock (locker)
        
            Console.WriteLine(DateTime.Now + " Timer1 event started." + " Current thread number " + Thread.CurrentThread.ManagedThreadId);

            Thread.Sleep(10000);

            Console.WriteLine(DateTime.Now + " Timer1 event finished. Lock released.");
        

    

    void Timer2EventHandler(object sender, ElapsedEventArgs e)
    
        counter++;
        lock (locker)
        
            Console.WriteLine(DateTime.Now + " Timer2 event fired. Current thread number " + Thread.CurrentThread.ManagedThreadId +
                " Counter=" + counter);
                                                 
    

【问题讨论】：

I don't get all stacked in memory timer2 events 你到底是什么意思，这似乎是你所期望的工作

虽然除非我读错了，但这正是它所做的

如果您对 3-8 的去向感到困惑 - 将 ++ 移入锁内。

从实用的角度来看，你也不能安全地同时在多个线程中使用++。所以如果你不把它们放在锁里，你必须使用Interlocked.Increment。这对您来说还不是一个大问题（因为竞争条件很少见），但它仍然是一个问题。

我认为它只是厌倦了亲自给你线程，我的意思是线程池不会尽可能快地放弃线程。我认为如果您将时间更改为 5 秒锁定，它很可能会按预期工作

【参考方案1】：

感谢 @TheGeneral 将此确定为 OP 问题的根本原因。

您在这里遇到的主要问题是您的ThreadPool 已用尽（而您的Timer 正在使用ThreadPool），因为您的CPU 只有4 个逻辑核心。这就解释了为什么我个人（有 12 个核心）无法重现这一点。

根据the docs：

默认情况下，最小线程数设置为系统上的处理器数。

所以线程池调度程序很可能从 4 个线程开始。线程池调度程序相当保守。它不只是根据您的要求提供线程 - 有时delays creating them 可以帮助提高整体系统性能（因为启动线程很昂贵）。

要解决您的即时问题，您可以提示线程池更快地启动更多线程，使用：

ThreadPool.SetMinThreads(50, 50);

这将快速提升到 50，然后更保守。

但从长远来看，问题在于您在线程池中执行长时间运行的操作。这是一个坏主意。您可能希望将它们移动到线程或long running tasks（实际上是线程）。但这两种选择都有其缺点。从根本上说，如果可能，您希望将长时间运行的操作保留在线程池之外。

如果不了解您使用lock 的原因，很难给出好的建议。但是要考虑的一个选项可能是使用BlockingCollection 来形成一个队列 - 然后让一个单独的线程处理该队列。这意味着您的 Timer 事件只会将一个条目添加到队列中然后返回 - 处理的首当其冲将在处理来自队列的条目的（单个）线程中。