HTTP服务器线程池被接收函数阻塞

在处理socket连接时，可以使用非阻塞I/O（Non-blocking I/O）来避免线程被阻塞。具体实现可以使用select或epoll来实现。

下面是一个使用select实现非阻塞I/O的示例代码：

import socket

sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.bind(('localhost', 8080))
sock.listen(10)

sock.setblocking(False)   # 将 socket 设置为非阻塞模式

inputs = [sock]
outputs = []

while True:
    readable, writable, exceptional = select.select(inputs, outputs, inputs)

    # 处理可读事件
    for s in readable:
        if s is sock:
            connection, client_address = s.accept()
            connection.setblocking(False)   # 将新建立的连接设置为非阻塞模式
            inputs.append(connection)
        else:
            data = s.recv(1024)
            if data:
                print('Received message: ', data.decode('utf-8'))
                outputs.append(s)
            else:
                inputs.remove(s)
                s.close()

    # 处理可写事件
    for s in writable:
        s.send(b'HTTP/1.1 200 OK\r\n\r\nHello, world!')
        outputs.remove(s)

    # 处理异常事件
    for s in exceptional:
        inputs.remove(s)
        if s in outputs:
            outputs.remove(s)
        s.close()

在上面的代码中，setblocking(False)将socket设置为非阻塞模式，而select.select()函数可以监听多个socket，并且当socket出现可读、可写或异常事件时，会返回对应的socket列表。因此我们可以在循环中不断处理这些事件，从而实现非阻塞I/O的效果。