Python .NET、多线程和 Windows 事件循环

问题描述 投票:0回答:2

我正在使用 Python .NET 围绕黑盒 .NET DLL 构建 Python API。 DLL 仅执行网络操作。该 DLL 要求我运行 Windows 消息泵循环,否则网络操作会在一段时间后卡住。我在主线程中使用

System.Windows.Forms.Application.Run()
运行 Windows 消息循环。这对于仅接收数据来说效果很好。当我开始从其他 Python 线程调用 DLL 时,我的程序开始表现得很奇怪。我认为这与线程有关,因为问题的发生非常不规律——网络事件消失或出现得很晚。据我所知,Python 和 C# 是线程安全的,但可能是因为多层包装而出现了问题。 所以我有几个问题:

    从多个 Python 主题调用 DLL 是一个坏主意吗?或者这取决于 DLL 内部结构?我认为从 DLL 的角度来看,由于 GIL,Python 线程被视为一个单独的代理。
  • 每个使用该 DLL 的 Python 线程都需要消息泵吗?
  • 将所有 DLL 交互保留在一个线程中可能是一个好主意。我很难完成此任务,因为我将控制权交给了主线程中的消息泵循环。我天真的方法是将我的工作线程中生成的新传出网络消息放在 Python 队列中,在主线程中创建一个自定义消息泵循环,该循环执行 Windows 事件处理,但也监视我的队列,如果有消息,则会执行调用 DLL。但这一切都让人感觉相当笨重,而且对于这样一个简单的任务来说需要做很多工作。这是正确的做法吗?
  • 是否有其他方法可以将函数放入主窗口事件循环中来监视前面描述的队列并采取操作?或者我应该深入研究 .NET 细节并开始使用 .NET 事件或调度程序?
c# python multithreading dll python.net
2个回答
10
投票

    我认为我们不能假设 DLL 是线程安全的,因此最好将与 DLL 的所有交互隔离到一个线程。
  • 看起来Windows消息系统是每个线程而不是每个进程,所以是的,每个使用Windows消息系统的线程都需要有一个Windows消息处理循环。
  • 可以使用
  • Form.Invoke

    在 Windows 事件循环中插入执行。运行非 ui 主循环,您可以使用

    Dispatcher.CurrentDispatcher
    获取调度程序,它可用于“调用”函数。然后,调用的函数在创建调度程序的线程上执行。不过,被调用的函数需要进行委托,这是 C# 特定的事情,用于传递对函数的引用。
    
    

  • 最后我为非 ui 主循环做了类似的事情:

import clr import threading # we need to get access to the threading assembly clr.AddReference("c:\\Program Files\\Reference Assemblies\\Microsoft\\Framework\\v3.0\\WindowsBase.dll") import System from System.Windows.Threading import Dispatcher from System.Windows.Forms import Application # now get the dispatcher for the current thread dispatcher = Dispatcher.CurrentDispatcher def display(): print(threading.current_thread()) # now make this a deligate deligate = System.Action(display) def other_thread(dispatcher): # now you can use the dispatcher from the main thread to # to schedule a run from an other thread dispatcher.Invoke(deligate) thread = threading.Thread(target=other_thread, args=(dispatcher,)) thread.start() Application.Run()

一些相关链接:

    有关调度程序的更多信息
  • 有关操作委托的更多信息

0
投票
import clr

等)。

当多个线程与相同的函数(管理硬件设备)并行通信时,我遇到了错误。

解决方案:

    创建全局锁:
  1. lock = threading.Lock()

  2. 替换每个 API 调用,例如
  3. device.move(x=1234)

    作者:

    with lock:
        device.move(x=1234)
    

    
        
© www.soinside.com 2019 - 2024. All rights reserved.