source:
src/tests/concurrent/thread.c
@
6eb131c
Last change on this file since 6eb131c was b9f383f, checked in by , 6 years ago | |
---|---|
|
|
File size: 820 bytes |
Rev | Line | |
---|---|---|
[0c92c9f] | 1 | #include <fstream> |
2 | #include <kernel> | |
3 | #include <stdlib> | |
[4a3334cf] | 4 | #include <thread> |
[0c92c9f] | 5 | |
[f3c1737] | 6 | thread First { semaphore* lock; }; |
7 | thread Second { semaphore* lock; }; | |
[0c92c9f] | 8 | |
[b9f383f] | 9 | void ?{}( First & this, semaphore & lock ) { ((thread&)this){"Thread 1"}; this.lock = &lock; } |
10 | void ?{}( Second & this, semaphore & lock ) { ((thread&)this){"Thread 2"}; this.lock = &lock; } | |
[0c92c9f] | 11 | |
[83a071f9] | 12 | void main(First& this) { |
[0c92c9f] | 13 | for(int i = 0; i < 10; i++) { |
14 | sout | "First : Suspend No." | i + 1 | endl; | |
15 | yield(); | |
16 | } | |
[4cedd9f] | 17 | V(*this.lock); |
[0c92c9f] | 18 | } |
19 | ||
[83a071f9] | 20 | void main(Second& this) { |
[4cedd9f] | 21 | P(*this.lock); |
[0c92c9f] | 22 | for(int i = 0; i < 10; i++) { |
23 | sout | "Second : Suspend No." | i + 1 | endl; | |
24 | yield(); | |
25 | } | |
26 | } | |
27 | ||
28 | ||
29 | int main(int argc, char* argv[]) { | |
[f3c1737] | 30 | semaphore lock = { 0 }; |
[0c92c9f] | 31 | sout | "User main begin" | endl; |
32 | { | |
[ee897e4b] | 33 | processor p; |
[0c92c9f] | 34 | { |
[83a071f9] | 35 | First f = { lock }; |
36 | Second s = { lock }; | |
[0c92c9f] | 37 | } |
38 | } | |
39 | sout | "User main end" | endl; | |
[242a902] | 40 | } |
Note: See TracBrowser
for help on using the repository browser.