我正在嘗試創建一個應用程序，該應用程序創建一個套接字并打印出現在套接字上的傳入數據。select 是使用套接字的首選方法，所以我寫了這個：#!/usr/bin/python3from select import selectimport sockets = socket.socket(socket.AF_INET, socket.SOCK_STREAM)s.connect(('localhost', 2345))s.setblocking(False) # True did not change anything#s.settimeout(2) # same behavior if uncommenteds.send(("give me data\n").encode("latin1"))while True: readers, writers, err = select([s], [s], []) if s in readers: data = s.recv(1024) print(data) # some kind of sleep here?然而，這是代碼示例消耗 100% 的一個 CPU 內核。在具有非阻塞套接字的情況下等待來自套接字的數據而沒有這種無限循環的正確方法是什么？我需要它來檢查連接是否仍然有效。有一個類似的問題CPU 在 python 中使用 select 達到 100% 使用率，但它沒有清楚地解釋為什么某種睡眠是必要的。
2 回答
阿晨1998
TA貢獻2037條經驗 獲得超6個贊
您調用它的方式 ( readers, writers, err = select([s], [s], []))，如果它可讀或可寫，它會立即返回。但是你只檢查它是否可讀。
由于套接字在大多數情況下可能是可寫的，這正是您被告知的。
另一種可能性是在time.sleep(0.02)某處添加一個，例如，當您在該循環中不執行任何其他操作時。然后，20 毫秒的額外延遲不應該受到傷害（但是，它并不干凈）。
縹緲止盈
TA貢獻2041條經驗 獲得超4個贊
select 最常見的用途是只考慮rlistandtimeout參數。對于您的示例代碼，它應該是：
while True:
readers, writers, err = select([s], [], [])
if s in readers:
data = s.recv(1024)
print(data)
該wlist參數僅在應用程序可能需要寫入大數據時使用。在這種情況下，要寫入套接字的數據只是排隊，然后將套接字添加到wlist. 當select返回并且有內容要寫入套接字時，程序會嘗試寫入，如果仍有內容，它會再次推送到隊列中（注意：必須推送到頭部......）并且套接字留在wlist. 如果所有內容都已寫入且隊列為空，則套接字將從wlist.
在上面的文本中，隊列可以是真正的雙端隊列，也可以是簡單的bytes緩沖區或任何其他允許在兩端添加字節的容器。每個套接字應該存在一個。
添加回答
舉報
0/150
提交
取消