.NET 4 任务并行库可以使用 COM 对象吗？

Question

这是一个“这可能吗？如果可以的话，你能给我一个简单的例子吗，因为我在网上找不到一个例子？”类似的问题。

我有许多完全独立的（即“令人尴尬的并行”）进程，我想使用 C# 使用 .NET Framework 4 中的任务并行库并行运行这些进程。其中一些流程需要使用可通过 COM/OLE 自动化访问的软件。

具体来说，有一个 Parallel.Foreach() 循环从项目列表中划分任务，基本上调用 Parallel.Foreach 内的不同函数来处理处理（因此其中一些函数使用 COM 库来工作）。

这可能吗？谢谢。

Answer 1

将 COM 对象与 TPL 结合使用是 100% 可能的。虽然默认情况下 TPL 确实将使用标准 .NET ThreadPool，但 TPL 通过 TaskScheduler 类，它使您能够提供自己的调度程序，该调度程序可以将工作分派到您创建的线程。

在使用 COM 对象的情况下，您首先需要知道 COM 类是否需要 STA 线程或 MTA 线程。如果是 MTA 线程，则无需执行任何特殊操作，因为 COM 类已可以从任何随机线程中使用。不幸的是，大多数经典的 COM 对象往往依赖于 STA 线程，此时您需要使用自定义 TaskScheduler ，以便您使用它们的任何 .NET 线程都已 初始化为 STA 兼容线程。

虽然 TaskScheduler 的编写并不简单，但如果您对线程有基本的了解，那么编写它们也并不难。幸运的是，ParallelExtensions Extras 库 已经提供了一个 StaTaskScheduler 类，因此您不需要甚至不需要自己写任何东西。 PFX 这里有一篇很棒的博客文章团队讨论 StaTaskScheduler 类的实现和一些用例。

但基本上，您需要在某个类的某处将一个新的 StaTaskScheduler 初始化为静态，然后启动您的 Tasks 并指定它们由该实例调度。那看起来像这样：

// Create a static instance of the scheduler specifying some max number of threads
private static readonly StaTaskScheduler MyStaTaskScheduler = new StaTaskScheduler(4);

....

// Then specify the scheduler when starting tasks that need STA threading
Task.TaskFactory.StartNew(
() =>
{
    MyComObject myComObject = new MyComObject();

    myComObject.DoSomething();

    // ... etc ...
},
CancellationToken.None,
TaskCreationOptions.None,
MyStaTaskScheduler);

Answer 2

这有可能，但也可能行不通。

许多 COM 对象需要特定的独立线程。当您使用 Parallel.For/ForEach 时，您正在 .NET ThreadPool 上运行，该线程池没有单元线程设置。这可能有效，并且适用于某些 COM 对象，但也可能导致崩溃和难以追踪的奇怪 COM 异常。

Answer 3

我尚未验证一些其他信息，但这可能会有所帮助。默认任务调度程序将使用当前线程来完成一些工作，然后根据需要从线程池中添加其他线程。

如果您在执行 Parallel.ForEach 时共享 COM 对象，这可能会导致问题。例如，假设您的主线程是 STA。您可以在其上实例化 COM 对象，并使用 Parallel.ForEach 执行一些工作，其中每个线程都尝试访问先前实例化的 COM 对象。我怀疑它会损坏，并且初步测试似乎支持了这一点。在这种情况下，我至少看到几个选项：

• 假设 COM 对象支持 MTA，让调用线程使用 MTA。然而，由于其他原因，这可能不是一个选择。例如，如果应用程序是 Windows 窗体应用程序，我相信 Main() 需要具有 STAThread 属性。
• 使用替代任务计划程序，例如 Drew 提到的 StaTaskScheduler。您可以拥有所有 STA 线程，也可以使用不使用调用线程并运行所有 MTA 线程的调度程序。