MCPcopy Create free account
hub / github.com/apache/datafusion / spawn_blocking

Method spawn_blocking

datafusion/common-runtime/src/join_set.rs:98–105  ·  view source on GitHub ↗

[JoinSet::spawn_blocking](tokio::task::JoinSet::spawn_blocking) - Spawn a blocking task.

(&mut self, f: F)

Source from the content-addressed store, hash-verified

96
97 /// [JoinSet::spawn_blocking](tokio::task::JoinSet::spawn_blocking) - Spawn a blocking task.
98 pub fn spawn_blocking<F>(&mut self, f: F) -> AbortHandle
99 where
100 F: FnOnce() -> T,
101 F: Send + 'static,
102 T: Send,
103 {
104 self.inner.spawn_blocking(trace_block(f))
105 }
106
107 /// [JoinSet::spawn_blocking_on](tokio::task::JoinSet::spawn_blocking_on) - Spawn a blocking task on a provided runtime.
108 pub fn spawn_blocking_on<F>(&mut self, f: F, handle: &Handle) -> AbortHandle

Callers

nothing calls this directly

Calls 1

trace_blockFunction · 0.85

Tested by

no test coverage detected