我正在嘗試創(chuàng)建一個應用程序，該應用程序創(chuàng)建一個套接字并打印出現(xiàn)在套接字上的傳入數(shù)據(jù)。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 內(nèi)核。在具有非阻塞套接字的情況下等待來自套接字的數(shù)據(jù)而沒有這種無限循環(huán)的正確方法是什么？我需要它來檢查連接是否仍然有效。有一個類似的問題CPU 在 python 中使用 select 達到 100% 使用率，但它沒有清楚地解釋為什么某種睡眠是必要的。
2 回答
阿晨1998
TA貢獻2037條經(jīng)驗 獲得超6個贊
您調(diào)用它的方式 ( readers, writers, err = select([s], [s], []))，如果它可讀或可寫，它會立即返回。但是你只檢查它是否可讀。
由于套接字在大多數(shù)情況下可能是可寫的，這正是您被告知的。
另一種可能性是在time.sleep(0.02)某處添加一個，例如，當您在該循環(huán)中不執(zhí)行任何其他操作時。然后，20 毫秒的額外延遲不應該受到傷害（但是，它并不干凈）。
縹緲止盈
TA貢獻2041條經(jīng)驗 獲得超4個贊
select 最常見的用途是只考慮rlistandtimeout參數(shù)。對于您的示例代碼，它應該是：
while True:
readers, writers, err = select([s], [], [])
if s in readers:
data = s.recv(1024)
print(data)
該wlist參數(shù)僅在應用程序可能需要寫入大數(shù)據(jù)時使用。在這種情況下，要寫入套接字的數(shù)據(jù)只是排隊，然后將套接字添加到wlist. 當select返回并且有內(nèi)容要寫入套接字時，程序會嘗試寫入，如果仍有內(nèi)容，它會再次推送到隊列中（注意：必須推送到頭部......）并且套接字留在wlist. 如果所有內(nèi)容都已寫入且隊列為空，則套接字將從wlist.
在上面的文本中，隊列可以是真正的雙端隊列，也可以是簡單的bytes緩沖區(qū)或任何其他允許在兩端添加字節(jié)的容器。每個套接字應該存在一個。
添加回答
舉報
0/150
提交
取消