python - 如何停止Python中的套接字线程？

Question

在Python 3.3.3中，我创建了一个线程来监听与套接字的某些连接。它像这样:

import threading
import socket
import time

Host = ''
Port = 50000

flag = False

class ServerThread(threading.Thread):
    def __init__(self):
        threading.Thread.__init__(self)
        self._sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    def run(self):
        try:
            self._sock.bind((Host, Port))
            self._sock.listen(5)
            while True:
                conn, addr = self._sock.accept()
                print('Connected by', addr)
        except socket.error as msg:
            print(msg)
        except Exception as e:
            print(str(e))
        finally:
            self._sock.close()
    def exit(self):
        self._sock.close()

def TargetFunc(vlock):
    vlock.acquire()
    flag = True
    vlock.release()

def main():
    sthread = ServerThread()
    sthread.start()
    vlock = threading.Lock()
    time.sleep(10)
    vthread = threading.Thread(target = TargetFunc, args = (vlock, ))
    vthread.start()
    while True:
        vlock.acquire()
        if flag:
            sthread.exit()
            vlock.release()
            break
        vlock.release()
    sthread.join()
    vthread.join()

if __name__ == '__main__':
    main()

有两个线程，一个是监听socket，另一个是设置flag。当标志为 True 时，关闭套接字，然后引发套接字错误并捕获它，因此监听套接字终止。但为什么它不起作用。

谢谢!

Answer 1

self._sock.accept() 正在阻塞。所以它将等待直到有人连接。您应该使用非阻塞变体(或阻塞但有超时)。以便您可以检查退出条件。

或者，您可以在 ServerThread 中强制发生异常。