source: tests/concurrency/futures/typed.cfa @ f5dbc8d

#include <thread.hfa>
#include <future.hfa>
enum {NFUTURES = 10};

thread Server {
        int cnt;
        single_future(int) * requests[NFUTURES];
};

void ?{}( Server & this ) {
        this.cnt = 0;
        for(i; NFUTURES) {
                this.requests[i] = 0p;
        }
}

void ^?{}( Server & mutex this ) {
        assert(this.cnt == 0);
        for(i; NFUTURES) {
                this.requests[i] = 0p;
        }
}

void process( Server & this, int i ) {
        if( this.requests[i] == 0p ) return;
        single_future(int) * f = this.requests[i];
        this.requests[i] = 0p;
        this.cnt--;
        fulfil( *f , i);
}

void call( Server & mutex this, single_future(int) & f ) {
        for(i; NFUTURES) {
                if( this.requests[i] == 0p ) {
                        this.requests[i] = &f;
                        this.cnt++;
                        return;
                }
        }
        abort("Monitor Error");
}

void main( Server & this ) {
        unsigned i = 0;
        for() {
                waitfor( ^?{} : this ) {
                        break;
                }
                or when( this.cnt < NFUTURES ) waitfor( call: this ) {}
                or else {
                        process( this, i % NFUTURES );
                        i++;
                }
        }

        for(i; NFUTURES) {
                process( this, i );
        }
}

Server * the_server;
thread Worker {};

void thrash(void) {
        volatile int locals[250];
        for(i; 250) {
                locals[i] = 0xdeadbeef;
        }
}

void work(void) {
        single_future(int) mine;
        call( *the_server, mine );
        wait( mine );
}

void main( Worker & ) {
        for(150) {
                thrash();
                work();
                thrash();
        }
}

int main() {
        printf( "start\n" );                            // non-empty .expect file
        processor procs[2];
        {
                Server server;
                the_server = &server;
                {
                        Worker workers[17];
                }
        }
        printf( "done\n" );                             // non-empty .expect file

}