From 0183ce2e23134bd1805d481daa56d174865f7cb9 Mon Sep 17 00:00:00 2001 From: Santo Cariotti Date: Tue, 23 Nov 2021 21:33:09 +0100 Subject: tsdwl: add exam (thread blocks (?) ) --- Year_3/TSDWL/ex_20131219/thread.c | 67 +++++++++++++++++++++++++++++++++++++++ 1 file changed, 67 insertions(+) create mode 100644 Year_3/TSDWL/ex_20131219/thread.c diff --git a/Year_3/TSDWL/ex_20131219/thread.c b/Year_3/TSDWL/ex_20131219/thread.c new file mode 100644 index 0000000..e46d05b --- /dev/null +++ b/Year_3/TSDWL/ex_20131219/thread.c @@ -0,0 +1,67 @@ +#include +#include +#include +#include + +int m; +pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER; +pthread_cond_t cond; + +void* +fn_t1(void* arg) +{ + int xrand; + + while (1) { + pthread_mutex_lock(&mutex); + if (m >= 1 && m <= 5) { + xrand = (rand() % 10) + 1; + printf("Thread 1: (%d, %d)\n", m, xrand); + m = xrand; + pthread_cond_broadcast(&cond); + pthread_mutex_unlock(&mutex); + } else { + pthread_mutex_unlock(&mutex); + pthread_cond_wait(&cond, &mutex); + } + } + + pthread_exit(NULL); +} + +void* +fn_t2(void* arg) +{ + int xrand; + + while (1) { + pthread_mutex_lock(&mutex); + if (m >= 6 && m <= 10) { + xrand = (rand() % 10) + 1; + printf("Thread 2: (%d, %d)\n", m, xrand); + m = xrand; + pthread_cond_broadcast(&cond); + pthread_mutex_unlock(&mutex); + } else { + pthread_mutex_unlock(&mutex); + pthread_cond_wait(&cond, &mutex); + } + } + + pthread_exit(NULL); +} + +int +main() +{ + pthread_t th[2]; + srand(time(NULL)); + m = (rand() % 10) + 1; + + pthread_create(&th[0], NULL, (void*)&fn_t1, NULL); + pthread_create(&th[1], NULL, (void*)&fn_t2, NULL); + pthread_join(th[0], NULL); + pthread_join(th[1], NULL); + + return 0; +} -- cgit v1.2.3-18-g5258