diff options
| -rw-r--r-- | ddekit_test/main.c | 77 |
1 files changed, 76 insertions, 1 deletions
diff --git a/ddekit_test/main.c b/ddekit_test/main.c index 221e5019..bb9ccf83 100644 --- a/ddekit_test/main.c +++ b/ddekit_test/main.c @@ -1,6 +1,8 @@ #include <mach.h> #include "dde.h" +#include "ddekit/condvar.h" +#include "ddekit/semaphore.h" #include "ddekit/thread.h" #include "ddekit/printf.h" #include "ddekit/assert.h" @@ -253,6 +255,78 @@ static void memory_test(void) } } +ddekit_sem_t *sem; +ddekit_condvar_t *cond; +ddekit_lock_t cond_lock; +int status; + +static void thread_func (void *arg) +{ + ddekit_lock_t lock = arg; + int ret; + + ddekit_printf ("%s thread starts at %d\n", + ddekit_thread_get_name (ddekit_thread_myself ()), time (NULL)); + ddekit_lock_lock (&lock); + ddekit_thread_sleep (&lock); + ddekit_lock_unlock (&lock); + ddekit_printf ("%s thread wakes up at %d\n", + ddekit_thread_get_name (ddekit_thread_myself ()), time (NULL)); + + ret = ddekit_sem_down_timed (sem, 1000); + ddekit_printf ("%s thread enter a semaphore at %d, timeout: %d\n", + ddekit_thread_get_name (ddekit_thread_myself ()), + time (NULL), ret != 0); + + ddekit_printf ("%s thread waits for signal at %d\n", + ddekit_thread_get_name (ddekit_thread_myself ()), time (NULL)); + ddekit_lock_lock (&cond_lock); + while (!status) + ddekit_condvar_wait (cond, &cond_lock); + ddekit_lock_unlock (&cond_lock); + ddekit_printf ("%s thread wakes up at %d\n", + ddekit_thread_get_name (ddekit_thread_myself ()), time (NULL)); +} + +static void thread_test () +{ + ddekit_thread_t *thread1 = NULL; + ddekit_thread_t *thread2 = NULL; + ddekit_lock_t lock1; + ddekit_lock_t lock2; + + sem = ddekit_sem_init (0); + cond = ddekit_condvar_init (); + status = 0; + ddekit_lock_init (&cond_lock); + ddekit_lock_init (&lock1); + ddekit_lock_init (&lock2); + + thread1 = ddekit_thread_create (thread_func, lock1, "test1"); + thread2 = ddekit_thread_create (thread_func, lock2, "test2"); + + sleep (3); + ddekit_lock_lock (&lock1); + ddekit_thread_wakeup (thread1); + ddekit_lock_unlock (&lock1); + + ddekit_lock_lock (&lock2); + ddekit_thread_wakeup (thread2); + ddekit_lock_unlock (&lock2); + sleep (2); + + ddekit_sem_up (sem); + ddekit_sem_up (sem); + sleep (1); + + ddekit_printf ("main thread wakes up the other two at %d\n", time (NULL)); + ddekit_lock_lock (&cond_lock); + status = 1; + ddekit_condvar_broadcast (cond); + ddekit_lock_unlock (&cond_lock); + sleep (1); +} + int main(int argc, char **argv) { @@ -261,7 +335,8 @@ int main(int argc, char **argv) ddekit_init(); if (0) memory_test(); - if (1) timer_test(); + if (0) timer_test(); + if (1) thread_test(); return 0; } |