source: doc/papers/concurrency/examples/RWMonitor.cfa @ df75fe97

ADTarm-ehast-experimentalenumforall-pointer-decayjacob/cs343-translationjenkins-sandboxnew-astnew-ast-unique-exprpthread-emulationqualifiedEnum
Last change on this file since df75fe97 was bd12159, checked in by Peter A. Buhr <pabuhr@…>, 5 years ago

complete draft for second version of concurrency paper

  • Property mode set to 100644
File size: 1.6 KB
Line 
1#include <fstream.hfa>
2#include <thread.hfa>
3
4volatile int SharedRW = 0;                                                              // shared variable to test readers and writers
5
6monitor ReadersWriter {
7        int rcnt, wcnt;                                                                         // number of readers/writer using resource
8};
9void EndRead( ReadersWriter & mutex rw ) with(rw) { rcnt -= 1; }
10void EndWrite( ReadersWriter & mutex rw ) with(rw) { wcnt = 0; }
11void StartRead( ReadersWriter & mutex rw ) with(rw) {
12        if ( wcnt > 0 ) waitfor( EndWrite, rw );
13        rcnt += 1;
14}
15void StartWrite( ReadersWriter & mutex rw ) with(rw) {
16        if ( wcnt > 0 ) waitfor( EndWrite, rw );
17        else while ( rcnt > 0 ) waitfor( EndRead, rw );
18        wcnt = 1;
19}
20void ?{}( ReadersWriter & rw ) with(rw) { rcnt = wcnt = 0; }
21int readers( ReadersWriter & rw ) { return rw.rcnt; }
22void Read( ReadersWriter & rw ) {
23        StartRead( rw );
24        sout | "Reader:" | active_thread() | ", shared:" | SharedRW | " with:" | readers( rw ) | " readers";
25        yield( 3 );
26        EndRead( rw );
27}
28void Write( ReadersWriter & rw ) {
29        StartWrite( rw );
30
31        SharedRW += 1;
32        sout | "Writer:" | active_thread() | ",  wrote:" | SharedRW;
33        yield( 1 );
34        EndWrite( rw );
35}
36thread Worker {
37        ReadersWriter &rw;
38};
39void ?{}( Worker & w, ReadersWriter * rw ) { &w.rw = rw; }
40void main( Worker & w ) with(w) {
41        for ( 10 ) {
42                if ( rand() % 100 < 70 ) {                                      // decide to be a reader or writer
43                        Read( rw );
44                } else {
45                        Write( rw );
46                } // if
47        } // for
48}
49int main() {
50        enum { MaxTask = 5 };
51        ReadersWriter rw;
52        Worker *workers[MaxTask];
53
54        for ( i; MaxTask ) workers[i] = new( &rw );
55        for ( i; MaxTask ) delete( workers[i] );
56        sout | "successful completion";
57} // main
58
59
60// Local Variables: //
61// tab-width: 4 //
62// compile-command: "cfa -O2 RWMonitor.cfa" //
63// End: //
Note: See TracBrowser for help on using the repository browser.