Rev 2050 | Rev 2071 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed
| Rev 2050 | Rev 2053 | ||
|---|---|---|---|
| Line 38... | Line 38... | ||
| 38 | 38 | ||
| 39 | #define THREADS 5 |
39 | #define THREADS 5 |
| 40 | 40 | ||
| 41 | static atomic_t finish; |
41 | static atomic_t finish; |
| 42 | static atomic_t threads_finished; |
42 | static atomic_t threads_finished; |
| - | 43 | static bool sh_quiet; |
|
| 43 | 44 | ||
| 44 | static void threadtest(void *data) |
45 | static void threadtest(void *data) |
| 45 | { |
46 | { |
| 46 | thread_detach(THREAD); |
47 | thread_detach(THREAD); |
| 47 | 48 | ||
| 48 | while (atomic_get(&finish)) { |
49 | while (atomic_get(&finish)) { |
| - | 50 | if (!sh_quiet) |
|
| 49 | printf("%d\n", (int) (THREAD->tid)); |
51 | printf("%d\n", (int) (THREAD->tid)); |
| 50 | thread_usleep(100); |
52 | thread_usleep(100); |
| 51 | } |
53 | } |
| 52 | atomic_inc(&threads_finished); |
54 | atomic_inc(&threads_finished); |
| 53 | } |
55 | } |
| 54 | 56 | ||
| 55 | char * test_thread1(bool quiet) |
57 | char * test_thread1(bool quiet) |
| 56 | { |
58 | { |
| 57 | unsigned int i, total = 0; |
59 | unsigned int i, total = 0; |
| - | 60 | sh_quiet = quiet; |
|
| 58 | 61 | ||
| 59 | atomic_set(&finish, 1); |
62 | atomic_set(&finish, 1); |
| 60 | atomic_set(&threads_finished, 0); |
63 | atomic_set(&threads_finished, 0); |
| 61 | 64 | ||
| 62 | for (i = 0; i < THREADS; i++) { |
65 | for (i = 0; i < THREADS; i++) { |
| 63 | thread_t *t; |
66 | thread_t *t; |
| 64 | if (!(t = thread_create(threadtest, NULL, TASK, 0, "threadtest", false))) { |
67 | if (!(t = thread_create(threadtest, NULL, TASK, 0, "threadtest", false))) { |
| - | 68 | if (!quiet) |
|
| 65 | printf("Could not create thread %d\n", i); |
69 | printf("Could not create thread %d\n", i); |
| 66 | break; |
70 | break; |
| 67 | } |
71 | } |
| 68 | thread_ready(t); |
72 | thread_ready(t); |
| 69 | total++; |
73 | total++; |
| 70 | } |
74 | } |
| 71 | 75 | ||
| - | 76 | if (!quiet) |
|
| 72 | printf("Running threads for 10 seconds...\n"); |
77 | printf("Running threads for 10 seconds...\n"); |
| 73 | thread_sleep(10); |
78 | thread_sleep(10); |
| 74 | 79 | ||
| 75 | atomic_set(&finish, 0); |
80 | atomic_set(&finish, 0); |
| 76 | while (atomic_get(&threads_finished) < total) { |
81 | while (atomic_get(&threads_finished) < total) { |
| - | 82 | if (!quiet) |
|
| 77 | printf("Threads left: %d\n", total - atomic_get(&threads_finished)); |
83 | printf("Threads left: %d\n", total - atomic_get(&threads_finished)); |
| 78 | thread_sleep(1); |
84 | thread_sleep(1); |
| 79 | } |
85 | } |
| 80 | 86 | ||
| 81 | return NULL; |
87 | return NULL; |
| 82 | } |
88 | } |