Changeset 930b504 for doc/papers/concurrency/examples/Pingpong.py

Timestamp:

Feb 26, 2020, 6:13:54 PM (6 years ago)

Author:

Peter A. Buhr <pabuhr@…>

Branches:

ADT, arm-eh, ast-experimental, enum, forall-pointer-decay, jacob/cs343-translation, jenkins-sandbox, master, new-ast, new-ast-unique-expr, pthread-emulation, qualifiedEnum

Children:

04e6f93, 5452673, dac55004

Parents:

aeb5d0d (diff), 7dc2e015 (diff)
Note: this is a merge changeset, the changes displayed below correspond to the merge itself.
Use the (diff) links above to see all the changes relative to each parent.

Message:

Merge branch 'master' of plg.uwaterloo.ca:software/cfa/cfa-cc

File:

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

doc/papers/concurrency/examples/Pingpong.py

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