Python多进程教程

sentinel = -1

def creator(data, q):

"""

Creates data to be consumed and waits for the consumer

to finish processing

"""

print('Creating data and putting it on the queue')

for item in data:

q.put(item)

def my_consumer(q):

"""

Consumes some data and works on it

In this case, all it does is double the input

"""

while True:

data = q.get()

print('data found to be processed: {}'.format(data))

processed = data * 2

print(processed)

if data is sentinel:

break

if __name__ == '__main__':

q = Queue()

data = [5, 10, 13, -1]

process_one = Process(target=creator, args=(data, q))

process_two = Process(target=my_consumer, args=(q,))

process_one.start()

process_two.start()

q.close()

q.join_thread()

　　推荐阅读

　　马云说智能世界三要素：互联网、大数据、云计算，机器是不可能取代人类的

我今天不是为不合而不合，我本身认为我们在进入数据时代，一个很重要的事，每小我对每个问题的看法、角度、深度和广度必须是不一样的，只有不一样，你才是你。人工智能，我是这么看的良士>>>详细阅读

地址：http://www.17bianji.com/lsqh/35977.html