test/threads/signalcondition.c

   1 #include <exec/memory.h>
   2 #include <libraries/thread.h>
   3 #include <proto/exec.h>
   4 #include <proto/dos.h>
   5 #include <proto/thread.h>
   6 #include <stdio.h>
   7 #include <stdint.h>
   8
   9 struct thread_data {
  10     void *mutex;
  11     void *cond;
  12 };
  13
  14 void *waiter_thread(void *data) {
  15     struct thread_data *td = (struct thread_data *) data;
  16     uint32_t id = CurrentThread();
  17
  18     printf("[%d] starting, locking the mutex\n", id);
  19     LockMutex(td->mutex);
  20
  21     printf("[%d] waiting on the condition\n", id);
  22     WaitCondition(td->cond, td->mutex);
  23
  24     printf("[%d] condition signalled, unlocking the mutex\n", id);
  25     UnlockMutex(td->mutex);
  26
  27     printf("[%d] all done, exiting\n", id);
  28
  29     return NULL;
  30 }
  31
  32 int main (int argc, char **argv) {
  33     struct thread_data *td;
  34     uint32_t tw;
  35
  36     td = AllocMem(sizeof(struct thread_data), MEMF_PUBLIC | MEMF_CLEAR);
  37
  38     printf("creating mutex\n");
  39     td->mutex = CreateMutex();
  40
  41     printf("creating condition\n");
  42     td->cond = CreateCondition();
  43
  44     printf("starting waiter thread\n");
  45     tw = CreateThread(waiter_thread, (void *) td);
  46
  47     printf("sleeping for 2s\n");
  48     Delay(100);
  49
  50     printf("signalling condition\n");
  51     SignalCondition(td->cond);
  52
  53     printf("waiting for waiter thread\n");
  54     WaitThread(tw, NULL);
  55
  56     printf("destroying the condition\n");
  57     DestroyCondition(td->cond);
  58
  59     printf("destroying the mutex\n");
  60     DestroyMutex(td->mutex);
  61
  62     FreeMem(td, sizeof(struct thread_data));
  63
  64     printf("all done\n");
  65
  66     return 0;
  67 }