source: tests/concurrency/actors/pingpong.cfa @ bfa7bf0

#include <fstream.hfa>
#include <stdlib.hfa>
#include <string.h>
#include <stdio.h>
#include <mutex_stmt.hfa>
#include <actor.hfa>

struct ping { inline actor; };
struct pong { inline actor; };

struct p_msg {
        inline message;
        size_t count;
};
//static inline void ?{}( p_msg & this ) { ((message &)this){}; this.count = 0; }
static inline void ?{}( p_msg & this ) { this.count = 0; }

ping * pi;
pong * po;
size_t times = 100000;

allocation receive( ping & receiver, p_msg & msg ) {
        msg.count++;
        if ( msg.count > times ) return Finished;

        allocation retval = Nodelete;
        if ( msg.count == times ) retval = Finished;
        *po | msg;
        return retval;
}

allocation receive( pong & receiver, p_msg & msg ) {
        msg.count++;
        if ( msg.count > times ) return Finished;
        
        allocation retval = Nodelete;
        if ( msg.count == times ) retval = Finished;
        *pi | msg;
        return retval;
}

size_t Processors = 2;

int main( int argc, char * argv[] ) {
        sout | "start";

        processor p[Processors - 1];

        start_actor_system( Processors ); // test passing number of processors
        ping pi_actor;
        pong po_actor;
        po = &po_actor;
        pi = &pi_actor;
        p_msg m;
        pi_actor | m;
        stop_actor_system();

        sout | "end";
}