关于异步IO asyncIO 协程coroutine 并发的疑惑。

发布于 2022-09-06 09:37:30 字数 1600 浏览 14 评论 0

问题在最下面!

#!/usr/bin/env python3
# -*- coding: utf-8 -*-

import threading, asyncio, time

@asyncio.coroutine
def sleep1():     
    print("Am I being executed concurrently?")
    #yield from asyncio.sleep(3)
    time.sleep(1)     
    yield

@asyncio.coroutine
def hello(n):

    print(n,'Hello world! (%s)' % threading.currentThread())
    yield from sleep1()
    print(n,'Hello again! (%s)' % threading.currentThread())

loop = asyncio.get_event_loop()                 # 获得时间循环
tasks = [hello(n) for n in range(1,5)]          # 布置任务
loop.run_until_complete(asyncio.wait(tasks))    # 开始执行
loop.close()

输出结果:

2 Hello world! (<_MainThread(MainThread, started 13608)>)
Am I being executed concurrently?
1 Hello world! (<_MainThread(MainThread, started 13608)>)
Am I being executed concurrently?
3 Hello world! (<_MainThread(MainThread, started 13608)>)
Am I being executed concurrently?
4 Hello world! (<_MainThread(MainThread, started 13608)>)
Am I being executed concurrently?
2 Hello again! (<_MainThread(MainThread, started 13608)>)
1 Hello again! (<_MainThread(MainThread, started 13608)>)
3 Hello again! (<_MainThread(MainThread, started 13608)>)
4 Hello again! (<_MainThread(MainThread, started 13608)>)

问题:4个协程hello的:hello world! 为什么没有并发输出? 而是等了 sleep1() ?

重新补充:
我清楚 time.sleep 无法异步,只能串行。这个没有问题。
但是 yield from sleep1(),遇到 yield 按照协程的规则,当前协程等待 sleep1()返回,但控制权应该交给其他协程继续运行啊??
我期待的结果是 4个hello world 迅速输出然后 阻塞的 sleep 依次等待。然后 4个 hello again 输出。这也是串行的,单线程。应该符合协程的规则。

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(3

你的笑 2022-09-13 09:37:30

time.sleep改成asyncio.sleep

塔塔猫 2022-09-13 09:37:30

你既然用了asyncio这个框架,就要按照这个框架作者的说明去使用,不能直接使用sleep,那样会在主程序直接全局sleep。

蓝梦月影 2022-09-13 09:37:30

我很奇怪为什么你这里输出为什么不是1,2,3,4而是2,1,3,4...

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文