如何在 C# 中正确终止工作线程

Question

问题陈述

我有一个工作线程，它基本上扫描一个文件夹，进入其中的文件，然后休眠一段时间。扫描操作可能需要 2-3 秒，但不会更多。我正在寻找一种优雅地停止这个线程的方法。

澄清：我想在线程睡眠而不是扫描时停止线程。但是，问题是我不知道线程的当前状态是什么。如果它正在睡觉，我希望它立即退出。如果它正在扫描，我希望它在它试图阻止的那一刻退出。

尝试解决方案

起初我使用的是睡眠和中断。然后我发现中断并没有真正中断睡眠——它只在线程试图进入睡眠时起作用。

所以我切换到 Monitor Wait&Pulse。然后我发现 Pulse 仅在我实际处于等待状态时才有效。所以现在我有一个看起来像这样的线程：

while (m_shouldRun)
{
    try
    {
        DoSomethingThatTakesSeveralSeconds();
        lock (this)
        {
            Monitor.Wait(this, 5000);
        }
    }
    catch (ThreadInterruptedException)
    {
        m_shouldRun = false;
    }
}

现在我需要制作我的停止功能。所以我开始了：

public void Stop()
{
    m_shouldRun = false;
    lock (this)
    {
        Monitor.Pulse(this);
    }
    thread.Join();
}

但这不起作用，因为我可能在线程工作时（当它不等待时）脉动。所以我添加了中断：

public void Stop()
{
    m_shouldRun = false;
    thread.Interrupt();
    lock (this)
    {
        Monitor.Pulse(this);
    }
    thread.Join();
}

另一种选择是使用：

public void Stop()
{
    m_shouldRun = false;
    while (!thread.Join(1000))
    {
        lock (this)
        {
            Monitor.Pulse(this);
        }
    }
}

问题

首选方法是什么？有没有第三种更好的方法？

Answer 1

优雅地停止线程的方法是让它自行完成。所以在 worker 方法中你可以有一个布尔变量来检查我们是否要中断。默认情况下，它将设置为false，当您从主线程将其设置为true 时，它会通过中断处理循环来停止扫描操作。

Answer 2

另一种选择是使用事件：

private ManualResetEvent _event = new ManualResetEvent(false);


public void Run() 
{
 while (true)
 {
    DoSomethingThatTakesSeveralSeconds();
    if (_event.WaitOne(timeout))
      break;
 }
}

public void Stop() 
{
   _event.Set();
   thread.Join();
}

Answer 3

我建议保持简单：

while (m_shouldRun)
{
    DoSomethingThatTakesSeveralSeconds();
    for (int i = 0; i < 5; i++)  // example: 5 seconds sleep
    {
        if (!m_shouldRun)
            break;
        Thread.Sleep(1000);
    }
}

public void Stop()
{
    m_shouldRun = false;
    // maybe thread.Join();
}

这样有以下优点：

• 闻起来像是忙着等待，但事实并非如此。 $NUMBER_OF_SECONDS 检查是在等待阶段完成的，这与真正繁忙的等待中完成的数千次检查相比是无法比拟的。
• 很简单，大大降低了多线程代码出错的风险。您的所有Stop 方法需要做的就是将m_shouldRun 设置为false 并（可能）调用Thread.Join（如果线程需要在Stop 离开之前完成）。不需要同步原语（除了将 m_shouldRun 标记为 volatile）。

Answer 4

我想出了单独安排任务：

using System;
using System.Threading;

namespace ProjectEuler
{
    class Program
    {
        //const double cycleIntervalMilliseconds = 10 * 60 * 1000;
        const double cycleIntervalMilliseconds = 5 * 1000;
        static readonly System.Timers.Timer scanTimer =
            new System.Timers.Timer(cycleIntervalMilliseconds);
        static bool scanningEnabled = true;
        static readonly ManualResetEvent scanFinished =
            new ManualResetEvent(true);

        static void Main(string[] args)
        {
            scanTimer.Elapsed +=
                new System.Timers.ElapsedEventHandler(scanTimer_Elapsed);
            scanTimer.Enabled = true;

            Console.ReadLine();
            scanningEnabled = false;
            scanFinished.WaitOne();
        }

        static void  scanTimer_Elapsed(object sender,
            System.Timers.ElapsedEventArgs e)
        {
            scanFinished.Reset();
            scanTimer.Enabled = false;

            if (scanningEnabled)
            {
                try
                {
                    Console.WriteLine("Processing");
                    Thread.Sleep(5000);
                    Console.WriteLine("Finished");
                }
                finally
                {
                    scanTimer.Enabled = scanningEnabled;
                    scanFinished.Set();
                }
            }
        }
    }
}