Subversion Repositories HelenOS

Rev

Rev 2022 | Rev 2029 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 2022 Rev 2028
Line 37... Line 37...
37
 
37
 
38
#include <arch.h>
38
#include <arch.h>
39
 
39
 
40
#define THREADS 5
40
#define THREADS 5
41
 
41
 
-
 
42
static atomic_t finish;
-
 
43
static atomic_t threads_finished;
-
 
44
 
42
static void threadtest(void *data)
45
static void threadtest(void *data)
43
{
46
{
44
 
-
 
45
    thread_detach(THREAD); 
47
    thread_detach(THREAD); 
46
 
48
 
47
    while (1)
49
    while (atomic_get(&finish)) {
48
        printf("%d\n",(int)(THREAD->tid));
50
        printf("%d\n", (int) (THREAD->tid));
-
 
51
        thread_usleep(100);
-
 
52
    }
-
 
53
    atomic_inc(&threads_finished);
49
}
54
}
50
 
55
 
51
void test_thread1(void)
56
char * test_thread1(void)
52
{
57
{
53
    thread_t *t;
58
    unsigned int i, total = 0;
54
    int i;
59
   
-
 
60
    atomic_set(&finish, 1);
-
 
61
    atomic_set(&threads_finished, 0);
55
 
62
 
56
    for (i=0; i<THREADS; i++) {  
63
    for (i = 0; i < THREADS; i++) {  
-
 
64
        thread_t *t;
57
        if (!(t = thread_create(threadtest, NULL, TASK, 0, "threadtest")))
65
        if (!(t = thread_create(threadtest, NULL, TASK, 0, "threadtest"))) {
58
            panic("could not create thread\n");
66
            printf("Could not create thread %d\n", i);
-
 
67
            break;
-
 
68
        }
59
        thread_ready(t);
69
        thread_ready(t);
-
 
70
        total++;
-
 
71
    }
-
 
72
   
-
 
73
    printf("Running threads for 10 seconds...\n");
-
 
74
    thread_sleep(10);
-
 
75
   
-
 
76
    atomic_set(&finish, 0);
-
 
77
    while (atomic_get(&threads_finished) < total) {
-
 
78
        printf("Threads left: %d\n", total - atomic_get(&threads_finished));
-
 
79
        thread_sleep(1);
60
    }
80
    }
-
 
81
   
61
    printf("ok\n");
82
    return NULL;
62
}
83
}