def udp_reader(socket, iqueue, size):
"""Read one or more packets from an UDP socket."""
data, peer = socket.recvfrom(size)
iqueue.put_nowait((peer, data))
微信
公众号
扫码关注公众号