python2

gistfile1.txt

#coding:utf-8
import os, sys, time
from multiprocessing import Pool, Queue, Manager


def out(queue):
    while True:
        item = queue.get()
        print item
        time.sleep(0.01)


class Data(object):
    def __init__(self):
        self.pool = Pool(2)
        self.queue = Manager().Queue()

    def put(self,item):
        self.queue.put(item)


    def start(self):
        print self.queue.qsize()
        for _ in range(2):
            self.pool.apply_async(out,(self.queue,))

if __name__ == '__main__':

    data = Data()
    for i in range(1000):
        data.put(i)
    data.start()
    data.pool.close()
    data.pool.join()