ソケットにデータがあるのを待つ方法は？

Question

私はいくつかのソケットを同時に開くソケットクライアントを実装しています。どんなソケットにも異なる時刻にデータがある可能性があり、ソケットにデータがあり、読み込み可能なときにコードを実行したい。

私はこれを実装する方法を、私はselect.selectを見ていたかわからないが、読みやすいように、すべてのソケットを待つように思われます。

私はそれが各ソケットからの読み込みで連続することが、利用可能なデータがあるときに読みたい、ソケット上のデータを処理するためのマルチプロセッシングを使用しないようにしたいと思います。

にはどうすれば読めるように任意のソケットのを待つのですか？

# psudo code 

sockets = [sock1, sock2, sock3] 

while True: 
    if len(sockets) == 0: 
    break 
    for sock in sockets: 
    if sock.has_data(): 
     do_stuff(sock) 
     sockets.remove(sock) 
    sleep(0.1) 

Answer 1

はあなたがあなたの問題のためselect.selectを使用することができます標準ライブラリにselectorsモジュールがあります。それはあなたのシステムが提供する（選択し、世論調査、kqueueの...）「最高の」I/Oの多重化の実装のために、こののbackportをありますドキュメントのページhttps://docs.python.org/3/library/selectors.html

の最後に、単純なエコーサーバの例がありますが使用されます古いPythonバージョンも利用可能です。そのうちの一つが読めるしたら

Answer 2

あなたがPOSIX上にある場合は、select.pollを見てみましょう：あなたは、Python 3.4以降を使用している場合

sockets = [sock1, sock2, sock3] 
while sockets: 
    rlist, _, _ = select.select(sockets, [], []) 
    for sock in rlist: 
     do_stuff(sock) 
     sockets.remove(sock) 

Answer 3

：

import socket 
import select 
p = select.poll() 
s1 = socket.socket() 
s2 = socket.socket() 
# call connect on sockets here... 
p.register(s1, select.POLLIN) 
p.register(s2, select.POLLIN) 
p.poll()