Struct polars_io::pl_async::RuntimeManager

pub struct RuntimeManager { /* private fields */ }

Available on crate feature async only.

Implementations

impl RuntimeManager

pub fn block_on_potential_spawn<F>(&'static self, future: F) -> F::Output

where F: Future + Send, F::Output: Send,

Keep track of rayon threads that drive the runtime. Every thread only allows a single runtime. If this thread calls block_on and this rayon thread is already driving an async execution we must start a new thread otherwise we panic. This can happen when we parallelize reads over 100s of files.

pub fn block_on<F>(&self, future: F) -> F::Output

where F: Future,