diff options
Diffstat (limited to '04_exercise/threadpool.c')
| -rw-r--r-- | 04_exercise/threadpool.c | 19 |
1 files changed, 16 insertions, 3 deletions
diff --git a/04_exercise/threadpool.c b/04_exercise/threadpool.c index 510e83e..93b8807 100644 --- a/04_exercise/threadpool.c +++ b/04_exercise/threadpool.c @@ -7,6 +7,7 @@ #include <stdio.h> #include <stdlib.h> #include <unistd.h> +#include <stdatomic.h> #define MAX_FUTURES 2048 typedef struct Thread { @@ -28,7 +29,7 @@ ThreadPool threadPool; /* TODO: interne Hilfsfunktionen hinzufügen */ void * poolWorkerFunc(void * v_index) { size_t index = * (size_t *) v_index; - printf("Thread %zu started", index); + printf("Thread %zu started \n", index); return NULL; } @@ -51,8 +52,7 @@ int tpInit(size_t size) { void tpRelease(void) { for (size_t i = 0; i < threadPool.size; ++i) { if (pthread_cancel(threadPool.threads[i].pthread) != 0) { - perror("Thread doesn't exist anymore"); - exit(-1); + fprintf(stderr, "The thread %zu had already exited. \n", threadPool.threads[i].index); } } for (size_t i = 0; i < threadPool.size; ++i) { @@ -66,6 +66,19 @@ void tpRelease(void) { void tpAsync(Future *future) { alPush(&threadPool.al, (void *) future); + char expected = FUT_WAITING; + if(!atomic_compare_exchange_strong(&future->status, &expected, FUT_IN_PROGRESS )) { + perror("The future has been scheduled before"); + exit(-1); + } + + future->fn(future); + expected = FUT_IN_PROGRESS; + if(!atomic_compare_exchange_strong(&future->status, &expected, FUT_IN_PROGRESS)) { + perror("The future got marked as done by another thread"); + exit(-1); + } + } void tpAwait(Future *future) { |