Python:套接字和线程？

Question

我有一个设计问题:

我有两个线程，一个心跳/控制线程和一个消息处理程序线程。

两者共享同一个套接字，但是 messageHandler 线程只发送消息而从不接收消息。心跳线程发送和接收(接收消息并对心跳使用react)。

问题是我不确定这是否安全。我自己没有实现机制来查看套接字是否正在使用。 那么通过 python 共享套接字是否自动线程安全？

此外，如果不是，我将它们放在单独的线程中的原因是心跳比消息处理更重要。这意味着如果它被消息淹没，它仍然需要进行心跳。因此，如果我必须实现 bolt ，如果我的心跳/控制线程需要发送心跳，我是否可以确定优先级？

Answer 1

代替使用第三个线程的更好方法是使用 threading.Lock() 来保护套接字资源，因为这消除了对第三个线程的需要。与拥有第三个线程相比，您的开销和延迟更少。

import threading

lock = threading.Lock()

def sendfunction(sock, data):
    with lock:
        sock.send(data)

您可以从任一线程调用它，但一次只允许一个线程调用 sock.send。当一个线程到达已被另一个线程锁定的锁时，它会休眠直到另一个线程释放锁，然后它会获取锁并重复该过程。

threading 模块包含Lock、RLock 和Condition，它们在处理多线程时都非常有用，您将发现花时间熟悉它们及其用法非常值得。

在处理每条消息之前，您可以通过检查当前时间与上次发送心跳的时间来将心跳合并到消息处理中，这样可以防止被消息淹没导致无法发送心跳。问题是如果您的消息处理代码没有运行，则不会发送心跳。您可以通过让您的消息处理代码按时间间隔获取虚拟消息以允许它检查是否需要发送心跳并忽略该虚拟消息来缓解这种情况。

您应该尽量少使用线程(以单线程为目标)，但在您的情况下，线程可能没问题，因为它大部分时间都在休眠。但是，您不应使用守护线程，因为它们无法正确关闭。尽管如果没有正确关闭，在您的情况下可能不存在损坏，但它仍然可能引发某种看起来很糟糕的故障(错误消息)。

我不同意多套接字方法，因为我认为它实际上会使情况复杂化。您会发现许多类型的网络服务/应用程序将心跳和消息合并到单个套接字字节流中。