如何在Python中杀死服务器线程

Question

我有一个应用程序，可以在各自的线程上运行多个服务器。我希望能够告诉线程停止运行。为此，尽管我需要告诉线程停止，然后线程需要告诉服务器停止，然后服务器将关闭自己的套接字（该套接字在接收循环中，从所有连接的客户端获取数据） 。我该怎么做？

我尝试使用传递的停止变量，但是我认为问题出在套接字上，需要关闭它。我找不到一种方法来告诉服务器关闭套接字，而不向服务器发送直接消息告诉它这样做，这似乎效率很低。

这是我的服务器代码：

import socket
import threading

class Server:
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    connections = []

    def __init__(self, port):
        self.sock.bind(('0.0.0.0', port))
        self.sock.listen(1)

    def handler(self, c, a):
        while True:
            try:
                data = c.recv(1024) #loop won't run until recieved dat
            except:
                c.shutdown(socket.SHUT_RDWR)
                c.close()
                break

            print("Chat:    ", str(data, 'utf-8'))

            if not data:
                c.close()
                break

    def run(self):
        self._stop = False
        while not self._stop: 
            c, a = self.sock.accept()  ##c is client and a is address
            cThread = threading.Thread(target=self.handler, args=(c,a))
            cThread.daemon = True
            cThread.start()
            self.connections.append(c)
            print("Server:    ", str(a[0]) + ':' + str(a[1]), "connected")
        self.close()

    def shutdownServer(self):
        self._stop = True 

    def close(self):
        print('Closing server')
        if self.sock:
            self.sock.close()
            self.sock = None

def serverRun(port, stop):
    while True:
        print("server port: " + str(port))
        actual_server = Server(port)
        actual_server.run()
        if(stop):
            print("Stopping server thread")
            break

这里是设置线程并运行服务器的代码：

def main():
        stopThreads = False
        thread = threading.Thread(target = server.serverRun, args=(1, lambda : stopThreads,))
        thread.start()
        time.sleep(1)
        stopThreads = True
        thread.join()
        print("server thread killed")
main()

任何帮助将不胜感激。

编辑：为了澄清问题而进行的编辑较少是关闭线程，而更多是将变量传递给线程中正在运行的类，以便在尝试停止线程时可以关闭其套接字。

Answer 1

好的，所以我知道阻塞器是socket.accept（）函数。因此，对于终止服务器线程可能有相同问题的任何人，您都可以在sock.accept（）之前使用sock.select（）来检查是否存在任何传入连接。如果您使用sock.select（）并向其中添加超时，则整个循环将在分配的等待连接的时间后运行，因此如果事件告诉线程这样做并且如果线程尚未中断，则线程可以被杀死。 t，它将再次寻找连接。

您可以使用线程事件功能（stovfl在主线程的注释中提到）来告诉线程何时停止。

这里是我更改代码的方式，现在它可以自行终止：

def run(self, running):
        while running.is_set(): 
            timeout = 2
            readable, writable, errored = select.select([self.sock], [], [], timeout)
            for s in readable:
                if s is self.sock:
                    client_socket, a = self.sock.accept()  ##c is client and a is address
                    cThread = threading.Thread(target=self.handler, args=(client_socket, a))
                    cThread.daemon = True
                    cThread.start()
                    self.connections.append(client_socket)
                    print("Server:    ", str(a[0]) + ':' + str(a[1]), "connected")

        self.close()

def serverRun(running, port):
    while running.is_set():
        print("server port: " + str(port))
        actual_server = Server(port)
        actual_server.run(running)

并且main更改为：

def main(): 
    running = threading.Event()
    running.set()

    thread = threading.Thread(target=server.serverRun, args=(running, 1))
    thread.start()

    time.sleep(30)
    print("Event running.clear()")
    running.clear()

    print('Wait until Thread is terminating')
    thread.join()
    print("EXIT __main__")

main()