Python 线程：threading.Thread().start() 有效，_thread.start_new_thread() 无效

Question

我正在尝试实现一个连接多个客户端的集中式服务器。连接应保持活动状态。

到目前为止，我已经尝试过使用线程的多个客户端，但是当套接字与客户端“忙”时，另一个客户端无法在该套接字中连接。

此代码代表服务器脚本：

import socket
import threading

HOST = '127.0.0.1'
PORT = 54321


def request_handler(conn, addr):
    with conn:
        print(conn, addr)

        while True:
            data = conn.recv(1024)
            print(data.decode('utf-8'))

            if not data:
                break

            conn.sendall(data)


def main():
    with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
        s.bind((HOST, PORT))
        s.listen()

        while True:
            conn, addr = s.accept()
            print('Connected with', addr[0], ':', str(addr[1]))

            t = threading.Thread(target=request_handler(conn, addr), daemon=True)
            t.start()


if __name__ == '__main__':
    main()

此代码代表客户端部分：

import socket


host = '127.0.0.1'
port = 54321


def main():
    with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
        s.connect((host, port))
        while True:
            data = input('Type data: ')

            if not data:
                break

            s.send(str.encode(data))

            res = s.recv(1024)
            print('Server Response:', res.decode('utf-8'))


if __name__ == '__main__':
    main()

客户端可以写入许多消息，并且连接保持打开状态，但如果我使用另一个客户端，则在第一个客户端关闭连接之前，它无法与服务器连接。

但我想要的是第二个客户端可以对其他客户端执行与第一个客户端相同的操作，依此类推。如何做到这一点？

除了创建多个端口之外还有其他解决方案吗？

更新

我已经使用 _thread.start_new_thread 修改了服务器脚本，现在它可以工作了。但我不明白为什么。

修改 server.py

import socket
from _thread import start_new_thread

HOST = '127.0.0.1'
PORT = 54321


def request_handler(conn, addr):
    with conn:
        print(conn, addr)

        while True:
            data = conn.recv(1024)
            print(data.decode('utf-8'))

            if not data:
                break

            conn.sendall(data)


def main():
    with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
        s.bind((HOST, PORT))
        s.listen()

        while True:
            conn, addr = s.accept()
            print('Connected with', addr[0], ':', str(addr[1]))

            start_new_thread(request_handler, (conn, addr))


if __name__ == '__main__':
    main()

总而言之，使用 start_new_thread(request_handler, (conn, addr)) 第二个客户端可以连接到服务器并发送消息；使用 threading.Thread(target=request_handler(conn, addr)).start() 它不会连接到服务器，但不会引发错误。

当我使用 threading.Thread.start() 时，主线程正在等待 #1 客户端线程停止，因此它处于休眠状态，并且不会启动 #2 客户端线程；相反，_thread.start_new_thread()工作正常。但是 threading.Thread.start() 实现了 _thread.start_new_thread，那么这里发生了什么？

Answer 1

解决了，我以错误的方式使用 threading.Thread 构造函数：

构造函数调用 request_handler 而不是引用它。

所以，而不是：

t = threading.Thread(target=request_handler(conn, addr))

正确的方法是：

t = threading.Thread(target=request_handler, args=(conn, addr))

以便线程可以并行运行。