Changeset 96348adc in mainline for kernel/test/thread/thread1.c

Timestamp:

2006-12-12T17:24:58Z (17 years ago)

Author:

Martin Decky <martin@…>

Branches:

lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export

Children:

7e13972

Parents:

34db7fa

Message:

cleanup tests

File:

• kernel/test/thread/thread1.c (modified) (1 diff)

kernel/test/thread/thread1.c

@@ -40 +40 @@
 #define THREADS 5
 
+static atomic_t finish;
+static atomic_t threads_finished;
+
 static void threadtest(void *data)
 {
-
         thread_detach(THREAD);  
 
-        while (1)
-                printf("%d\n",(int)(THREAD->tid));
+        while (atomic_get(&finish)) {
+                printf("%d\n", (int) (THREAD->tid));
+                thread_usleep(100);
+        }
+        atomic_inc(&threads_finished);
 }
 
-void test_thread1(void)
+char * test_thread1(void)
 {
-        thread_t *t;
-        int i;
+        unsigned int i, total = 0;
+        
+        atomic_set(&finish, 1);
+        atomic_set(&threads_finished, 0);
 
-        for (i=0; i<THREADS; i++) {  
-                if (!(t = thread_create(threadtest, NULL, TASK, 0, "threadtest")))
-                        panic("could not create thread\n");
+        for (i = 0; i < THREADS; i++) {  
+                thread_t *t;
+                if (!(t = thread_create(threadtest, NULL, TASK, 0, "threadtest"))) {
+                        printf("Could not create thread %d\n", i);
+                        break;
+                }
                 thread_ready(t);
+                total++;
         }
-        printf("ok\n");
+        
+        printf("Running threads for 10 seconds...\n");
+        thread_sleep(10);
+        
+        atomic_set(&finish, 0);
+        while (atomic_get(&threads_finished) < total) {
+                printf("Threads left: %d\n", total - atomic_get(&threads_finished));
+                thread_sleep(1);
+        }
+        
+        return NULL;
 }