Introduce the Tokio runtime: Reactor + Threadpool

Cargo.toml

@@ -23,20 +23,24 @@ keywords = ["io", "async", "non-blocking", "futures"]

members = [
  "./",
  "tokio-executor",
  "tokio-io",
  "tokio-threadpool",
]

[badges]
travis-ci = { repository = "tokio-rs/tokio" }
appveyor = { repository = "carllerche/tokio" }

[dependencies]
tokio-io = "0.1"
tokio-executor = { version = "0.1", path = "tokio-executor" }
tokio-threadpool = { version = "0.1", path = "tokio-threadpool" }
bytes = "0.4"
log = "0.4"
mio = "0.6.13"
slab = "0.4"
iovec = "0.1"
tokio-io = "0.1"
futures = "0.1.16"

[dev-dependencies]

examples/chat.rs

@@ -439,6 +439,8 @@ pub fn main() {
        println!("accept error = {:?}", err);
    });

    println!("server running on localhost:6142");

    // This starts the `current_thread` executor.
    //
    // Executors are responsible for scheduling many asynchronous tasks, driving
@@ -447,19 +449,16 @@ pub fn main() {
    //
    // The `current_thread` executor multiplexes all scheduled tasks on the
    // current thread. This means that spawned tasks must not implement `Send`.
    current_thread::run(|_| {
        // Now, the server task must be spawned.
    // It's important to note that all futures / tasks are lazy. No work will
    // happen unless they are spawned onto an executor.
    //
        // It's important to note that all futures / tasks are lazy. No work
        // will happen unless they are spawned onto an executor.
        current_thread::spawn(server);

        println!("server running on localhost:6142");

        // The `current_thread::run` function will now block until *all* spawned
        // tasks complete.
    // The executor will start running the `server` task, which, in turn, spawns
    // new tasks for each incoming connection.
    //
        // In our example, we have not defined a shutdown strategy, so
        // this will block until `ctrl-c` is pressed at the terminal.
    });
    // The `current_thread::block_on_all` function will block until *all*
    // spawned tasks complete.
    //
    // In our example, we have not defined a shutdown strategy, so this will
    // block until `ctrl-c` is pressed at the terminal.
    current_thread::block_on_all(server).unwrap();
}

examples/hello_world.rs

@@ -55,28 +55,26 @@ pub fn main() {
        println!("accept error = {:?}", err);
    });

    println!("server running on localhost:6142");

    // This starts the `current_thread` executor.
    //
    // Executors are responsible for scheduling many asynchronous tasks, driving
    // them to completion. There are a number of different executor
    // implementations, each providing different scheduling characteristics.
    //
    // The `current_thread` executor multiplexes all scheduled tasks on the
    // current thread. This means that spawned tasks are not required to
    // implement `Send`.
    current_thread::run(|_| {
        // Now, the server task must be spawned.
    // current thread. This means that spawned tasks must not implement `Send`.
    // It's important to note that all futures / tasks are lazy. No work will
    // happen unless they are spawned onto an executor.
    //
        // It's important to note that all futures / tasks are lazy. No work
        // will happen unless they are spawned onto an executor.
        current_thread::spawn(server);

        println!("server running on localhost:6142");

        // The `current_thread::run` function will now block until *all* spawned
        // tasks complete.
    // The executor will start running the `server` task, which, in turn, spawns
    // new tasks for each incoming connection.
    //
        // In our example, we have not defined a shutdown strategy, so
        // this will block until `ctrl-c` is pressed at the terminal.
    });
    // The `current_thread::block_on_all` function will block until *all*
    // spawned tasks complete.
    //
    // In our example, we have not defined a shutdown strategy, so this will
    // block until `ctrl-c` is pressed at the terminal.
    current_thread::block_on_all(server).unwrap();
}