source: src/tests/prodcons.c@ 93fe7141

// 
// Cforall Version 1.0.0 Copyright (C) 2017 University of Waterloo
//
// The contents of this file are covered under the licence agreement in the
// file "LICENCE" distributed with Cforall.
// 
// prodcons.c -- 
// 
// Author           : Peter A. Buhr
// Created On       : Mon Sep 18 12:23:39 2017
// Last Modified By : Peter A. Buhr
// Last Modified On : Wed Sep 20 17:03:28 2017
// Update Count     : 40
// 

#include <fstream>
#include <coroutine>
#include <stdlib>                                                                               // rand48
#include <unistd.h>                                                                             // getpid

coroutine Cons;                                                                                 // forward
int delivery( Cons & cons, int p1, int p2 );
void stop( Cons & cons );

coroutine Prod {
        Cons *c;
        int N, money, receipt;
};
void main( Prod & prod ) {                                                              // starter ::main
        // 1st resume starts here
        for ( int i = 0; i < prod.N; i += 1 ) {
                int p1 = (unsigned int)rand48() % 100;                  // non-negative
                int p2 = (unsigned int)rand48() % 100;
                sout | p1 | " " | p2 | endl;
                int status = delivery( *prod.c, p1, p2 );
                sout | " $" | prod.money | endl;
                sout | status | endl;
                prod.receipt += 1;
        }
        stop( *prod.c );
        sout | "prod stops" | endl;
}
int payment( Prod & prod, int money ) {
        prod.money = money;
        resume( prod );                                                                         // main 1st time, then
        return prod.receipt;                                                            // prod in delivery
}
void start( Prod & prod, int N, Cons &c ) {
        prod.N = N;
        prod.c = &c;
        prod.receipt = 0;
        resume( prod );                                                                         // activate main
}

coroutine Cons {
        Prod * p;
        int p1, p2, status;
        bool done;
};
void ?{}( Cons & cons, Prod & p ) {
        cons.p = &p;
        cons.status = 0;
        cons.done = false;
}
void ^?{}( Cons & cons ) {}
void main( Cons & cons ) {                                                              // starter prod
        // 1st resume starts here
        int money = 1, receipt;
        for ( ; ! cons.done; ) {
                sout | cons.p1 | " " | cons.p2 | endl;
                sout | " $" | money | endl;
                cons.status += 1;
                receipt = payment( *cons.p, money );
                sout | " #" | receipt | endl;
                money += 1;
        }
        sout | "cons stops" | endl;
}
int delivery( Cons & cons, int p1, int p2 ) {
        cons.p1 = p1;
        cons.p2 = p2;
        resume( cons );                                                                         // main 1st time, then
        return cons.status;                                                                     // cons in payment
}
void stop( Cons & cons ) {
        cons.done = true;
        resume( cons );                                                                         // activate payment
}
int main() {
        Prod prod;
        Cons cons = { prod };
        rand48seed( /* getpid() */ 103 );                                       // fixed seed for testing
        start( prod, 5, cons );
        sout | "main stops" | endl;
}

// Local Variables: //
// tab-width: 4 //
// compile-command: "cfa prodcons.c" //
// End: //