Pythoncom - 将相同的 COM 对象传递给多个线程

Question

你好：）对于 COM 对象，我是一个完全的初学者，非常感谢任何帮助！

我正在开发一个Python程序，该程序应该以客户端/服务器的方式读取传入的MS-Word文档，即客户端发送一个请求（一个或多个MS-Word文档），服务器使用pythoncom和从这些请求中读取特定内容win32com。

因为我想最大限度地减少客户端的等待时间（客户端需要来自服务器的状态消息，所以我不想为每个请求打开一个 MS-Word 实例。因此，我打算有一个正在运行的 MS-Word 实例池，从中服务器可以选择。反过来，这意味着我必须在不同的线程中重用池中的这些实例，这就是我读完之后造成麻烦的原因。 href="https://stackoverflow.com/questions/26764978/using-win32com-with-multithreading">将 win32com 与多线程结合使用，我的服务器虚拟代码如下所示：

import pythoncom, win32com.client, threading, psutil, os, queue, time, datetime

appPool = {'WINWORD.EXE': queue.Queue()}

def initAppPool():
    global appPool
    wordApp = win32com.client.DispatchEx('Word.Application')
    appPool["WINWORD.EXE"].put(wordApp) # For testing purpose I only use one MS-Word instance currently

def run_in_thread(appid, path):
    #open doc, read do some stuff, close it and reattach MS-Word instance to pool
    pythoncom.CoInitialize()
    wordApp = win32com.client.Dispatch(pythoncom.CoGetInterfaceAndReleaseStream(appid, pythoncom.IID_IDispatch))
    doc = wordApp.Documents.Open(path)
    time.sleep(3) # read out some content ...
    doc.Close()
    appPool["WINWORD.EXE"].put(wordApp)

if __name__ == '__main__':
    initAppPool()

    pathOfFile2BeRead1 = r'C:\Temp\file4.docx'
    pathOfFile2BeRead2 = r'C:\Temp\file5.doc'

    #treat first request
    wordApp = appPool["WINWORD.EXE"].get(True, 10) 
    pythoncom.CoInitialize()
    wordApp_id = pythoncom.CoMarshalInterThreadInterfaceInStream(pythoncom.IID_IDispatch, wordApp) 
    readDocjob1 = threading.Thread(target=run_in_thread,args=(wordApp_id,pathOfFile2BeRead1), daemon=True)
    readDocjob1.start() 

    #wait here until readDocjob1 is done 
    wait = True
    while wait:
        try:
            wordApp = appPool["WINWORD.EXE"].get(True, 1)
            wait = False
        except queue.Empty:
            print(f"[{datetime.datetime.now()}] error: appPool empty")
        except BaseException as err:
            print(f"[{datetime.datetime.now()}] error: {err}")
    

到目前为止，一切都按预期工作，但是当我启动与第一个请求类似的第二个请求时：

(x) wordApp_id = pythoncom.CoMarshalInterThreadInterfaceInStream(pythoncom.IID_IDispatch, wordApp)
    readDocjob2 = threading.Thread(target=run_in_thread,args=(wordApp_id,pathOfFile2BeRead2), daemon=True)
    readDocjob2.start()

“应用程序调用了为不同线程编组的接口”。

我收到以下错误消息：对于 (x) 标记行， 我必须使用 pythoncom.CoGetInterfaceAndReleaseStream 在具有相同 COM 对象的线程之间跳转？除此之外，为什么它第一次可以工作，但第二次却不能呢？

我在 StackOverflow 上搜索了使用 CoMarshalInterface 而不是 CoMarshalInterThreadInterfaceInStream 的不同解决方案，但它们都给了我相同的错误。我现在真的很困惑。

编辑： 修复评论中提到的错误后，我遇到了一种神秘的行为。 当执行第二个作业时：

    wordApp_id = pythoncom.CoMarshalInterThreadInterfaceInStream(pythoncom.IID_IDispatch, wordApp)
    readDocjob2 = threading.Thread(target=run_in_thread,args=(wordApp_id,pathOfFile2BeRead2), daemon=True)
    readDocjob2.start()

函数 run_in_thread 立即终止而不执行任何行，分别看来 pythoncom.CoInitialize() 未正常工作。 但脚本完成后没有任何错误消息。

def run_in_thread(instance,appid, path):
    #open doc, read do some stuff, close it and reattach MS-Word instance to pool
    pythoncom.CoInitialize()
    wordApp = win32com.client.Dispatch(pythoncom.CoGetInterfaceAndReleaseStream(appid, pythoncom.IID_IDispatch))
    doc = wordApp.Documents.Open(path)
    time.sleep(3) # read out some content ...
    doc.Close()
    instance.flag = True

Answer 1

发生的情况是，您将从 CoGetInterfaceAndReleaseStream。但是这个引用是专门为这个新线程创建的，然后您调用 CoMarshalInterThreadInterfaceInStream 关于此新参考。

这就是问题所在。

您必须始终使用从创建它的线程中获取的原始 COM 引用，以便能够重复调用CoMarshalInterThreadInterfaceInStream。

因此，要解决这个问题，您必须更改应用程序池的工作方式，使用某种“正在使用”标志，但不要触及原始的 COM 引用。