1 unstable release
0.1.2 | Feb 20, 2021 |
---|
#2061 in Asynchronous
9KB
99 lines
tokio_safe
Provides the ability to execute async code from a sync context, without blocking a tokio core thread or busy looping the cpu.
Example
#[tokio::main(threaded_scheduler)]
async fn main() {
// we need to ensure we are in the context of a tokio task
tokio::task::spawn(async move {
// some library api may take a sync callback
// but we want to be able to execute async code
(|| {
let r = tokio_safe::tokio_safe(
// async code to poll synchronously
async move {
// simulate some async work
tokio::time::delay_for(
std::time::Duration::from_millis(2)
).await;
// return our result
"test"
},
// timeout to allow async execution
std::time::Duration::from_millis(10),
).unwrap();
// note we get the result inline with no `await`
assert_eq!("test", r);
})()
})
.await
.unwrap();
}
Dependencies
~4.5MB
~65K SLoC