首页 > 编程语言 > 详细

线程_FIFO队列实现生产者消费者

时间:2020-05-07 21:45:32      阅读:66      评论:0      收藏:0      [点我收藏+]
import threading # 导入线程库
import time
from queue import Queue # 队列

class Producer(threading.Thread):
    # 线程的继承类,修改 run 方法
    def run(self):
        global queue
        count = 0
        while True:
            if queue.qsize() <1000:
                for i in range(100):
                    count = count + 1
                    msg = 生成产品+str(count)
                    queue.put(msg)#向队列中添加元素
                    print(msg)
            time.sleep(1)


class Consumer(threading.Thread):
    # 线程的继承类,修改 run 方法
    def run(self):
        global queue
        while True:
            if queue.qsize() >100 :
                for i in range(3):
                    msg = self.name + 消费了 + queue.get() #获取数据
                    # queue.get()获取到数据
                    print(msg)
            time.sleep(1)


if __name__ == __main__:
    queue = Queue()
    # 创建一个队列

    for i in range(500):
        queue.put(初始产品+str(i))
        # 在 queue 中放入元素 使用 put 函数

    for i in range(2):
        p = Producer()
        p.start()
    #     调用Producer类的run方法
    for i in range(5):
        c = Consumer()
        c.start()

2020-05-07

import threading # 导入线程库
import time

from queue import Queue # 队列

class Producer(threading.Thread):

# 线程的继承类,修改 run 方法
def run(self):

global queue
count = 0
while True:

if queue.qsize() <1000:
for i in range(100):
count = count + 1
msg = 生成产品+str(count)

queue.put(msg)#向队列中添加元素
print(msg)

time.sleep(1)


class Consumer(threading.Thread):
# 线程的继承类,修改 run 方法
def run(self):

global queue
while True:
if queue.qsize() >100 :
for i in range(3):
msg = self.name + 消费了+ queue.get() #获取数据
# queue.get()获取到数据
print(msg)

time.sleep(1)


if __name__ == ‘__main__‘:
queue = Queue()
# 创建一个队列

for i in range(500):

queue.put(初始产品+str(i))
# queue 中放入元素 使用 put 函数

for i in range(2):

p = Producer()
p.start()
# 调用Producer类的run方法
for i in range(5):

c = Consumer()
c.start()

线程_FIFO队列实现生产者消费者

原文:https://www.cnblogs.com/hany-postq473111315/p/12845511.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!