asyncio队列多生产者(同步)单消费者
创始人
2024-09-21 06:30:17
0

下面是一个使用asyncio实现的多生产者(同步)单消费者的示例代码:

import asyncio
import random

async def producer(queue):
    while True:
        # 模拟一些生产的任务
        await asyncio.sleep(random.random())
        item = random.randint(1, 100)
        await queue.put(item)
        print(f'生产者放入队列: {item}')

async def consumer(queue):
    while True:
        # 模拟一些消费的任务
        await asyncio.sleep(random.random())
        item = await queue.get()
        print(f'消费者从队列取出: {item}')
        queue.task_done()

async def main():
    queue = asyncio.Queue()
    producers = [asyncio.create_task(producer(queue)) for _ in range(3)]
    consumer_task = asyncio.create_task(consumer(queue))

    # 等待所有生产者完成
    await asyncio.gather(*producers)

    # 等待队列中的任务全部完成
    await queue.join()

    consumer_task.cancel()
    await consumer_task

asyncio.run(main())

在这个示例中,我们创建了一个asyncio队列,并创建了多个生产者任务和一个消费者任务。生产者任务循环执行,每次生产一个随机数并放入队列中。消费者任务循环执行,每次从队列中取出一个元素并进行处理。在生产者任务完成后,我们使用await queue.join()等待队列中的所有任务都完成,然后取消消费者任务。最后,我们使用asyncio.run(main())来运行主任务。

相关内容

热门资讯

2024教程!德扑ai有挂总是... 2024教程!德扑ai有挂总是,德扑之星解析真是是真的有挂(详细代打教程);致您一封信;亲爱玩家:《...
wepoke模拟器!wepok... wepoke模拟器!wepoke线上,wePoke都是真的有挂,解密教程(有挂教程);玩家必备必赢加...
总算了解!!德扑真的有挂一直,... 总算了解!!德扑真的有挂一直,德扑之星底牌一直有挂(详细ai代理教程)1、快速入门:当你通过点击开始...
wepokeai机器人!wep... wepokeai机器人!wepoke系统规律(透视)wepoke(果然真的有挂)是一款可以让一直输的...
透视辅助!微扑克有机器人吗,(... 透视辅助!微扑克有机器人吗,(微扑克机器人)总是有挂(详细全自动机器人教程),您好,这款游戏可以开挂...
wepokeai代打的胜率!w... wepokeai代打的胜率!wopoker有外 挂,wePoke好像真的有挂,安装教程(有挂细节);...
透视辅助!红龙扑克总是有挂,红... 透视辅助!红龙扑克总是有挂,红龙扑克确实真的是有挂(详细辅助工具教程)1、超多福利:超高返利,海量正...
wpk提高胜率!WPk就是真的... wpk提高胜率!WPk就是真的有挂,wpK都是真的有挂,系统教程(有挂教程);该软件可以轻松地帮助玩...
教你攻略!wopoker轻量版... wopoker新手教程相关信息汇总(需添加指定薇757446909获取下载链接);教你攻略!wopo...
wpk德州透视辅助!WpK一般... wpk德州透视辅助!WpK一般真的有挂,wPk都是真的有挂,德州论坛(有挂插件);1、完成wpk透视...