mirror/async-std
2
0
Fork 1
mirror of https://github.com/async-rs/async-std.git synced 2025-04-05 07:56:42 +00:00
Code Issues Releases Wiki Activity

switch to blocking

Browse source 
Signed-off-by: Marc-Antoine Perennou <Marc-Antoine@Perennou.com>
This commit is contained in:
Marc-Antoine Perennou 2020-07-22 09:12:48 +02:00
parent 25e0e1abdc
commit 2fe087bd0a
2 changed files with 4 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
Cargo.toml
View file

@ -26,6 +26,7 @@ default = [
"std", "std",
"async-io", "async-io",
"async-task", "async-task",
"blocking",
"kv-log-macro", "kv-log-macro",
"log", "log",
"num_cpus", "num_cpus",
@ -79,6 +80,7 @@ surf = { version = "1.0.3", optional = true }
[target.'cfg(not(target_os = "unknown"))'.dependencies] [target.'cfg(not(target_os = "unknown"))'.dependencies]
async-io = { version = "0.1.5", optional = true } async-io = { version = "0.1.5", optional = true }
blocking = { version = "0.5.0", optional = true }
smol = { version = "0.1.17", optional = true } smol = { version = "0.1.17", optional = true }
[target.'cfg(target_arch = "wasm32")'.dependencies] [target.'cfg(target_arch = "wasm32")'.dependencies]

7
src/task/spawn_blocking.rs
View file

@ -1,4 +1,4 @@
use crate::task::{JoinHandle, Task}; use crate::task::{self, JoinHandle};
/// Spawns a blocking task. /// Spawns a blocking task.
/// ///
@ -35,8 +35,5 @@ where
F: FnOnce() -> T + Send + 'static, F: FnOnce() -> T + Send + 'static,
T: Send + 'static, T: Send + 'static,
{ {
once_cell::sync::Lazy::force(&crate::rt::RUNTIME); task::spawn(async move { blocking::unblock!(f()) })
let handle = smol::Task::blocking(async move { f() }).into();
JoinHandle::new(handle, Task::new(None))
} }