启动和停止（强制）线程作业

Question

我想知道启动和停止强制和非强制线程作业的正确方法。这是停止线程的正确方法吗？

    public class ProcessDataJob : IJob
    {
        private ConcurrentQueue<byte[]> _dataQueue = new ConcurrentQueue<byte[]>();
        private volatile bool _stop = false;
        private volatile bool _forceStop = false;
        private Thread _thread;
        private int _timeOut = 1000;

        public void Start()
        {
            _stop = false;
            _forceStop = false;

            _thread = new Thread(ProcessData);
            _thread.Start();
        }

        private void ProcessData()
        {
            while (!_stop || _dataQueue.Count > 0)
            {
                if(_forceStop) return;

                byte[] data;
                if(_dataQueue.TryDequeue(data))
                {
                   //Process data
                   //.....//
                }
            }
        }

        public void Stop(bool force)
        {
            _stop = true;
            _forceStop = force;
            _thread.Join(_timeOut); 
        }

        public void Enqueue(byte[] data)
        {
            _dataQueue.Enqueue(data);
        }
    }

Answer 1

没有正确的方法可以强行杀死一个线程。

有几种方法可以做到这一点，但没有一种方法是正确的。

仅当您需要终止程序或卸载包含该线程的 appdomain 并且不关心任何处于损坏/错误/锁定状态的数据结构时，您才应该执行强制终止线程，因为他们也会在短时间内消失。

互联网上有很多关于 Thread.Abort 有多糟糕/邪恶的建议，所以不要这样做。

相反，编写适当的协作线程。线程应该自己检查一个标志（事件、volatile bool 字段等），然后在收到很好的请求时自愿退出。

这是正确的方式。

Answer 2

这是我过去的做法，但有一点不同。过去我有线程意外挂起，这意味着你的那个循环没有得到答案。为了解决这个问题，我让所有线程都使用类，比如你的类，注册一个“经理”类，该类负责参与强制停止等关键事项。线程类具有对管理器的引用，当强制停止完成时，它会调用管理器上的一个方法，该方法实际上是一个计时器。如果到计时器关闭时，线程类尚未将状态标志设置为 STOPPED，则管理器对其调用 abort。

对我来说，关键不只是呼叫“停止”，而是确认“停止”已经发生，并理解这将是一个不确定的时间量，但“在合理的时间量之后”我应该放弃并继续前进。

Answer 3

您可以使用 .NET ThreadPool 类，这样您就不必自己处理堆栈。