tests/futex_timeout.c

   1 #include <stdio.h>
   2 #include <stdlib.h>
   3 #include <parlib/parlib.h>
   4 #include <parlib/vcore.h>
   5 #include <futex.h>
   6 #include <pthread.h>
   7
   8 #define NUM_THREADS 10
   9 pthread_t thandlers[NUM_THREADS];
  10
  11 void *handler(void *arg) {
  12         int id = pthread_self()->id;
  13         int var = 0;
  14     struct timespec timeout = {
  15                 .tv_sec = id,
  16                 .tv_nsec = 0
  17         };
  18         printf("Begin thread: %d\n", id);
  19     futex(&var, FUTEX_WAIT, 0, &timeout, NULL, 0);
  20         printf("End thread: %d\n", id);
  21         return 0;
  22 }
  23
  24 int main(int argc, char **argv)
  25 {
  26         for (int i=0; i<NUM_THREADS; i++) {
  27                 pthread_create(&thandlers[i], NULL, &handler, NULL);
  28         }
  29         for (int i=0; i<NUM_THREADS; i++) {
  30                 pthread_join(thandlers[i], NULL);
  31         }
  32         return 0;
  33 }