この上から髪を伸ばしています。zeromq と gevent を使用した最も単純な例を取得しようとしています。PUB/SUB ソケットを使用するようにこのスクリプトを変更しました。これを実行すると、「サーバー」ソケットが永遠にループします。gevent.sleep(0.1) 行のコメントを外すと、期待どおりに動作し、他の緑色のスレッド (この場合はクライアント) に譲ります。
問題は、スリープ コールを手動で追加する必要があるのはなぜですか? zmq.green バージョンの zmq をインポートすると、送信呼び出しと受信呼び出しがブロックされておらず、その下でタスクの切り替えが行われると思いました。
つまり、この例を機能させるために gevent.sleep() 呼び出しを追加する必要があるのはなぜでしょうか? Jeff Lindsey の元の例では、彼は REQ/REP ソケットを実行しており、スリープ コールを追加する必要はありません... しかし、これを PUB/SUB に変更したとき、処理のためにクライアントに渡すために必要です。
#Notes: Code taken from slide: http://www.google.com/url?sa=t&rct=j&q=zeromq%20gevent&source=web&cd=27&ved=0CFsQFjAGOBQ&url=https%3A%2F%2Fraw.github.com%2Fstrangeloop%2F2011-slides%2Fmaster%2FLindsay-DistributedGeventZmq.pdf&ei=JoDNUO6OIePQiwK8noHQBg&usg=AFQjCNFa5g9ZliRVoN_yVH7aizU_fDMtfw&bvm=bv.1355325884,d.cGE
#Jeff Lindsey talk on gevent and zeromq
import gevent
from gevent import spawn
import zmq.green as zmq
context = zmq.Context()
def serve():
print 'server online'
socket = context.socket(zmq.PUB)
socket.bind("ipc:///tmp/jeff")
while True:
print 'send'
socket.send("World")
#gevent.sleep(0.1)
def client():
print 'client online'
socket = context.socket(zmq.SUB)
socket.connect("ipc:///tmp/jeff")
socket.setsockopt(zmq.SUBSCRIBE, '')
while True:
print 'recv'
message = socket.recv()
cl = spawn(client)
server = spawn(serve)
print 'joinall'
gevent.joinall([cl, server])
print 'end'