Struct ThreadPerTaskExecutorService 

pub struct ThreadPerTaskExecutorService { /* private fields */ }

Managed service that runs every accepted task on a dedicated OS thread.

The service has no queue: accepted tasks start immediately on their own thread. Shutdown prevents later submissions but cannot forcefully stop running OS threads.

Implementations

impl ThreadPerTaskExecutorService

pub fn new() -> Self

Creates a new service instance.

Returns

A service that accepts tasks until shutdown is requested.

Trait Implementations

impl Clone for ThreadPerTaskExecutorService

fn clone(&self) -> ThreadPerTaskExecutorService

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for ThreadPerTaskExecutorService

fn default() -> ThreadPerTaskExecutorService

Returns the “default value” for a type.

impl ExecutorService for ThreadPerTaskExecutorService

fn submit_callable<C, R, E>( &self, task: C, ) -> Result<Self::Handle<R, E>, RejectedExecution>

where C: Callable<R, E> + Send + 'static, R: Send + 'static, E: Send + 'static,

Accepts a callable and starts it on a dedicated OS thread.

Parameters

• task - Callable to execute on a new OS thread.

Returns

A TaskHandle for the accepted task.

Errors

Returns RejectedExecution::Shutdown if shutdown has already been requested before the task is accepted.

fn shutdown(&self)

Stops accepting new tasks.

Already accepted threads are allowed to finish.

fn shutdown_now(&self) -> ShutdownReport

Stops accepting new tasks and reports currently running work.

Running OS threads cannot be forcefully stopped by this service.

Returns

A report with zero queued tasks, the observed active thread count, and zero cancelled tasks.

fn is_shutdown(&self) -> bool

Returns whether shutdown has been requested.

fn is_terminated(&self) -> bool

Returns whether shutdown was requested and all tasks are finished.

fn await_termination(&self) -> Self::Termination<'_>

Waits for all accepted tasks to complete after shutdown.

This future blocks the polling thread while waiting on a condition variable.

Returns

A future that resolves after shutdown has been requested and all accepted OS-thread tasks have completed.

type Handle<R, E> = TaskHandle<R, E> where R: Send + 'static, E: Send + 'static

Handle returned for an accepted task.

type Termination<'a> = Pin<Box<dyn Future<Output = ()> + Send + 'a>> where Self: 'a

Future returned when waiting for service termination.

fn submit<T, E>( &self, task: T, ) -> Result<Self::Handle<(), E>, RejectedExecution>

where T: Runnable<E> + Send + 'static, E: Send + 'static,

Submits a runnable task to this service.