mirror of
https://github.com/rcore-os/rCore-Tutorial-v3.git
synced 2024-11-26 03:13:36 +04:00
add user app: sync_sem.rs
This commit is contained in:
parent
90796450fe
commit
1c0bbf4404
45
user/src/bin/sync_sem.rs
Normal file
45
user/src/bin/sync_sem.rs
Normal file
@ -0,0 +1,45 @@
|
|||||||
|
#![no_std]
|
||||||
|
#![no_main]
|
||||||
|
|
||||||
|
#[macro_use]
|
||||||
|
extern crate user_lib;
|
||||||
|
|
||||||
|
extern crate alloc;
|
||||||
|
|
||||||
|
use user_lib::{semaphore_create, semaphore_up, semaphore_down};
|
||||||
|
use user_lib::{thread_create, waittid, sleep};
|
||||||
|
use user_lib::exit;
|
||||||
|
use alloc::vec::Vec;
|
||||||
|
|
||||||
|
const SEM_SYNC: usize = 0;
|
||||||
|
|
||||||
|
|
||||||
|
unsafe fn first() -> ! {
|
||||||
|
sleep(10);
|
||||||
|
println!("First work and wakeup Second");
|
||||||
|
semaphore_up(SEM_SYNC);
|
||||||
|
exit(0)
|
||||||
|
}
|
||||||
|
|
||||||
|
unsafe fn second() -> ! {
|
||||||
|
println!("Second want to continue,but need to wait first");
|
||||||
|
semaphore_down(SEM_SYNC);
|
||||||
|
println!("Second can work now");
|
||||||
|
exit(0)
|
||||||
|
}
|
||||||
|
|
||||||
|
#[no_mangle]
|
||||||
|
pub fn main() -> i32 {
|
||||||
|
// create semaphores
|
||||||
|
assert_eq!(semaphore_create(0) as usize, SEM_SYNC);
|
||||||
|
// create threads
|
||||||
|
let mut threads = Vec::new();
|
||||||
|
threads.push(thread_create(first as usize, 0));
|
||||||
|
threads.push(thread_create(second as usize, 0));
|
||||||
|
// wait for all threads to complete
|
||||||
|
for thread in threads.iter() {
|
||||||
|
waittid(*thread as usize);
|
||||||
|
}
|
||||||
|
println!("sync_sem passed!");
|
||||||
|
0
|
||||||
|
}
|
Loading…
Reference in New Issue
Block a user