Changeset 1e5d0f0c for doc/papers/concurrency/examples

Timestamp:

Mar 27, 2019, 9:07:47 AM (6 years ago)

Author:

Peter A. Buhr <pabuhr@…>

Branches:

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

Children:

86fb8f2

Parents:

0087e0e

Message:

start rewrite of coroutine section

Location:

doc/papers/concurrency/examples

Files:

• Fib2.cfa (added)
• Pingpong.cfa (modified) (3 diffs)
• Pingpong.py (modified) (1 diff)
• ProdCons.cfa (modified) (1 diff)
• ProdCons.py (added)

doc/papers/concurrency/examples/Pingpong.cfa

@@ -4 +4 @@
 coroutine PingPong {
         const char * name;
-        /* const */ unsigned int N;
-        PingPong * part;
+        unsigned int N;
+        PingPong & part;
 };
 
 void ?{}( PingPong & this, const char * name, unsigned int N, PingPong & part ) {
-        (this.__cor){name};
-        this.name = name;
-        this.N = N;
-        this.part = ∂
+        this.[name, N] = [name, N];  &this.part = ∂
 }
 void ?{}( PingPong & this, const char * name, unsigned int N ) {
-        this{ name, N, *(PingPong *)0 };
+        this{ name, N, *0p };                                                           // call first constructor
 }
 void cycle( PingPong & pingpong ) {
@@ -21 +18 @@
 }
 void partner( PingPong & this, PingPong & part ) {
-        this.part = ∂
+        &this.part = ∂
         resume( this );
 }
-void main( PingPong & pingpong ) {                                              // ping's starter ::main, pong's starter ping
-        for ( pingpong.N ) {                                                            // N ping-pongs
-                sout | pingpong.name;
-                cycle( *pingpong.part );
+void main( PingPong & pingpong ) with(pingpong) {               // ping's starter ::main, pong's starter ping
+        for ( N ) {                                                                                     // N ping-pongs
+                sout | name;
+                cycle( part );
         } // for
 }
 int main() {
-        enum { N = 20 };
+        enum { N = 5 };
         PingPong ping = { "ping", N }, pong = { "pong", N, ping };
         partner( ping, pong );
@@ -38 +35 @@
 // Local Variables: //
 // tab-width: 4 //
-// compile-command: "cfa pingpong.cfa" //
+// compile-command: "cfa Pingpong.cfa" //
 // End: //

doc/papers/concurrency/examples/Pingpong.py

@@ -1 @@
-def Scheduler
+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():
+        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
+
+s = Scheduler();
+next( s )                       # prime
 try:
-        yield from ping();
-        yield from pong();
+        s.send( pi )                            # start cycle
 except StopIteration:
-        print( "Scheduler stop" )
-
-
-def pong():
-        print( "pong" )
-for i in range( 10 ):
-
-                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:
-        next( p )
-except StopIteration:
-        print( "stop" )
+        print( "scheduler stop" )
+print( "stop" )
 
 # Local Variables: #
 # tab-width: 4 #
-# compile-command: "python3.5 pingpong.py" #
+# compile-command: "python3.5 Pingpong.py" #
 # End: #

doc/papers/concurrency/examples/ProdCons.cfa

@@ -23 +23 @@
         sout | "prod stops";
 }
-int payment( Prod & prod, int money ) {
-        prod.money = money;
+int payment( Prod & prod, int m ) with(prod) {
+        money = m;
         resume( prod );                                                                         // main 1st time, then
-        return prod.receipt;                                                            // prod in delivery
+        return receipt;                                                                         // prod in delivery
 }
 void start( Prod & prod, int N, Cons &c ) {