在计时器回调中创建的线程意外终止

Question

这就是我想要做的：

1. 有一个具有一定间隔的计时器
2. 在计时器回调代码中，如果满足某些条件，则应该运行另一个线程

我已将代码放入一个由主窗体和代码实例化的类中在方法调用时执行（“StartSync()”，参见示例代码）。

问题是代码运行了几秒钟，然后终止。我想我在做一些愚蠢的事情，但我真的不明白那是什么。感谢您对此提供的任何帮助。

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Diagnostics;

namespace WindowsFormsApplication1
{
    class Syncer
    {
        static bool SYNC_IN_PROGRESS;

        public void StartSync()
        {
            SYNC_IN_PROGRESS = false;
            Timer timer = new Timer(timerCallback, null, 0, 1000);
        }

        public void timerCallback(Object stateInfo)
        {
            Debug.WriteLine("Sync?");

            if (!SYNC_IN_PROGRESS)
            {
                SYNC_IN_PROGRESS = true;

                Thread thSync = new Thread(new ThreadStart(sync));
                thSync.Start();
            }
        }

        void sync()
        {
            Debug.WriteLine("Syncing...");
            SYNC_IN_PROGRESS = false;
        }
    }
}

Answer 1

猜测，Timer仅保存在方法变量中； 对我来说听起来就像Timer正在收集垃圾并最终确定，因此终止。我怀疑您应该在字段中保留该引用以防止收集。

顺便说一句 - 我怀疑这是这里的原因，但是在处理线程时，您应该认真地意识到从多个线程访问共享状态；例如：

• 使用Monitor（又名lock）
• 情况下适当使用易失性
• 在适合

您当前访问的 Interlocked static bool可能可以正常工作，但是......

Answer 2

尝试这种更干净的方法

    static volatile bool SYNC_IN_PROGRESS; 
    static thread syncPoll; 

    public void StartSync() 
    { 
        SYNC_IN_PROGRESS = false; 
        syncPoll = new Thread(sync);
        syncPoll.Start();
    } 

    void sync() 
    { 
        while (true)
        {
             Debug.WriteLine("Sync?");
             if (SYNC_IN_PROGRESS) Debug.WriteLine("Syncing..."); 
             Thread.Sleep(1000);
        }
    } 

它的作用与您尝试对当前代码执行的操作相同:)但不使用计时器

Answer 3

这就是我所做的，看起来效果很好

public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }


        private void button1_Click(object sender, EventArgs e)
        {
            StartSync();
        }

        static bool SYNC_IN_PROGRESS;

        public void StartSync()
        {
            SYNC_IN_PROGRESS = false;
            System.Threading.Timer timer = new System.Threading.Timer(timerCallback, SYNC_IN_PROGRESS, 0, 1000); 


        }

        public void timerCallback(Object stateInfo)
        {
            Debug.WriteLine("Sync?");

            if (!(bool)stateInfo)
            {
                SYNC_IN_PROGRESS = true;

                Thread thSync = new Thread(new ThreadStart(sync));
                thSync.Start();
            }
        }

        void sync()
        {
            Debug.WriteLine("Syncing...");
            SYNC_IN_PROGRESS = false;
        }
    }