coio-rs's Introduction

Coroutine I/O

Coroutine scheduling with work-stealing algorithm.

Feature

Non-blocking I/O
Work-stealing coroutine scheduling
Asynchronous computing APIs

Usage

[dependencies]
git = "https://github.com/zonyitoo/coio-rs.git"

Basic Coroutines

extern crate coio;

use coio::{run, spawn, sched};

fn main() {
    spawn(|| {
        for _ in 0..10 {
            println!("Heil Hydra");
            sched();
        }
    });

    run(1);
}

TCP Echo Server

extern crate coio;

use std::io::{Read, Write};

use coio::net::TcpListener;
use coio::{spawn, run};

fn main() {
    // Spawn a coroutine for accepting new connections
    spawn(move|| {
        let acceptor = TcpListener::bind("127.0.0.1:8080").unwrap();
        println!("Waiting for connection ...");

        for stream in acceptor.incoming() {
            let mut stream = stream.unwrap();

            println!("Got connection from {:?}", stream.peer_addr().unwrap());

            // 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");
            });
        }
    });

    // Schedule with 4 threads
    run(4);
}

Basic Benchmarks

Run the tcp-echo-server in the example with 4 threads:

Benchmarking: 127.0.0.1:8000
128 clients, running 26 bytes, 30 sec.

Speed: 71344 request/sec, 71344 response/sec
Requests: 2140348

Run the sample TCP server in Go 1.5 with GOMAXPROCS=4:

Benchmarking: 127.0.0.1:8000
128 clients, running 26 bytes, 30 sec.

Speed: 70789 request/sec, 70789 response/sec
Requests: 2123691
Responses: 2123691

Recommend Projects