source: tests/concurrency/channels/daisy_chain.cfa @ cbbfba9

#include <locks.hfa>
#include <fstream.hfa>
#include <stdio.h>
#include <channel.hfa>
#include <thread.hfa>
#include <time.hfa>
#include <string.h>

size_t total_operations = 0;
ssize_t Processors = 1, Tasks = 4;                                              // must be signed

owner_lock o;

typedef channel( int ) Channel;

Channel * chain;

thread Task {};
void main(Task & this) {
    size_t runs = 0;
    int token = 0;
    try{
        for ( ;; ) {
            token << *chain;
            *chain << token;
            runs++;
        }
    } catch ( channel_closed * e ) {}
    lock( o );
    total_operations += runs;
    unlock( o );
}


int main( int argc, char * argv[] ) {
    switch ( argc ) {
          case 3:
                if ( strcmp( argv[2], "d" ) != 0 ) {                    // default ?
                        Tasks = ato( argv[2] );
            if ( Tasks < 1 ) fallthru default;
                } // if
          case 2:
                if ( strcmp( argv[1], "d" ) != 0 ) {                    // default ?
                        Processors = ato( argv[1] );
                        if ( Processors < 1 ) fallthru default;
                } // if
          case 1:                                                                                       // use defaults
                break;
          default:
                exit | "Usage: " | argv[0]
             | " [ processors (> 0) | 'd' (default " | Processors
                         | ") ] [ channel size (>= 0) | 'd' (default " | Tasks
                         | ") ]" ;
        } // switch
    processor proc[Processors - 1];

    sout | "start";
    Channel chainChan{ 1 };

    chainChan << ((int)0);

    chain = &chainChan;    
    {
        Task t[Tasks];
        sleep(10`s);
        close( chainChan );
    }
    
    // sout | total_operations;
    sout | "done";
}