Changes in doc/papers/concurrency/examples/Pingpong.py [1e5d0f0c:17c6c1c3]

File:

• doc/papers/concurrency/examples/Pingpong.py (modified) (1 diff)

doc/papers/concurrency/examples/Pingpong.py

@@ -1 @@
-def PingPong( name, N ):
-        partner = (yield)           # get partner
-        yield                       # resume scheduler
-        for i in range( N ):
-                print( name )
-                yield partner           # execute next
-        print( "end", name )
+def Scheduler
+try:
+        yield from ping();
+        yield from pong();
+except StopIteration:
+        print( "Scheduler stop" )
 
-def Scheduler():
-        n = (yield)                 # starting coroutine
-        while True:
-                n = next( n )           # schedule coroutine
 
-pi = PingPong( "ping", 5 )
-po = PingPong( "pong", 5 )
-next( pi )                      # prime
-pi.send( po )                   # send partner
-next( po )                      # prime
-po.send( pi )                   # send partner
+def pong():
+        print( "pong" )
+for i in range( 10 ):
 
-s = Scheduler();
-next( s )                       # prime
+                yield from ping()
+        print( "stop pong" )
+
+def ping():
+        global i
+        print( "ping" )
+        i += 1
+        if i < 5:
+                yield from pong()
+        print( "stop ping" )
+
+p = ping()
 try:
-        s.send( pi )                            # start cycle
+        next( p )
 except StopIteration:
-        print( "scheduler stop" )
-print( "stop" )
+        print( "stop" )
 
 # Local Variables: #
 # tab-width: 4 #
-# compile-command: "python3.5 Pingpong.py" #
+# compile-command: "python3.5 pingpong.py" #
 # End: #