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.

pub fn builder() -> ThreadPerTaskExecutorServiceBuilder

Creates a builder for configuring this service.

Returns

A builder initialized with default worker thread options.

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() -> Self

Creates a service with default worker options and no hook.

impl ExecutorService for ThreadPerTaskExecutorService

fn submit<T, E>(&self, task: T) -> Result<(), SubmissionError>

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

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

Parameters

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

Returns

Ok(()) if the runnable was accepted.

Errors

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

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

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 SubmissionError::Shutdown if shutdown has already been requested before the task is accepted.

fn submit_tracked_callable<C, R, E>( &self, task: C, ) -> Result<Self::TrackedHandle<R, E>, SubmissionError>

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

Accepts a callable and starts it with a tracked handle.

fn shutdown(&self)

Stops accepting new tasks.

Already accepted threads are allowed to finish.

fn stop(&self) -> StopReport

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 lifecycle(&self) -> ExecutorServiceLifecycle

Returns the current lifecycle state.

fn wait_termination(&self)

Blocks until all accepted tasks complete after shutdown or stop.

This method blocks the current thread on a condition variable. Calling it while the service is still running will wait until another thread calls Self::shutdown or Self::stop and all accepted OS-thread tasks have completed.

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

Result handle returned for an accepted callable task.

type TrackedHandle<R, E> = TrackedTask<R, E> where R: Send + 'static, E: Send + 'static

Tracked handle returned for accepted tasks that expose status.

fn submit_tracked<T, E>( &self, task: T, ) -> Result<Self::TrackedHandle<(), E>, SubmissionError>

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

Submits a runnable task and returns a tracked handle.

fn is_running(&self) -> bool

Returns whether the service accepts new tasks.

fn is_shutting_down(&self) -> bool

Returns whether graceful shutdown is in progress.

fn is_stopping(&self) -> bool

Returns whether abrupt stop is in progress.

fn is_not_running(&self) -> bool

Returns whether this service is not running.

fn is_terminated(&self) -> bool

Returns whether the service has terminated.