Changes in kernel/test/thread/thread1.c [bab75df6:0f4f1b2] in mainline
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
kernel/test/thread/thread1.c
rbab75df6 r0f4f1b2 30 30 #include <test.h> 31 31 #include <atomic.h> 32 #include <stdbool.h> 32 33 #include <proc/thread.h> 33 34 … … 36 37 #define THREADS 5 37 38 38 static atomic_t finish; 39 static atomic_t threads_finished; 39 static atomic_bool finish; 40 40 41 41 static void threadtest(void *data) 42 42 { 43 thread_detach(THREAD);44 45 43 while (atomic_load(&finish)) { 46 44 TPRINTF("%" PRIu64 " ", THREAD->tid); 47 45 thread_usleep(100000); 48 46 } 49 atomic_inc(&threads_finished);50 47 } 51 48 52 49 const char *test_thread1(void) 53 50 { 54 unsigned int i; 55 size_t total = 0; 51 atomic_store(&finish, true); 56 52 57 atomic_store(&finish, 1); 58 atomic_store(&threads_finished, 0); 53 thread_t *threads[THREADS] = { }; 59 54 60 for (i = 0; i < THREADS; i++) { 61 thread_t *t; 62 if (!(t = thread_create(threadtest, NULL, TASK, 63 THREAD_FLAG_NONE, "threadtest"))) { 55 for (int i = 0; i < THREADS; i++) { 56 threads[i] = thread_create(threadtest, NULL, 57 TASK, THREAD_FLAG_NONE, "threadtest"); 58 59 if (threads[i]) { 60 thread_start(threads[i]); 61 } else { 64 62 TPRINTF("Could not create thread %d\n", i); 65 63 break; 66 64 } 67 thread_ready(t);68 total++;69 65 } 70 66 … … 72 68 thread_sleep(10); 73 69 74 atomic_store(&finish, 0); 75 while (atomic_load(&threads_finished) < total) { 76 TPRINTF("Threads left: %zu\n", total - atomic_load(&threads_finished)); 77 thread_sleep(1); 70 atomic_store(&finish, false); 71 72 for (int i = 0; i < THREADS; i++) { 73 if (threads[i] != NULL) 74 thread_join(threads[i]); 75 76 TPRINTF("Threads left: %d\n", THREADS - i - 1); 78 77 } 79 78
Note:
See TracChangeset
for help on using the changeset viewer.