source:
src/tests/concurrent/preempt.c
@
ce28c7b
Last change on this file since ce28c7b was 12d2dc8, checked in by , 7 years ago | |
---|---|
|
|
File size: 712 bytes |
Rev | Line | |
---|---|---|
[11dbfe1] | 1 | #include <kernel> |
2 | #include <thread> | |
3 | ||
4 | #ifndef PREEMPTION_RATE | |
5 | #define PREEMPTION_RATE 10_000ul | |
6 | #endif | |
7 | ||
8 | unsigned int default_preemption() { | |
9 | return PREEMPTION_RATE; | |
10 | } | |
11 | ||
12 | static volatile int counter = 0; | |
13 | ||
[0322865c] | 14 | thread worker_t { |
[11dbfe1] | 15 | int value; |
16 | }; | |
17 | ||
[2afec66] | 18 | void ?{}( worker_t & this, int value ) { |
19 | this.value = value; | |
[11dbfe1] | 20 | } |
21 | ||
[83a071f9] | 22 | void main(worker_t & this) { |
[11dbfe1] | 23 | while(counter < 1000) { |
[83a071f9] | 24 | if( (counter % 7) == this.value ) { |
[11dbfe1] | 25 | int next = __atomic_add_fetch_4(&counter, 1, __ATOMIC_SEQ_CST); |
[12d2dc8] | 26 | if( (next % 100) == 0 ) printf("%d\n", (int)next); |
[11dbfe1] | 27 | } |
28 | } | |
29 | } | |
30 | ||
31 | int main(int argc, char* argv[]) { | |
32 | processor p; | |
33 | { | |
[0322865c] | 34 | worker_t w0 = 0; |
35 | worker_t w1 = 1; | |
36 | worker_t w2 = 2; | |
37 | worker_t w3 = 3; | |
38 | worker_t w4 = 4; | |
39 | worker_t w5 = 5; | |
40 | worker_t w6 = 6; | |
[11dbfe1] | 41 | } |
[2afec66] | 42 | } |
Note: See TracBrowser
for help on using the repository browser.