通过Asyncio了解Python并发

我想知道如何使用asyncio在python 3.6中并发工作。 我的理解是,当解释器执行await语句时,它会将其留在那里,直到等待过程完成,然后继续执行其他协程任务。 但是我在下面的代码中看到的不是这样的。 程序同步运行,逐个执行任务。

我的理解和实施代码有什么问题?


    import asyncio
    import time

    async def myWorker(lock, i):
        print("Attempting to attain lock {}".format(i))
        # acquire lock
        with await lock:
            # run critical section of code
            print("Currently Locked")

            time.sleep(10)

        # our worker releases lock at this point
        print("Unlocked Critical Section")

    async def main():
        # instantiate our lock
        lock = asyncio.Lock()
        # await the execution of 2 myWorker coroutines 
        # each with our same lock instance passed in 
        # await asyncio.wait([myWorker(lock), myWorker(lock)])
        tasks = []

        for i in range(0, 100):
            tasks.append(asyncio.ensure_future(myWorker(lock, i)))

        await asyncio.wait(tasks)


    # Start up a simple loop and run our main function
    # until it is complete
    loop = asyncio.get_event_loop()
    loop.run_until_complete(main())
    print("All Tasks Completed")
    loop.close()


调用阻塞调用诸如time.sleep在协程ASYNCIO块整个事件循环,击败使用ASYNCIO的目的。

更改await asyncio.sleep(10) time.sleep(10)await asyncio.sleep(10) ,代码的行为将与您的期望类似。


asyncio使用一个循环来运行一切, await会让控制回到循环,这样它可以安排下一个协程运行。

链接地址: http://www.djcxy.com/p/53219.html

上一篇: Understanding Python Concurrency with Asyncio

下一篇: Detect an idle asyncio event loop