我有這段服務器端代碼：
def listen_on_port(self):
try:
running = True
HOST = '' # Symbolic name meaning all available interfaces
PORT = int(self.port) # Arbitrary non-privileged port
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
server_socket.bind((HOST, PORT))
server_socket.listen()
server_socket.setblocking(False) # non-blocking I/O
self.logger.info(f'listening on port {self.port}')
read_list = [server_socket]
while running:
try:
self.logger.info(f'calling select().')
readable, writable, errored = select.select(read_list, [], [])
self.logger.info(f'called select().')
for s in readable:
if s is server_socket:
client_socket, address = server_socket.accept()
read_list.append(client_socket)
self.logger.info(f"Connection from address = {address} client_socket is {client_socket}.")
else:
self.logger.info(f"going to call s.recv(). s is {s}")
try:
data = s.recv(1024)
self.logger.info(f"Got data = {data}.")
if 'terminate' in data.decode('utf-8'):
self.logger.info(f"terminating.")
running = False
except Exception as ex:
self.logger.info(f'error s.recv() ex={ex}.')
finally:
self.logger.info(f"closing socket. s = {s}.")
s.close()
read_list.remove(s)
except Exception as ex:
self.logger.info(f'Inside while True. error ex={ex}.')
raise ex
except Exception as ex:
self.logger.info(f'error ex={ex}.')
當我運行我的腳本時，我可以在我的日志檔案中看到我的代碼正在等待......
readable, writable, errored = select.select(read_list, [], [])
... 回傳。我的日志檔案：
$ cat /tmp/test.log
doing port 50050
listening on port 50050
calling select().
我打電話...
server_socket.setblocking(False) # non-blocking I/O
...但代碼仍然阻塞。如果這很重要，我正在 Mac（不是 Linux 系統）上運行。
uj5u.com熱心網友回復：
select不在乎套接字是否阻塞。如果要進行非阻塞select呼叫，則需要指定超時值為 0：
readable, writable, errored = select.select(read_list, [], [], 0)
也就是說，您的代碼并沒有比阻塞更好的事情要做。指定timeout=0只會把你的while running回圈變成一個忙碌的等待。
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/447340.html
上一篇：如何在C中洗掉對變數的參考