source:
tests/concurrency/waitfor/simple.cfa
@
f90c092
Last change on this file since f90c092 was c26bea2a, checked in by , 17 months ago | |
---|---|
|
|
File size: 1.5 KB |
Rev | Line | |
---|---|---|
[73abe95] | 1 | #include <fstream.hfa> |
2 | #include <kernel.hfa> | |
3 | #include <monitor.hfa> | |
4 | #include <stdlib.hfa> | |
5 | #include <thread.hfa> | |
[97e3296] | 6 | |
7 | #include <time.h> | |
8 | ||
[90c4df0] | 9 | static const unsigned long N = 500ul; |
[97e3296] | 10 | |
11 | #ifndef PREEMPTION_RATE | |
[8ad6533] | 12 | #define PREEMPTION_RATE 10`ms |
[97e3296] | 13 | #endif |
14 | ||
[8ad6533] | 15 | Duration default_preemption() { |
[97e3296] | 16 | return PREEMPTION_RATE; |
17 | } | |
18 | ||
19 | monitor global_t {}; | |
20 | ||
21 | global_t globalA; | |
22 | ||
23 | thread Acceptor {}; | |
24 | thread Acceptee {}; | |
25 | ||
[90c4df0] | 26 | volatile bool done; |
27 | ||
[97e3296] | 28 | //---------------------------------------------------------------------------------------------------- |
29 | // Acceptor | |
30 | void do_notify( global_t * mutex a ); | |
31 | ||
32 | void do_wait( global_t * mutex a ) { | |
[200fcb3] | 33 | sout | "Waiting to accept"; |
[6c7b1e7] | 34 | yield( random( 10 ) ); |
[90c4df0] | 35 | |
[200fcb3] | 36 | sout | "Accepting"; |
[97e3296] | 37 | |
38 | __acceptable_t acceptable; | |
[90c4df0] | 39 | acceptable.func = (fptr_t)do_notify; |
[97e3296] | 40 | acceptable.count = 1; |
41 | acceptable.monitors = &a; | |
42 | ||
[310e5b7] | 43 | __waitfor_internal( 1, &acceptable ); |
[97e3296] | 44 | |
[200fcb3] | 45 | sout | "Accepted"; |
[6c7b1e7] | 46 | yield( random( 10 ) ); |
[97e3296] | 47 | } |
48 | ||
49 | void main( Acceptor* this ) { | |
[90c4df0] | 50 | for( int i = 0; i < N; i++ ) { |
51 | do_wait( &globalA ); | |
[200fcb3] | 52 | sout | i; |
[90c4df0] | 53 | } |
54 | ||
55 | done = true; | |
[97e3296] | 56 | } |
57 | ||
58 | //---------------------------------------------------------------------------------------------------- | |
59 | // Acceptee | |
60 | void do_notify( global_t * mutex a ) { | |
[90c4df0] | 61 | |
[97e3296] | 62 | } |
63 | ||
64 | void main( Acceptee* this ) { | |
[90c4df0] | 65 | while( !done ) { |
[6c7b1e7] | 66 | yield( random( 10 ) ); |
[90c4df0] | 67 | do_notify( &globalA ); |
[6c7b1e7] | 68 | yield( random( 10 ) ); |
[90c4df0] | 69 | } |
[97e3296] | 70 | } |
71 | ||
72 | //---------------------------------------------------------------------------------------------------- | |
73 | // Main | |
74 | int main(int argc, char* argv[]) { | |
[90c4df0] | 75 | done = false; |
[54aba8d] | 76 | srandom( time( NULL ) ); |
[90c4df0] | 77 | printf("%p\n", &globalA); |
[200fcb3] | 78 | sout | "Starting"; |
[97e3296] | 79 | { |
80 | Acceptor r; | |
[90c4df0] | 81 | Acceptee e[13]; |
82 | ||
[97e3296] | 83 | } |
[200fcb3] | 84 | sout | "Done"; |
[6c7b1e7] | 85 | } |
Note: See TracBrowser
for help on using the repository browser.