等待 Windows 服务中的线程停止

Question

我正在开发我的第一个 Windows 服务项目，其中涉及一些基本的线程/并行性。到目前为止，这已经相当激烈，但我正在慢慢开始理解线程（我想我们会看到这一点......）。

我有一个 Windows 服务，其中包含 2 个松散耦合的工作线程。线程 A 将从 FTP 服务器下载文件，解压缩/准备它们并保存到线程 B 将有 FileSystemWatcher 监视的另一个目录。线程 B 将解析文件，对数据执行许多操作，进行一些 http 调用，最后归档文件并将其从工作目录中删除。

我刚刚开始工作，现在面临的问题是如何等待线程A和线程B都返回。我查看了这个问题： Thread.Join 在多个线程上超时 并有了一个想法。

问题是，如果我们等待 x 个线程返回，每个线程都有 1 秒的超时，如果有足够的线程，即使在正常操作下，服务也可能会出现无响应（我在 SCM 抱怨之前读到的超时是 30 秒，对吧？）。此外，如果我们通过在循环线程时跟踪剩余加入时间来解决这个问题，那么在工作线程集合开始时等待线程的时间越长，剩余线程返回的时间就越少 - 所以最终如果有足够的线程，即使所有线程都在预期的时间内返回，服务也会显得无响应。

在这种情况下，我可能会在 14 秒的超时时间内对 A 和 B 进行 thread.join，因为我只有两个工作线程，而 14 秒似乎足以返回两者。

如果我有可变数量的工作线程（假设> 8），是否值得做这样的事情？这能可靠地工作吗？

注意：不要使用以下内容 - 从多个层面来说这都是一个坏主意。查看答案

    protected override void OnStop()
    {
        // the service is stopping - set the event
        Worker.ThreadStopEvent.Set();

        // stop the threads
        Parallel.ForEach(_workerThreads, t =>
        {
            t.Join(new TimeSpan(0, 0, 28));
        });
    }

Answer 1

我建议您不要为每个线程使用超时，而是设置事件，然后定期使用较短的超时执行Join。一个极端的版本是：

Worker.ThreadStopEvent.Set();
Thread.Sleep(30000); // wait 30 seconds
// Now try to Join each thread, with a very short (20 ms, maybe) timeout.

该方法的最大问题是您将始终等待 30 秒，即使所有线程在 5 秒内停止也是如此。

您可以使用休眠一秒钟然后进行检查的循环来做得更好。然后，您可以跟踪哪些线程已停止，并在所有线程停止时退出循环。

不过，您可能最好使用 CountdownEvent。每个线程在停止时都会发出信号，主线程会等待，直到所有线程都停止。 Wait 方法允许您指定超时值。等待之后，您可以通过调用 Join 并设置一个非常短的超时来确定是否有任何线程仍然挂起。

Answer 2

从技术上讲，您不必等到线程完成（加入），而是等到它们报告完成为止。因此，您可以使用在之间共享的 CountdownEvent 实例所有线程并等待它。所有线程都必须在finally块中减少事件：

void WorkerThread (object args)
{
  try
  {
    // actual work here
    ... 
  }
  finally
  {
    sharedCountdown.Signal();
  }
}

并且在关闭并等待线程完成时：

// Notify all workers of shutdown
...

// Now wait for all workers to complete, up to 30 seconds
sharedCountdown.Wait(TimeSpan.FromSeconds(30));

Answer 3

您当前的方法可能效果不佳 - 您无法控制 Parallel.ForEach 实际创建的线程数量，并非所有线程连接都可以并行运行 - 这完全取决于这些任务的调度方式在线程池上。最重要的是，它的效率非常低，因为您生成的所有线程基本上都在等待。

如果这些工作线程没有必须在服务关闭时完成的关键任务，我将使它们全部成为后台线程 - 在这种情况下，您根本不必处理这个问题。