test/threads/broadcastcondition.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     int i;
  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 threads\n");
  45     for (i = 0; i < 5; i++)
  46         CreateThread(waiter_thread, (void *) td);
  47
  48     printf("sleeping for 2s\n");
  49     Delay(100);
  50
  51     printf("signalling condition\n");
  52     SignalCondition(td->cond);
  53
  54     printf("sleeping for 2s\n");
  55     Delay(100);
  56
  57     printf("broadcasting condition\n");
  58     BroadcastCondition(td->cond);
  59
  60     printf("waiting for threads to exit\n");
  61     WaitAllThreads();
  62
  63     printf("destroying the condition\n");
  64     DestroyCondition(td->cond);
  65
  66     printf("destroying the mutex\n");
  67     DestroyMutex(td->mutex);
  68
  69     FreeMem(td, sizeof(struct thread_data));
  70
  71     printf("all done\n");
  72
  73     return 0;
  74 }