multiprocessing.Queue() 和 Queue.Queue() 有区别吗？

[cc7756789]

用法都一样， 但下面这段代码，Queue从 Queue.Queue导入，read函数便没有执行

from multiprocessing import Pool, Process, Queue
import os, time, random

def write(q):
for v in ['A', 'B', 'C']:
print 'Put %s to queue ' % v
q.put_nowait(v)
time.sleep(random.random())

def read(q):
while 1:
if not q.empty():
v = q.get(True)
print "Get %s from queue" % v
time.sleep(random.random())
else:
break

if __name__ == '__main__':
q = Queue()
pw = Process(target=write, args=(q, ))
pr = Process(target=read, args=(q, ))
pw.start()
pw.join()

pr.start()
pr.join()

print "all done.."

[clino]

multiprocessing.Queue 这个重点是支持进程间的通讯
第二个应该木有这种功能吧

[cc7756789]

@clino 我的理解就是Queue模块是给多线程用的，多线程之间可以共享内存，而multiprocessing自带的Queue支持多进程间的通讯 ？

[clino]

@cc7756789
文档不看的?
'''
multiprocessing supports two types of communication channel between processes:

Queues
...
Pipes
...

'''

[kimchan]

multiprocessing.Queue 是用来支持多个进程使用一个队列的, 如果你程序是多进程, 但是使用的队列的Queue.Queue, 那么每个进程就会都新建了一个队列, 无法供应资源