Python复习—并发编程实战(八)—生产者-消费者模型、线程与进程总结
发布时间
阅读量:
阅读量
任务
生产者管理生成数据(自动生成一个随机数值),消费者识别生成的数据是否为质数。
现在假设有一个生产者和多个消费者。
1. 多线程(Thread)的生产者消费者模型
import random
import time
import math
import threading
from queue import Queue
class Producer(threading.Thread): # 生产者线程
def __init__(self, data, num_sum):
super(Producer, self).__init__()
self.data = data
self.num_sum = num_sum
def run(self):
for idx in range(self.num_sum):
self.data.put(random.randint(0,999999999)) # 队列进
class Consumer(threading.Thread): # 消费者线程
def __init__(self, data,
全部评论 (0)
还没有任何评论哟~
