我在.NET编程和多线程方面相对新手，想知道是否可以在控制台应用程序中使用.NET提供的BackgroundWorker来生成工作线程来做一些工作？从网上的各种文档中看到，这个类的意图更多地是为面向UI的应用程序设计的，其中你想在后台执行一些工作，但保持UI响应，并报告进度、必要时取消处理等。
在我的情况下，我有一个控制器类，想要生成多个工作线程来进行一些处理（使用信号量限制最大数量的工作线程）。然后我希望我的控制器类在所有线程完成处理之前阻塞。所以在启动工作线程来处理工作后，我希望线程可以在处理完成时通知控制器线程。我看到可以使用BackgroundWorker类，并处理DoWork和RunWorkerCompleted事件来完成这一点，但是想知道是否这是一个好主意？是否有更好的方法实现这一点？
如果您的需求只是等待所有线程完成，那么这很容易 - 只需启动新线程，然后在每个线程上调用Thread.Join：
using System;
using System.Collections.Generic;
using System.Threading;
public class Test
{
static void Main()
{
var threads = new List<Thread>();
for (int i = 0; i < 10; i++)
{
int copy = i;
Thread thread = new Thread(() => DoWork(copy));
thread.Start();
threads.Add(thread);
}
Console.WriteLine("Main thread blocking");
foreach (Thread thread in threads)
{
thread.Join();
}
Console.WriteLine("Main thread finished");
}
static void DoWork(int thread)
{
Console.WriteLine("Thread {0} doing work", thread);
Random rng = new Random(thread); // Seed with unique numbers
Thread.Sleep(rng.Next(2000));
Console.WriteLine("Thread {0} done", thread);
}
}
编辑：如果您可以访问.NET 4.0，则TPL绝对是正确的选择。否则，我建议使用生产者/消费者队列（有大量示例代码可用）。基本上，您拥有一个工作项队列和与核心数相同的消费者线程（假设它们是CPU密集型；您需要根据工作负载进行调整）。每个消费者线程将从队列中获取一个项目并逐个处理。如何管理这一点将取决于您的情况，但它并不是非常复杂。如果您能提前想出所有需要完成的工作，那么当线程发现队列为空时，它们就可以退出，这样会更容易些。
在控制台应用程序中，这不起作用，因为 SynchronizationContext.Current永远不会初始化。只有在使用GUI应用程序时，Windows Forms或WPF才会为您初始化它。
话虽如此，没有理由这样做。只需使用 ThreadPool.QueueUserWorkItem和重置事件（ ManualResetEvent或 AutoResetEvent）来捕获完成状态并阻止主线程即可。
编辑：
看到一些原帖评论后，我想补充一下。
在我看来，“最好”的选择是获取Rx Framework的副本，因为它包含了.NET 4中TPL的回溯。这将允许您使用Parallel.ForEach的重载，该重载提供了提供ParallelOptions实例的选项。这将允许您限制总并发操作数，并为您处理所有工作：
// using collection of work items, such as: List<Action<object>> workItems;
var options = new ParallelOptions();
options.MaxDegreeOfParallelism = 10; // Restrict to 10 threads, not recommended!
// Perform all actions in the list, in parallel
Parallel.ForEach(workItems, options, item => { item(null); });
然而，使用Parallel.ForEach时，我个人会让系统管理并行度。它将自动分配适当数量的线程（特别是当/如果它转移到.NET 4时）。
using System.ComponentModel; // for BackgroundWorker
using Console = System.Console;
class Program
{
static void Main(string[] args) {
BackgroundWorker worker = new();
worker.DoWork += worker_DoWork;
worker.RunWorkerCompleted += worker_RunWorkerCompleted;
worker.ProgressChanged += worker_ProgressChanged;
worker.WorkerReportsProgress = true;
worker.WorkerSupportsCancellation = true;
Console.WriteLine("Starting worker... (any key to cancel/exit)");
worker.RunWorkerAsync();
Console.ReadKey(true); // event loop
if (worker.IsBusy) {
Console.WriteLine("Interrupting the worker...");
worker.CancelAsync();
var sw = System.Diagnostics.Stopwatch.StartNew();
while (worker.IsBusy && sw.ElapsedMilliseconds < 5000)
System.Threading.Thread.Sleep(1);
}
}
static void worker_ProgressChanged(object _, ProgressChangedEventArgs e) {
Console.WriteLine("Worker progress: {0:d}%", e.ProgressPercentage);
}
static void worker_DoWork(object sender, DoWorkEventArgs e) {
Console.WriteLine("Worker: Starting to do some work now...");
BackgroundWorker worker = sender as BackgroundWorker;
e.Result = 0;
for (int i = 1; i < 11; ++i) {
for (int ii=0; !worker.CancellationPending && ii < 10; ++ii)
System.Threading.Thread.Sleep(100);
if (worker.CancellationPending)
break;
worker.ReportProgress((int)((100.0 * i) / 10));
e.Result = i;
}
e.Cancel = worker.CancellationPending;
}
static void worker_RunWorkerCompleted(object _, RunWorkerCompletedEventArgs e) {
if (e.Cancelled) {
Console.WriteLine("Worker: I wuz busy!");
return;
}
Console.WriteLine("Worker: I worked {0:D} times.", e.Result);
Console.WriteLine("Worker: Done now!");
}
}
最初可在https://www.codeproject.com/Questions/625473/backgroundWorker-in-csharp 找到（发布于2013年7月，因此我认为这已经运作了一段时间？）。