Struct SharedTaskSlot 

pub struct SharedTaskSlot<T> { /* private fields */ }

Owns one typed task shared by cloned clients.

Concurrent finish calls are serialized within the caller’s graceful and abort durations. Canceling a finish or reaching the forced-completion deadline retains the task for another drain attempt. Dropping the owner requests abort but cannot asynchronously prove termination.

Implementations

impl<T> SharedTaskSlot<T>

pub fn new() -> Self

Creates an empty shared task slot.

pub fn is_empty(&self) -> bool

Returns whether the slot owns no task, including while a drain is pending.

pub fn is_finished(&self) -> bool

Returns whether the owned task has finished without being joined.

Returns false while a drain owns the handle and its state is unavailable.

pub fn insert(&self, handle: JoinHandle<T>)

Stores a task in an empty slot.

Panics

Aborts handle and panics if the slot already owns a task or is draining one.

pub fn spawn<F>(&self, future: F) -> Result<(), TaskSpawnError>

where T: Send + 'static, F: Future<Output = T> + Send + 'static,

Spawns and stores a task before its future can be polled.

Errors

Returns an error if the task stops before its start gate opens. The terminal handle remains owned so its join outcome stays observable.

Panics

Panics if the slot already owns a task or is draining one.

pub fn try_insert_slot(&self, slot: TaskSlot<T>) -> Result<(), TaskSlot<T>>

Transfers a task slot into this owner if it is empty.

An empty input slot is always accepted. Returns a nonempty input unchanged when this owner already has a task or is draining one.

Errors

Returns the input slot when this owner already has a task or is draining one.

pub fn abort(&self)

Requests task cancellation and records it as owner-initiated.

Panics

Panics if the shared task slot changes while cancellation temporarily drains it.

pub async fn finish( &self, graceful_timeout: Duration, abort_timeout: Duration, ) -> Option<TaskJoinOutcome<T>>

Gracefully joins the task, then aborts and joins it within a second bound.

If another caller holds the drain lock through both bounds, returns TaskJoinOutcome::Incomplete when a task remains owned.

Trait Implementations

impl<T: Debug> Debug for SharedTaskSlot<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T> Default for SharedTaskSlot<T>

fn default() -> Self

Returns the “default value” for a type.

impl<T> Drop for SharedTaskSlot<T>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.