C# 调用定时器上的方法的单独线程（定时器超出范围）

Question

我的程序有一个工作版本，我的程序的主要部分使用 forms.timer 在与 GUI 相同的线程上运行。

我正在尝试升级到使用 2 个线程的更好版本。我的一个线程（处理所有信息）需要重复调​​用（在计时器上）。

我正在使用我的主要课程中的以下内容：

Timer tmr = new Timer(new TimerCallback(bot.refresh), null, 0, 1000);

其中 bot.refresh 是我希望每秒（1000 毫秒）调用一次的方法，直到我停止它为止。

public void refresh(Object obj)
{
        Debug.WriteLine("Updated: " + DateTime.Now.ToString());
}

大约 1/3 的时间计时器将停止运行，我将得到以下输出：

Updated: 23/11/2013 4:37:24 PM
Updated: 23/11/2013 4:37:25 PM
Updated: 23/11/2013 4:37:26 PM
Updated: 23/11/2013 4:37:27 PM
Updated: 23/11/2013 4:37:28 PM
Updated: 23/11/2013 4:37:29 PM
Updated: 23/11/2013 4:37:30 PM
The thread '<No Name>' (0x3f20) has exited with code 0 (0x0).
The thread '<No Name>' (0x37a0) has exited with code 0 (0x0).

关于为什么会发生这种情况的任何建议？

另外，有没有更好的方法可以做到这一点？我觉得这是一种奇怪的方法。

感谢您的帮助。

编辑：

这会超出范围吗？这样我可以在需要时而不是在构造 Main 时启动计时器。是否需要在构造函数中才能被引用？

class Main
{
    Timer tmr;
    public Main()
    {

    }

    public void start()
    {
         tmr = new Timer (new TimerCallback(bot.refresh), null, 0, 1000);
    }
}

谢谢。

Answer 1

您的计时器超出范围，最终被垃圾收集并停止运行。您必须保留对它的引用，以免超出范围。

class MainClass
{
    public MainClass()
    {
        tmr = new Timer(new TimerCallback(bot.refresh), null, 0, 1000);
    }

    Timer tmr;
}

至于更好的处理方式，这取决于bot.refresh 在做什么。但是，如果可能的话，我会使用消费者 - 生产者模型并收集第二个线程刚进入时处理的“排队工作”（这可能对你根本不起作用，就像我说的那样，这取决于bot.refesh有效。）

class MainClass
{
    public MainClass()
    {
        bot = new Bot();
        botDataProducer = BotDataProducer();
        dataQueue = new BlockingCollection<BotData>();
        consumer = Task.Factory.Run(() => ProcessData, TaskCreationOptions.LongRunning);
        producer = Task.Factory.Run(() => GenerateData, TaskCreationOptions.LongRunning);

    }

    BlockingCollection<BotData> dataQueue;
    Task consumer;
    Task producer;
    Bot bot;
    BotDataProducer botDataProducer;

    private void ProcessData()
    {
        //blocks the thread when there is no data, automatically wakes up when data is added.
        foreach(var data in dataQueue.GetConsumingEnumerable())
        {
            bot.Refresh(data);
        }
    }

    private void GenerateData()
    {
        //Assume Next() returns "false" when there will be no more data to process
        // and blocks when there is no data currently but more could come.
        while(botDataProducer.Next())
        {
            dataQueue.Add(botDataProducer.Data);
        }

        //This allows the foreach loop in the other thread to exit when the queue is empty.
        dataQueue.CompleteAdding();
    }
}