python 多进程multipocessing模块
# -*-coding:utf-8-*-__author__ = 'magicpwn'
import multiprocessing
import Queue
def worker():
print 'worker'
return
q = Queue.Queue(1000)
def producer():
for i in range(1000):
q.put(i)
def consumer():
for i in range(1000):
print q.get(), q.qsize()
# 进程不能使用queue
# k = multiprocessing.Process(target=producer)
# sh = multiprocessing.Process(target=consumer)
# k.start()
# sh.start()
# 多进程声明和使用同线程，但通信不能使用queue.
if __name__ == '__main__':
jobs= []
for i in range(5):
p = multiprocessing.Process(target=worker)
jobs.append(p)
p.start()
页:
[1]