asyncio.Queue在有1个协程向队列添加数据,1个协程从队列获取数据时会卡住。
创始人
2024-09-21 05:30:29
0

可以使用asyncio.Lock来确保只有一个协程在同时执行添加或者获取操作,防止被阻塞。下面是示例代码:

import asyncio

async def producer(q, lock):
    while True:
        async with lock:
            await q.put('data')
        await asyncio.sleep(1)

async def consumer(q, lock):
    while True:
        async with lock:
            data = await q.get()
        print(data)
        await asyncio.sleep(1)

async def main():
    q = asyncio.Queue()
    lock = asyncio.Lock()
    producer_task = asyncio.create_task(producer(q, lock))
    consumer_task = asyncio.create_task(consumer(q, lock))
    await asyncio.gather(producer_task, consumer_task)

asyncio.run(main())

在这段示例代码中,我们创建了一个异步锁asyncio.Lock(),并在producer和consumer协程中使用with关键字来对锁进行上下文管理。

这样,在任何时候,只会有一个协程在执行添加或获取操作,防止了队列被卡住的情况出现。

相关内容

热门资讯

日前!中至鹰潭亲友圈辅助(辅助... 日前!中至鹰潭亲友圈辅助(辅助)切实是有辅助修改器(有挂透视)-哔哩哔哩1、日前!中至鹰潭亲友圈辅助...
相较于以往!来几局辅助器吾爱破... 相较于以往!来几局辅助器吾爱破解(辅助)切实是有辅助工具(有挂方略)-哔哩哔哩来几局辅助器吾爱破解脚...
据统计!广东雀神挂件脚本开挂(... 据统计!广东雀神挂件脚本开挂(辅助)一贯是有辅助挂(有挂方法)-哔哩哔哩小薇(辅助器软件下载)致您一...
有了最新消息!樱花之盛免费挂(... 有了最新消息!樱花之盛免费挂(辅助)本来真的是有辅助软件(有挂猫腻)-哔哩哔哩1、金币登录送、破产送...
网友热议!陕麻圈内购破解辅助(... 网友热议!陕麻圈内购破解辅助(辅助)确实有挂辅助神器(有挂秘诀)-哔哩哔哩1、打开软件启动之后找到中...
现场直击!广西友乐解码器下载安... 现场直击!广西友乐解码器下载安装(辅助)一直真的是有辅助脚本(确实有挂)-哔哩哔哩1、完成广西友乐解...
据文件显示!兴动互娱技巧(辅助... 据文件显示!兴动互娱技巧(辅助)一贯有挂辅助插件(有挂教学)-哔哩哔哩1、金币登录送、破产送、升级送...
近年来!越乡游义乌微信小程序辅... 近年来!越乡游义乌微信小程序辅助(辅助)其实是真的辅助软件(有挂辅助)-哔哩哔哩越乡游义乌微信小程序...
刚刚!510k脚本(辅助)切实... 刚刚!510k脚本(辅助)切实是有辅助神器(有挂详细)-哔哩哔哩1、完成510k脚本有辅助插件,帮助...
经调查!盛世辅助器(辅助)切实... 经调查!盛世辅助器(辅助)切实是真的辅助平台(有挂工具)-哔哩哔哩1、盛世辅助器辅助器安装包、盛世辅...