在python线程中关闭监听套接字 [英] Close listening socket in python thread

问题描述

我在尝试了解网络通信套接字时遇到问题.我创建了一个简单的线程来侦听连接并创建用于连接客户端的进程，但是我的问题是我无法找到合适的线程，因为我还没有找到取消socket.accept()-call的方法当我想退出程序时.

I have a problem trying to learn about sockets for network communication. I have made a simple thread that listens for connections and creates processes for connecting clients, my problem though is that I can't get the thread to join properly as I haven't found a way to cancel the socket.accept()-call when I want to quit the program.

我的代码如下:

class ServerThread( threading.Thread ):

    def __init__(self, queue, host, port):
        threading.Thread.__init__(self)
        self.queue = queue
        self.running = True
        self.hostname = host
        self.port = port

    def run(self):
        self.socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        self.socket.bind((self.hostname, self.port))
        self.socket.listen(1)
        while self.running:
            try:
                conn, address = self.socket.accept()
                process = Process(target=server_slave, args=(conn, address, self.queue))
                process.daemon = True
                process.start()
            except socket.timeout:
                pass

    def stop(self):
        self.running = False
        self.socket.close()

我已经设法通过设置self.setDaemon(True)并退出主程序来关闭程序，然后将所有内容交给出色的垃圾收集器-但这似乎是一个糟糕的解决方案.我也尝试过为套接字设置超时，但这会导致得到[Errno 35] Resource temporarily unavailable(无论实际超时如何，即使我将其设置为年...).

I have managed to get the program to close by setting self.setDaemon(True) and just exiting the main program, handing everything to the great garbage collector - but that seems like a bad solution. I've also tried setting a timeout for the socket but that results in getting [Errno 35] Resource temporarily unavailable (regardless of the actual timeout, even when I set it to years...).

我做错了什么?是我以一种愚蠢的方式设计了线程还是错过了一些接受连接的东西?

What am I doing wrong? Have I designed the thread in a dumb way or have I missed something about accepting connections?

推荐答案

一种使线程关闭的方法似乎是建立与套接字的连接，从而使线程继续完成.

One way to get the thread to close seems to be to make a connection to the socket, thus continuing the thread to completion.

def stop(self):
    self.running = False
    socket.socket(socket.AF_INET, 
                  socket.SOCK_STREAM).connect( (self.hostname, self.port))
    self.socket.close()

这可行，但仍然感觉可能不是最佳...

This works, but it still feels like it might not be optimal...

这篇关于在python线程中关闭监听套接字的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！