Python multiprocessing.Queue sucks

output.txt

zmq: 2.904726
queue: 12.812472

zmq_vs_std_queue.py

from threading import Thread
from time import time
from multiprocessing import Queue

import zmq


def inproc(sock):
    while True:
        d = sock.recv_pyobj()
        if not d:
            break
    sock.close()


def queue(q):
    while True:
        d = q.get()
        if not d:
            break


def test_inproc():
    ctx = zmq.Context()
    pull = ctx.socket(zmq.PULL)
    pull.bind('inproc://worker')
    worker = Thread(target=inproc, args=(pull,))
    worker.start()
    push = ctx.socket(zmq.PUSH)
    push.connect('inproc://worker')
    t0 = time()
    for i in range(1000000):
        push.send_pyobj(b'q')
    push.send_pyobj(b'')
    push.close()
    worker.join()
    ctx.term()
    print("zmq: %f" % (time() - t0))


def test_queue():
    q = Queue()
    worker = Thread(target=queue, args=(q,))
    worker.start()
    t0 = time()
    for i in range(1000000):
        q.put(b'q')
    q.put(b'')
    worker.join()
    print("queue: %f" % (time() - t0))


if __name__ == "__main__":
    test_inproc()
    test_queue()

норм... а zmq и multiprocessing.Queue запусти чтоб на одном железе сравнить?