Lock, Pipe # 管道
import time
import random
def producer_action(producer, pro, consumer_acc): # 生产端函数...producer.send(None)
producer.close()
def consumer_action(consumer, pro, lock): # 消费进程函数...p_consumer in p_consumer_list:
p_consumer.join()
consumer_obj.close() # 消费端结束
2.进程池,进程池的返回值...,进程池的回调函数
# apply_async(func[, args[, kwds[, callback]]]) 它是非阻塞
# apply(func[, args[, kwds]])是阻塞的(理解区别...):
time.sleep(3) # 进程花了一些时间干了一些事
print('进程号', os.getpid(), '拿到了', item)
return item + '的返回值