Coroutine I/O
Coroutine scheduling with work-stealing algorithm.
WARN: Possibly crash because of TLS inline, check https://github.com/zonyitoo/coio-rs/issues/56 for more detail!
Feature
- Non-blocking I/O
- Work-stealing coroutine scheduling
- Asynchronous computing APIs
Usage
Note: You must use Nightly Rust to build this Project.
[dependencies.coio]
git = "https://github.com/zonyitoo/coio-rs.git"
Basic Coroutines
extern crate coio;
use coio::Scheduler;
fn main() {
Scheduler::new()
.run(|| {
for _ in 0..10 {
println!("Heil Hydra");
Scheduler::sched(); // Yields the current coroutine
}
})
.unwrap();
}
TCP Echo Server
extern crate coio;
use std::io::{Read, Write};
use coio::net::TcpListener;
use coio::{spawn, Scheduler};
fn main() {
// Spawn a coroutine for accepting new connections
Scheduler::new().with_workers(4).run(move|| {
let acceptor = TcpListener::bind("127.0.0.1:8080").unwrap();
println!("Waiting for connection ...");
for stream in acceptor.incoming() {
let (mut stream, addr) = stream.unwrap();
println!("Got connection from {:?}", addr);
// Spawn a new coroutine to handle the connection
spawn(move|| {
let mut buf = [0; 1024];
loop {
match stream.read(&mut buf) {
Ok(0) => {
println!("EOF");
break;
},
Ok(len) => {
println!("Read {} bytes, echo back", len);
stream.write_all(&buf[0..len]).unwrap();
},
Err(err) => {
println!("Error occurs: {:?}", err);
break;
}
}
}
println!("Client closed");
});
}
}).unwrap();
}
Exit the main function
Will cause all pending coroutines to be killed.
extern crate coio;
use std::sync::Arc;
use std::sync::atomic::{AtomicUsize, Ordering};
use std::time::Duration;
use coio::Scheduler;
fn main() {
let counter = Arc::new(AtomicUsize::new(0));
let cloned_counter = counter.clone();
let result = Scheduler::new().run(move|| {
// Spawn a new coroutine
Scheduler::spawn(move|| {
struct Guard(Arc<AtomicUsize>);
impl Drop for Guard {
fn drop(&mut self) {
self.0.store(1, Ordering::SeqCst);
}
}
// If the _guard is dropped, it will store 1 to the counter
let _guard = Guard(cloned_counter);
coio::sleep(Duration::from_secs(10));
println!("Not going to run this line");
});
// Exit right now, which will cause the coroutine to be destroyed.
panic!("Exit right now!!");
});
// The coroutine's stack is unwound properly
assert!(result.is_err() && counter.load(Ordering::SeqCst) == 1);
}
Basic Benchmarks
See benchmarks for more details.
5.7k Dec 30, 2022
107 Nov 23, 2022
7.8k Jan 7, 2023
18 Dec 14, 2022
2.1k Jan 6, 2023
1 Oct 30, 2021
3 Apr 27, 2022
454 Dec 2, 2022
137 Dec 19, 2022
98 Dec 24, 2022
1.3k Dec 31, 2022
404 Dec 31, 2022
10 Nov 13, 2022
3 Jul 6, 2023
133 Dec 5, 2022
1 Jan 28, 2022
37 Nov 7, 2022
1.1k Dec 26, 2022
83 Nov 30, 2022