Changes in doc/papers/concurrency/examples/ProdCons.py [a573c22:1e5d0f0c]

File:

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

doc/papers/concurrency/examples/ProdCons.py

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