c# - 任务调度程序中的手动线程与 Parallel.Foreach

Question

我有一个 Windows 服务可以处理用户创建的任务。此服务在具有 4 个内核的服务器上运行。这些任务主要涉及繁重的数据库工作(例如生成报告)。服务器还运行了一些其他服务，所以我不想启动太多线程(假设最多 4 个)。

如果我使用 BlockingCollection<MyCustomTask> ，创建 4 个 Thread 对象并使用它们从 BlockingCollection<MyCustomTask> 中消费是不是一个更好的主意？或者我应该使用 Parallel.Foreach完成这个？

我正在查看 ParallelExtensionsExtras其中包含一个使用前者的 StaTaskScheduler，就像这样(为清楚起见稍微修改了代码):

var threads = Enumerable.Range(0, numberOfThreads).Select(i =>
                       {
                           var thread = new Thread(() =>
                           {
                               // Continually get the next task and try to execute it.
                               // This will continue until the scheduler is disposed and no more tasks remain.
                               foreach (var t in _tasks.GetConsumingEnumerable())
                               {
                                   TryExecuteTask(t);
                               }
                           });
                           thread.IsBackground = true;
                           thread.SetApartmentState(ApartmentState.STA);
                           return thread;
                       }).ToList();

            // Start all of the threads
            threads.ForEach(t => t.Start());

但是，还有一个 BlockingCollectionPartitioner在同一ParallelExtensionsExtras这将启用 Parallel.Foreach 的使用在 BlockingCollection<Task> 上，像这样:

 var blockingCollection = new BlockingCollection<MyCustomTask>();
        Parallel.ForEach(blockingCollection.GetConsumingEnumerable(), task =>
        {
            task.DoSomething();
        });

据我了解，后者利用了 ThreadPool .在这种情况下使用 Parallel.ForEach 会有什么好处吗？

Answer 1

如果代码中的 Task 类与 System.Threading.Tasks.Task 无关，则此答案是相关的。

作为一个简单的规则，使用 Parallel.ForEach 来运行最终会结束的任务。喜欢与其他工作并行执行一些工作

在应用程序的整个生命周期中运行例程时使用线程。

因此，在您的情况下，您应该使用线程方法。