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

Method spawn_blocking_on

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

[JoinSet::spawn_blocking_on](tokio::task::JoinSet::spawn_blocking_on) - Spawn a blocking task on a provided runtime.

(&mut self, f: F, handle: &Handle)

Source from the content-addressed store, hash-verified

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
109 where
110 F: FnOnce() -> T,
111 F: Send + 'static,
112 T: Send,
113 {
114 self.inner.spawn_blocking_on(trace_block(f), handle)
115 }
116
117 /// [JoinSet::join_next](tokio::task::JoinSet::join_next) - Await the next completed task.
118 pub async fn join_next(&mut self) -> Option<Result<T, JoinError>> {

Callers

nothing calls this directly

Calls 1

trace_blockFunction · 0.85

Tested by

no test coverage detected