C#中用Task.Run()并行处理Word文档未达预期的问题咨询

当前Task.Run实现的问题 #

你的代码没有实现真正的并行，核心原因有两个：

1. 全局锁lock (wordLock)：所有任务都必须等待锁释放才能执行内部逻辑，直接把并行任务变成了串行执行，这是任务未并行的根本原因。
2. 闭包捕获循环变量的陷阱：foreach中的item变量会被所有Task的lambda捕获，最终所有任务可能都会使用循环最后一个item的值，导致处理文档的参数错误。

Office Interop COM对象的并行处理方案 #

Office Interop的COM对象基于**单线程单元(STA)**模型，必须在STA线程中运行（Task.Run默认使用多线程单元MTA线程，直接创建Word实例会导致不稳定或异常）。结合你的场景，最优方案如下：

1. 修复核心问题并实现正确并行 #

List<WordTaskInfo> wordTaskInfos = new List<WordTaskInfo>();
List<Task> tasks = new List<Task>();

foreach (var item in someCollection)
{
    // 解决闭包捕获问题：将循环变量赋值给局部变量
    var currentItem = item;
    wordTaskInfos.Add(new WordTaskInfo
    {
        DocFilePath = currentItem.DocfilePath,
        BookmarkName = currentItem.BookmarkName,
        // 其他属性初始化
    });

    // 使用Task.Factory.StartNew指定STA线程（需配合LongRunning确保线程被正确初始化）
    tasks.Add(Task.Factory.StartNew(() =>
    {
        Log.LogBookmark($"Creating Instance Start :{currentItem.BookmarkName}", DateTime.Now.ToString("HH:mm:ss"));
        Microsoft.Office.Interop.Word.Application wordApp = null;
        Microsoft.Office.Interop.Word.Document doc = null;
        
        try
        {
            // 在STA线程中创建Word实例
            wordApp = new Microsoft.Office.Interop.Word.Application();
            doc = wordApp.Documents.Open(
                FileName: currentItem.DocfilePath,
                ReadOnly: false // 根据实际需求调整参数
            );
            
            // 执行书签转换
            ConvertBookMark(
                currentItem.IntroText, 
                currentItem.ConvertionNode1, 
                wordApp, 
                doc, 
                currentItem.DocFilePath, 
                currentItem.SolnPath, 
                currentItem.ClientName, 
                currentItem.SsoConfigModel
            );
            
            // 保存并关闭文档
            doc.SaveAs2(currentItem.DocFilePath, Microsoft.Office.Interop.Word.WdSaveFormat.wdFormatDocumentDefault, false);
        }
        catch (Exception ex)
        {
            Log.LogError($"处理文档 {currentItem.BookmarkName} 失败: {ex.Message}");
        }
        finally
        {
            // 强制清理COM资源，避免残留Word进程
            if (doc != null)
            {
                doc.Close();
                System.Runtime.InteropServices.Marshal.ReleaseComObject(doc);
            }
            if (wordApp != null)
            {
                wordApp.Quit();
                System.Runtime.InteropServices.Marshal.ReleaseComObject(wordApp);
            }
            Log.LogBookmark($"Creating Instance End :{currentItem.BookmarkName}", DateTime.Now.ToString("HH:mm:ss"));
        }
    }, TaskCreationOptions.LongRunning, TaskScheduler.Default));
}

Task.WaitAll(tasks.ToArray());

2. 关键注意事项 #

• STA线程要求：必须在STA线程中创建和操作Word COM对象，上面的代码通过Task.Factory.StartNew结合LongRunning选项，让.NET分配一个独立的STA线程（也可以手动创建Thread并设置ApartmentState.STA）。
• 资源清理：必须显式调用Marshal.ReleaseComObject释放COM对象，否则Word进程会残留后台，消耗系统资源。
• 控制并行度：每个Word实例会占用大量内存和CPU，建议限制并行任务数量（比如用Parallel.ForEach的MaxDegreeOfParallelism设置为Environment.ProcessorCount或更低），避免系统资源耗尽。

3. 替代方案：使用Parallel.ForEach控制并行度 #

如果需要更方便地控制并行数量，可以用Parallel.ForEach：

Parallel.ForEach(someCollection, new ParallelOptions { MaxDegreeOfParallelism = 4 }, item =>
{
    // 嵌套STA线程处理Word操作
    var staThread = new Thread(() =>
    {
        Microsoft.Office.Interop.Word.Application wordApp = null;
        Microsoft.Office.Interop.Word.Document doc = null;
        try
        {
            wordApp = new Microsoft.Office.Interop.Word.Application();
            doc = wordApp.Documents.Open(item.DocfilePath);
            ConvertBookMark(/* 对应参数 */);
            doc.SaveAs2(/* 对应参数 */);
        }
        finally
        {
            // 清理资源
            if (doc != null) { doc.Close(); System.Runtime.InteropServices.Marshal.ReleaseComObject(doc); }
            if (wordApp != null) { wordApp.Quit(); System.Runtime.InteropServices.Marshal.ReleaseComObject(wordApp); }
        }
    });
    staThread.SetApartmentState(ApartmentState.STA);
    staThread.Start();
    staThread.Join();
});

内容的提问来源于stack exchange，提问作者User777