从 yield 到 await：Python 协程的进化史

def counter():    i = 0    while True:        yield i        i += 1
gen = counter()print(next(gen))  # 输出 0print(next(gen))  # 输出 1

def echoer():    while True:        msg = yield        print(f"Echo: {msg}")
e = echoer()next(e)         # 预激：运行到第一个 yielde.send("Hi")    # 打印 "Echo: Hi"

def child_task():    for i in range(3):        print(f"  Child step {i}")        yield f"data_{i}"    return "child_done"
def parent_task():    print("Parent start")      # 想要“调用” child_task 并将其产出透传出去    for data in child_task():        yield data  # 手动循环转发      print("Parent end")

p = parent_task()next(p)p.send("X")  # ❌ 实际发送给了父生成器，但父层没有接收逻辑！

p.throw(ValueError())

def parent_task():    print("Parent start")    result = yield from child_task()   # 控制权移交，结束后自动继续    print(f"Child returned: {result}")    print("Parent end")

@wrappertaskdef parent_task():    self.setup()    yield child_task()    self.cleanup()

# commit_id: e649574d4751ffd8578f63787621c3a26d383a34
class Resource(status.ResourceStatus)    @scheduler.wrappertask    def destroy(self):        """A task to delete the resource and remove it from the database."""        yield self.delete()
        if self.id is None:            return
        try:            resource_objects.Resource.delete(self.context, self.id)        except exception.NotFound:            # Don't fail on deleteif the db entry has            # not been created yet.            pass
        self.id = None

def wrappertask(task):    """  Decorator for a task that needs to drive a subtask.  This is essentially a replacement for the Python 3-only "yield from"  keyword(PEP 380), using the "yield" keyword that is supported in  Python 2. For example::    @wrappertask    def parent_task(self):      self.setup()      yield self.child_task()      self.cleanup()  """    def wrapper(*args, **kwargs):        # 启动父生成器任务        parent = task(*args, **kwargs)        # 遍历父生成器产生的每个子任务        for subtask in parent:            try:                # 如果子任务不为None，则需要驱动执行它                if subtask is not None:                    # 遍历子任务产生的每个步骤                    for step in subtask:                        try:                            # 将子任务的产出值传递给外界调用者                            yield step                        # 捕获生成器关闭异常                        except GeneratorExit as exit:                            # 关闭子任务并重新抛出异常                            subtask.close()                            raise exit                        # 捕获其他所有异常                        except:                            try:                                # 将异常传递给子任务处理                                subtask.throw(*sys.exc_info())                            # 如果子任务因StopIteration结束，则跳出循环                            except StopIteration:                                break                else:                    # 如果子任务为None，则简单地yield一个值                    yield            # 捕获生成器关闭异常            except GeneratorExit as exit:                # 关闭父任务并重新抛出异常                parent.close()                raise exit            # 捕获其他所有异常            except:                try:                    # 将异常传递给父任务处理                    parent.throw(*sys.exc_info())                # 如果父任务因StopIteration结束，则跳出循环                except StopIteration:                    break    return wrapper

def parent_task():    print("Parent start")    result = yield from child_task()   # 所有行为自动代理    print(f"Child returned: {result}")    print("Parent end")

async def child_coro():    await asyncio.sleep(1)    return "child_done"
async def parent_coro():    print("Parent start")    result = await child_coro()    print(f"Child returned: {result}")    print("Parent end")

import asyncio
async def main():    task1 = asyncio.create_task(some_work())    task2 = asyncio.create_task(other_work())
    await task1    await task2
asyncio.run(main())  # 启动事件循环