# 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()