Advertisement

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)

还没有任何评论哟~