37 releases (17 stable)

new 1.3.1 Nov 30, 2020
1.1.10 Oct 9, 2020
0.2.7 Sep 3, 2020
0.1.9 Jul 31, 2020
0.1.0 May 18, 2019

#9 in Asynchronous

Download history 12734/week @ 2020-08-11 20662/week @ 2020-08-18 23778/week @ 2020-08-25 20315/week @ 2020-09-01 28465/week @ 2020-09-08 35099/week @ 2020-09-15 32311/week @ 2020-09-22 37565/week @ 2020-09-29 36124/week @ 2020-10-06 39954/week @ 2020-10-13 39095/week @ 2020-10-20 39764/week @ 2020-10-27 42251/week @ 2020-11-03 42222/week @ 2020-11-10 47797/week @ 2020-11-17 39905/week @ 2020-11-24

159,805 downloads per month
Used in 760 crates (38 directly)

Apache-2.0 OR MIT

87KB
1K SLoC

async-io

Build License Cargo Documentation

Async I/O and timers.

This crate provides two tools:

  • Async, an adapter for standard networking types (and many other types) to use in async programs.
  • Timer, a future that expires at a point in time.

For concrete async networking types built on top of this crate, see async-net.

Implementation

The first time Async or Timer is used, a thread named "async-io" will be spawned. The purpose of this thread is to wait for I/O events reported by the operating system, and then wake appropriate futures blocked on I/O or timers when they can be resumed.

To wait for the next I/O event, the "async-io" thread uses epoll on Linux/Android/illumos, kqueue on macOS/iOS/BSD, event ports on illumos/Solaris, and wepoll on Windows. That functionality is provided by the polling crate.

However, note that you can also process I/O events and wake futures on any thread using the block_on() function. The "async-io" thread is therefore just a fallback mechanism processing I/O events in case no other threads are.

Examples

Connect to example.com:80, or time out after 10 seconds.

use async_io::{Async, Timer};
use futures_lite::{future::FutureExt, io};

use std::net::{TcpStream, ToSocketAddrs};
use std::time::Duration;

let addr = "example.com:80".to_socket_addrs()?.next().unwrap();

let stream = Async::<TcpStream>::connect(addr).or(async {
    Timer::after(Duration::from_secs(10)).await;
    Err(io::ErrorKind::TimedOut.into())
})
.await?;

License

Licensed under either of

at your option.

Contribution

Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in the work by you, as defined in the Apache-2.0 license, shall be dual licensed as above, without any additional terms or conditions.

Dependencies

~720KB
~13K SLoC