source: tests/concurrency/futures/future_except.cfa

#include <fstream.hfa>
#include <thread.hfa>
#include <locks.hfa>
#include <future.hfa>

ExceptionDecl(E);

semaphore L;

thread A{ future( int ) & F; };
void ?{}( A & this, future( int ) & F) {
        &this.F = &F;
}
thread B{ future( int ) & F; };
void ?{}( B & this, future( int ) & F) {
        &this.F = &F;
}

void main( A & this ) {
        sout | "A: loading F with E";
        this.F( ExceptionPtr( ExceptionInst( E ) ) );
        P( L );
        reset( this.F );
}

void main( B & this ) {
        try {
                waituntil( this.F ) {
                        enable_ehm();
                        int f = this.F();
                        checked_poll();
                        sout|"B: should not be printed! " | f;
                        disable_ehm();
                }
        } catch( E * ) {
                sout | "B: caught E";
                V( L );
        }
}

int main(){
        future( int ) F;
        processor p;
        for( 10 ) {
                L{0};
                B b={ F };
                A a={ F };
        }
        return 0;
}