mirror of https://github.com/zeromq/pyzmq.git
37 lines
680 B
Python
37 lines
680 B
Python
#!/usr/bin/env python
|
|
"""For use with pong.py
|
|
|
|
This script simply pings a process started by pong.py or tspong.py, to
|
|
demonstrate that zmq remains responsive while Python blocks.
|
|
|
|
Authors
|
|
-------
|
|
* MinRK
|
|
"""
|
|
|
|
import time
|
|
|
|
import numpy
|
|
|
|
import zmq
|
|
|
|
ctx = zmq.Context()
|
|
|
|
req = ctx.socket(zmq.REQ)
|
|
req.connect('tcp://127.0.0.1:10111')
|
|
|
|
# wait for connects
|
|
time.sleep(1)
|
|
n = 0
|
|
while True:
|
|
t: float = numpy.random.random()
|
|
time.sleep(t)
|
|
for i in range(4):
|
|
n += 1
|
|
msg = f'ping {n}'
|
|
tic = time.time()
|
|
req.send_string(msg)
|
|
resp = req.recv_string()
|
|
print(f"{msg}: {1000 * (time.time() - tic):.2f} ms")
|
|
assert msg == resp
|