source: tests/concurrency/unified_locking/pthread_locks.cfa @ 09bdf2d

#include <stdio.h>
#include <locks.hfa>
#include <stdlib.hfa>
#include <thread.hfa>
#include <time.h>
#include <stdlib.hfa>

const unsigned int num_times = 50;

simple_owner_lock l;
pthread_cond_var( simple_owner_lock ) c;

owner_lock l2;
condition_variable( owner_lock ) c2;

volatile int counter = 0;

thread Wait_Signal_1 {};

void main( Wait_Signal_1 & this ) {
        for (unsigned int i = 0; i < num_times; i++) {
                lock(l);
                if(empty(c) && i != num_times - 1) {
                        wait(c,l);
                }else{
                        notify_one(c);
                }
                unlock(l);
        }
}

thread Wait_3_Signal_3 {};

void main( Wait_3_Signal_3 & this ) {
        for (unsigned int i = 0; i < num_times; i++) {
                lock(l);
        counter++;
                if(counter == 4 || i == num_times - 1) {
            counter = 0;
                        notify_all(c);
                }else{
                        wait(c,l);
                }
                unlock(l);
        }
}

thread Rec_Lock_Wait_Signal_1 {};

void main( Rec_Lock_Wait_Signal_1 & this ) {
        for (unsigned int i = 0; i < num_times; i++) {
                lock(l);
                lock(l);
                lock(l);
                if(empty(c) && i != num_times - 1) {
                        wait(c,l);
                }else{
                        notify_one(c);
                }
                unlock(l);
                unlock(l);
                unlock(l);
        }
}

thread Wait_Time_Signal_1 {};

void main( Wait_Time_Signal_1 & this ) {
        for (unsigned int i = 0; i < num_times; i++) {
                lock(l);
                if(empty(c) || random(10) >= 9 ) {
                        timespec t;
                        clock_gettime(CLOCK_REALTIME, &t);
                        timespec waitTime{0,1};
                        bool woken = wait(c,l, t + waitTime);
                }else{
                        notify_one(c);
                }
                unlock(l);
        }
}

int main() {
        processor p[1];
        printf("Start Test 1: lock and condition variable single wait/notify\n");
        {
                Wait_Signal_1 t1[2];
        }
        printf("Done Test 1\n");

        printf("Start Test 2: lock and condition variable 3 wait/notify all\n");
        {
                Wait_3_Signal_3 t1[4];
        }
        printf("Done Test 2\n");

        printf("Start Test 3: lock and condition variable multiple acquire and wait/notify\n");
        {
                Rec_Lock_Wait_Signal_1 t1[2];
        }
        printf("Done Test 3\n");

        printf("Start Test 4: lock and condition variable single timed wait/notify\n");
        {
                Wait_Time_Signal_1 t1[2];
        }
        printf("Done Test 4\n");
}