当前位置:   article > 正文

python异步编程(asyncio)_python异步绘图

python异步绘图
异步编程
    3.1 事件循环
    inport asyncio
    
    # 去生成或获取一个事件循环
    loop = asyncio.get_event_loop()
    
    # 将任务放到'任务列表'
    loop.run_until_complete(任务)
    
    3.2 快速上手
    协程函数,定义函数时候async def 函数名
    协程对象,执行协程函数()得到的协程对象 
    async def func():
       pass
    
    result = func()
    
    注意: 执行协程函数创建协程对象,函数内部代码不会执行
    如果想要运行协程函数内部代码,必须要将协程对象交给事件循环来处理
    
    import asyncio
    
    async def func():
       print("k=快来学习吧")
       
    result = func()
    
    loop= async.get_event_loop()
    loop.run_until_complete(result)
    
    # asyncio.run(result)  python3.7及之后
    
    3.3 await
    await + 可等待的对象(协程对象、Future、Task对象 --> IO等待)
    
    import asyncio
    
    async def func():
       print()
       response = await asyncio.sleep(2)
       print("结束", response)
    
    asyncio.run(func())
    
    3.4 Task对象
    
    作用:在事件循环中添加多个任务
    
    Tasks用于并发协程调度,通过asyncio.create_task(协程对象)的方式创建Task对象,
    这样可以让协程加入事件循环中等待被调度执行。除了使用asyncio.create_task()函数以外,还可以用低层级的
    loop.create_task()或ensure_future()函数。不建议手动实例化Task对象。
    
    注意: asyncio.create_task()函数在python3.7中被加入,在python3.7之前改用低层级的asyncio.ensure_future()函数
    
    示例1:
    import asyncio
    
    async def func():
        print(1)
        await asyncio.sleep(2)
        print(2)
        return "返回值"
        
    async def main():
        print("main开始")
        
        task1 = asyncio.create_task(func())
        
        task2 = asyncio.create_task(func())
        
        print("main结束")
        
        ret1 = await task1
        ret1 = await task2
        print(ret1, ret2)
    
    asyncio.run(mian())
    
    示例2:
    import asyncio

    async def func():
        print(1)
        await asyncio.sleep(2)
        print(2)
        return "返回值"


    async def main():
        print("main开始")

    task_list = [
        asyncio.create_task(func(), name='n1'),
        asyncio.create_task(func(), name='n2')
    ]

    print("main结束")

    done, pending = await asyncio.wait(task_list, timeout=None)
    print(done)
    print(pending)

    asyncio.run(main())  # 执行此代码后事件循环已经创建
    
    
    示例3:
    import asyncio


    async def func():
        print(1)
        await asyncio.sleep(2)
        print(2)
        return "返回值"

    task_list = [
        func(),
        func(),
    ]


    # done, pending = await asyncio.wait(task_list, timeout=None)
    done, pending = asyncio.run(asyncio.wait(task_list))
    print(done)
    print(pending)



    
    
    
     
    
    
    
    
    
    
    
    
    
    
        

 

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/Li_阴宅/article/detail/832813
推荐阅读
相关标签
  

闽ICP备14008679号