# -*- coding: UTF-8 -*-
from multiprocessing.pool import Pool
import Queue
from Logger import p_log

q = Queue.Queue()
for i in xrange(50):
    q.put(i)


def f():
    p_log.DEBUG(q.get())
    p_log.DEBUG(id(q))
    time.sleep(0.1)

if __name__ == '__main__':
    po = Pool(4)
    for i in xrange(20):
        po.apply_async(func=f)

    import time
    time.sleep(3)