testq.py

from threading import Thread
from time import sleep

n_items = 1000
queue = None

def put_stuff():
    for x in xrange(n_items):
        queue.put_nowait("xxx")

def run_test(q, n):
    global queue
    queue = q
    threads = [Thread(target=put_stuff) for x in xrange(n)]
    [t.start() for t in threads]

    count = n_items*n
    while count > 0:
        item = queue.get()
        count -= 1