Struct Pools 

pub struct Pools { /* private fields */ }

Handle to the runtime’s thread pools.

Wraps two rayon ThreadPool instances for workload isolation and an optional tokio Runtime for async I/O.

When async_threads is 0 in the config, no tokio runtime is created. Calling spawn(), block_on(), or handle() without a tokio runtime will panic.

Implementations

impl Pools

pub fn new(config: PoolConfig) -> Self

Create all thread pools from the given configuration.

If async_threads is 0, no tokio runtime is created.

pub fn system_pool(&self) -> &Arc<ThreadPool>

Get a reference to the system rayon pool.

pub fn query_pool(&self) -> &Arc<ThreadPool>

Get a reference to the query rayon pool.

pub fn handle(&self) -> Handle

Get a handle to the tokio runtime.

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

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

Spawn a future onto the tokio runtime.

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

where F: Future,

Block the current thread until the future completes.

Trait Implementations

impl Clone for Pools

fn clone(&self) -> Pools

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for Pools

fn default() -> Self

Returns the “default value” for a type.