4

我想启动一个线程来监听事件并在后台处理它们。这是我到目前为止所做的：

private Thread mThread;
private bool mKeepHandlingIt;

private void Init()
{
    mKeepHandlingIt = true;
    mThread = new Thread(ProcessEvents);
    mThread.SetApartmentState(ApartmentState.STA);
    mThread.Start();
}

private void ProcessEvents()
{
    StaticClass.CoolEvent += HandleIt;
    StaticClass.StartDoingStuff();

    while (mKeepHandlingIt)
    {
        Application.DoEvents();
    }

    StaticClass.StopDoingStuff();
    StaticClass.CoolEvent -= HandleIt;
}

private void HandleIt(object sender, EventArgs e)
{
    //Handles it
}

protected override void Dispose()
{
    if (mThread != null)
    {
        mKeepHandlingIt = false;
        mThread.Join();
    }
}

有更好的方法吗？像更适合此目的的线程类？在这种情况下，BackgroundWorker 似乎不是一个更好的选择......

但是，如果这是一个好方法，那么我有一个我不太理解的问题。上述解决方案适用于监听事件并处理它们，但是当调用 Dispose 并将 mKeepHandlingIt 设置为 false 时，退出 while 循环（如果我在循环中放置断点，调试器不会中断）但之后没有代码循环被执行并且 mThread.Join 永远不会返回。基本上......我想知道的是：我如何停止线程，然后确保在清理之前不要继续？

4

2 回答 2

6

这段代码有很多问题。首先，它受到事件处理程序在该工作线程上运行的错觉的影响。这不是事件的工作方式，处理程序在与触发事件的代码完全相同的线程上运行。.NET 中没有让它跳到另一个线程的机制。

您可以通过调试器的 Debug + Windows + Threads 窗口看到一些东西。在 Init() 方法上设置断点，在事件处理程序上设置断点。当它们中断时，切换到该调试器屏幕并记下选定的线程。

使用 Application.DoEvents() 非常危险。但不是在这里，线程没有创建任何窗口，所以没有事件可做。相反，线程只会烧掉 100% 的核心，而根本不会完成任何事情。

mKeepHandlingIt 变量通常不会像您希望的那样做。当您在 32 位机器上运行代码的发布版本时，线程将永远不会看到它被设置为 false，因此线程将永远不会退出。并且 Thread.Join() 会死锁。这是由抖动优化器引起的，它将 bool 变量存储在 cpu 寄存器中，并且永远不会从内存中重新加载它。您必须声明变量volatile以防止进行此优化。这是一个技巧，您应该始终使用适当的同步对象来向线程发出信号，此处适合使用 AutoResetEvent。

只需删除此代码，它对您没有帮助。

于 2013-10-02T11:43:05.233 回答
2

在大多数情况下，您不应该使用 doevents。s。

例如参见：

如果没有更多线程可用，使用新线程创建线程可能会遇到麻烦。因此，您可以使用Threadpool。

但我强烈建议看看Tasks和TPL

然后你可以开始

Task.Factory.StartNew()

当使用异步库并且您具有continuewith之类的功能时，还有等待

另请参阅MSDN 等待一项或多项任务

            // Wait for all tasks to complete.
            Task[] tasks = new Task[10];
            for (int i = 0; i < 10; i++)
            {
                tasks[i] = Task.Factory.StartNew(() => DoSomeWork(10000000));
            }
            Task.WaitAll(tasks);

Async 和 await 也不一定使用线程，但为此异步工作，请参阅：async-await-vs-threads

这对安全资源来说是一个很大的好处。尤其是当你有 io 操作时。

还有一种更复杂的方法是使用某种服务总线在单独的过程中实现监听（无论你想要实现什么）

于 2013-10-02T11:26:13.870 回答