Changeset 1e5d0f0c for doc/papers/concurrency/examples
- Timestamp:
- Mar 27, 2019, 9:07:47 AM (6 years ago)
- 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
- Location:
- doc/papers/concurrency/examples
- Files:
-
- 2 added
- 3 edited
Legend:
- Unmodified
- Added
- Removed
-
doc/papers/concurrency/examples/Pingpong.cfa
r0087e0e r1e5d0f0c 4 4 coroutine PingPong { 5 5 const char * name; 6 /* const */unsigned int N;7 PingPong *part;6 unsigned int N; 7 PingPong & part; 8 8 }; 9 9 10 10 void ?{}( PingPong & this, const char * name, unsigned int N, PingPong & part ) { 11 (this.__cor){name}; 12 this.name = name; 13 this.N = N; 14 this.part = ∂ 11 this.[name, N] = [name, N]; &this.part = ∂ 15 12 } 16 13 void ?{}( PingPong & this, const char * name, unsigned int N ) { 17 this{ name, N, * (PingPong *)0 };14 this{ name, N, *0p }; // call first constructor 18 15 } 19 16 void cycle( PingPong & pingpong ) { … … 21 18 } 22 19 void partner( PingPong & this, PingPong & part ) { 23 this.part = ∂20 &this.part = ∂ 24 21 resume( this ); 25 22 } 26 void main( PingPong & pingpong ) {// ping's starter ::main, pong's starter ping27 for ( pingpong.N ) {// N ping-pongs28 sout | pingpong.name;29 cycle( *pingpong.part );23 void main( PingPong & pingpong ) with(pingpong) { // ping's starter ::main, pong's starter ping 24 for ( N ) { // N ping-pongs 25 sout | name; 26 cycle( part ); 30 27 } // for 31 28 } 32 29 int main() { 33 enum { N = 20};30 enum { N = 5 }; 34 31 PingPong ping = { "ping", N }, pong = { "pong", N, ping }; 35 32 partner( ping, pong ); … … 38 35 // Local Variables: // 39 36 // tab-width: 4 // 40 // compile-command: "cfa pingpong.cfa" //37 // compile-command: "cfa Pingpong.cfa" // 41 38 // End: // -
doc/papers/concurrency/examples/Pingpong.py
r0087e0e r1e5d0f0c 1 def Scheduler 1 def PingPong( name, N ): 2 partner = (yield) # get partner 3 yield # resume scheduler 4 for i in range( N ): 5 print( name ) 6 yield partner # execute next 7 print( "end", name ) 8 9 def Scheduler(): 10 n = (yield) # starting coroutine 11 while True: 12 n = next( n ) # schedule coroutine 13 14 pi = PingPong( "ping", 5 ) 15 po = PingPong( "pong", 5 ) 16 next( pi ) # prime 17 pi.send( po ) # send partner 18 next( po ) # prime 19 po.send( pi ) # send partner 20 21 s = Scheduler(); 22 next( s ) # prime 2 23 try: 3 yield from ping(); 4 yield from pong(); 24 s.send( pi ) # start cycle 5 25 except StopIteration: 6 print( "Scheduler stop" ) 7 8 9 def pong(): 10 print( "pong" ) 11 for i in range( 10 ): 12 13 yield from ping() 14 print( "stop pong" ) 15 16 def ping(): 17 global i 18 print( "ping" ) 19 i += 1 20 if i < 5: 21 yield from pong() 22 print( "stop ping" ) 23 24 p = ping() 25 try: 26 next( p ) 27 except StopIteration: 28 print( "stop" ) 26 print( "scheduler stop" ) 27 print( "stop" ) 29 28 30 29 # Local Variables: # 31 30 # tab-width: 4 # 32 # compile-command: "python3.5 pingpong.py" #31 # compile-command: "python3.5 Pingpong.py" # 33 32 # End: # -
doc/papers/concurrency/examples/ProdCons.cfa
r0087e0e r1e5d0f0c 23 23 sout | "prod stops"; 24 24 } 25 int payment( Prod & prod, int m oney) {26 prod.money = money;25 int payment( Prod & prod, int m ) with(prod) { 26 money = m; 27 27 resume( prod ); // main 1st time, then 28 return prod.receipt;// prod in delivery28 return receipt; // prod in delivery 29 29 } 30 30 void start( Prod & prod, int N, Cons &c ) {
Note: See TracChangeset
for help on using the changeset viewer.