推荐学习书目
› Learn Python the Hard Way
Python Sites
› PyPI - Python Package Index
› http://diveintopython.org/toc/index.html
› Pocoo
值得关注的项目
› PyPy
› Celery
› Jinja2
› Read the Docs
› gevent
› pyenv
› virtualenv
› Stackless Python
› Beautiful Soup
› 结巴中文分词
› Green Unicorn
› Sentry
› Shovel
› Pyflakes
› pytest
Python 编程
› pep8 Checker
Styles
› PEP 8
› Google Python Style Guide
› Code Style from The Hitchhiker's Guide
这是一个创建于 3895 天前的主题，其中的信息可能已经有所发展或是发生改变。
用法都一样， 但下面这段代码，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.."
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.."
4 条回复 • 2015-06-16 17:56:47 +08:00
 |
1
clino 2015 年 5 月 18 日
multiprocessing.Queue 这个重点是支持进程间的通讯
第二个应该木有这种功能吧 |
 |
2
cc7756789 OP @clino 我的理解就是Queue模块是给多线程用的，多线程之间可以共享内存，而multiprocessing自带的Queue支持多进程间的通讯 ？
|
|
3
clino 2015 年 5 月 18 日
@cc7756789
文档不看的? ''' multiprocessing supports two types of communication channel between processes: Queues ... Pipes ... ''' |
 |
4
kimchan 2015 年 6 月 16 日
multiprocessing.Queue 是用来支持多个进程使用一个队列的, 如果你程序是多进程, 但是使用的队列的Queue.Queue, 那么每个进程就会都新建了一个队列, 无法供应资源
|
Select Language