async_1异步

简介

# coding:utf-8

import time,random
import asyncio,os

async def a():
    for i in range(4):
        print(i,'a',os.getpid())
        # time.sleep(random.random()*2)  # 如果使用time的sleep 是CPU级别的阻塞。
        await asyncio.sleep(random.random()*2) # 使用异步就要所有环境都使用上异步。
    return 'a function'

async def b():
    for i in range(4):
        print(i,'b',os.getpid())
        # time.sleep(random.random()*2)
        await asyncio.sleep(random.random() * 2)
    return 'b function'

async def main():
    result = await asyncio.gather(
        a(),
        b()
    )
    #print(result) # 这里result就打印的是列表。
    print(result[0],result[1]) # 按gather内的0，1索引打印列表内的值。

if __name__=='__main__':
    start = time.time()
    asyncio.run(main())
    # a()
    # b()
    print(time.time() - start)  # 不用异步是6秒左右。异步后4秒。
    print('parant is %s' % os.getpid())