On Wednesday, March 20, 2013 12:14:09 PM He Jie Xu wrote:
> Hi, all
>
> I try zeromq with following code:
>
> import zmq
> import random
> import time
>
> context = zmq.Context()
> socket = context.socket(zmq.PUSH)
> socket.bind("ipc://test.sock")
> socket.setsockopt(zmq.HWM, 1000)
> while True:
> zipcode = random.randrange(1, 100000)
> temperature = random.randrange(1, 215)
> message = "%d %d" % (zipcode, temperature)
> socket.send(message)
> print 'send', message
> time.sleep(1)
>
>
> When I am running the code without any consumer. it will block at
> 'socket.send'
>
> But after I read the document, I think when I set HWM, the message will
> send to memory buffer, it shouldn't block. Is there any wrong? How can I
> make the 'socket.send' won't block?
>
> my zmq version was 2.1.11
>
> I will appreciate any help from you!
This is one of the non-obvious aspects of zmq. Queues only exist when there
are known connections (whether potential or established). For sockets that
connect, the connections are known as you specify them. For sockets that bind,
the connections are known only when they are received. Therefore, a bind
socket that has no peers (no known connections) will block when you try to
send.
It's a little confusing because a connect socket that no peers will not block,
meaning that the choice to bind or connect produces different behaviors. But it
makes sense once you understand how the queues work.
Justin
_______________________________________________
zeromq-dev mailing list
zeromq-dev@lists.zeromq.org
http://lists.zeromq.org/mailman/listinfo/zeromq-dev
