# coding=utf-8

 from multiprocessing import Process

 from multiprocessing import queues

 import multiprocessing

 def ag(i,arg):

     arg.put(i)

     print(i,arg.qsize())





 q=queues.Queue(20,ctx=multiprocessing)#通过queues实现数据的共享

 if __name__ == '__main__':

      for i in range(20):

          t=Process(target=ag,args=(i,q))

          t.start()