Struct sealrs::executors::thread_pinned_executor::ThreadPinnedExecutor

pub struct ThreadPinnedExecutor { /* fields omitted */ }

Methods

impl ThreadPinnedExecutor

pub fn new() -> ThreadPinnedExecutor

Creates new executor with default settings. Thread counts = count of the physical cpu core's. Distribution strategy = Round.

pub fn set_threads_count(self, count: usize) -> Self

Set thread's count

pub fn get_threads_count(&self) -> usize

pub fn set_distribution_strategy(self, strategy: DistributionStrategy) -> Self

Set distribution strategy

pub fn run(self) -> Self

Starts executor threads

Trait Implementations

impl Executor for ThreadPinnedExecutor

fn execute(&mut self, f: ExecutorTask, options: Option<Box<dyn Any>>)

Plans task for execution. This method must be called only after the executor is running. Otherwise it will cause to panic!

fn stop(&mut self)

Stops executor threads