Coroutines Asyncio

Question

Je pensais que j'avais croisé coroutines avec très bon presentation de David Beazley mais je ne peux pas le réconcilier entièrement avec la nouvelle syntaxe décrite dans PEP-492. Dans la présentation, il explique comment les coroutines peuvent être considérées comme un pipeline qui est poussé au lieu d'être tiré de comme dans les générateurs.

Par exemple:

# cofollow.py 
# 
# A simple example showing how to hook up a pipeline with 
# coroutines. To run this, you will need a log file. 
# Run the program logsim.py in the background to get a data 
# source. 

from coroutine import coroutine 

# A data source. This is not a coroutine, but it sends 
# data into one (target) 

import time 
def follow(thefile, target): 
    thefile.seek(0,2)  # Go to the end of the file 
    while True: 
     line = thefile.readline() 
     if not line: 
      time.sleep(0.1) # Sleep briefly 
      continue 
     target.send(line) 

# A sink. A coroutine that receives data 

@coroutine 
def printer(): 
    while True: 
     line = (yield) 
     print line, 

# Example use 
if __name__ == '__main__': 
    f = open("access-log") 
    follow(f,printer()) 

Comment peut-on mettre en œuvre le printer() coroutine en utilisant cette nouvelle syntaxe? Je n'ai pas encore vu un exemple où la coroutine est poussée à utiliser cette nouvelle syntaxe. C'est possible?

Answer 1

Ce que vous avez là n'est pas une coroutine dans le sens du module asyncio et/ou du PEP-492. Comme le PEP lui-même dit:

[Cette PEP] ne concerne que le genre de coroutine qui utilise yield comme un signal au programmateur, indiquant que le coroutine vous attendra jusqu'à ce qu'un événement (comme IO) est terminé.

1. Il n'y a pas ordonnanceur (boucle d'événement) impliqué dans votre exemple, et
2. le coroutine n'utilise yield que « comme un signal à l'agenda »; c'est vraiment l'utiliser pour lire des données.