source: src/tests/concurrent/waitfor/simple.c @ 70969f8

ADTaaron-thesisarm-ehast-experimentalcleanup-dtorsdeferred_resndemanglerenumforall-pointer-decayjacob/cs343-translationjenkins-sandboxnew-astnew-ast-unique-exprnew-envno_listpersistent-indexerpthread-emulationqualifiedEnumresolv-newwith_gc
Last change on this file since 70969f8 was 54aba8d, checked in by Peter A. Buhr <pabuhr@…>, 7 years ago

change name of random_seed to srandom, and make all random calls through rand48

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