Struct RayonTaskHandle 

pub struct RayonTaskHandle<R, E> { /* private fields */ }

Handle returned by crate::RayonExecutorService for accepted tasks.

This handle supports blocking Self::get, asynchronous .await, and best-effort cancellation before a Rayon worker starts the task.

Implementations

impl<R, E> RayonTaskHandle<R, E>

pub fn get(self) -> TaskResult<R, E>

Waits for the task to finish and returns its final result.

Returns

The final task result reported through the underlying TaskHandle.

pub fn cancel(&self) -> bool

Attempts to cancel the task before any Rayon worker starts it.

Returns

true if the task was cancelled before start, or false if it had already started or completed.

pub fn is_done(&self) -> bool

Returns whether the task has reported completion.

Returns

true after the task has finished or has been cancelled.

Trait Implementations

impl<R, E> Future for RayonTaskHandle<R, E>

fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output>

Polls the accepted Rayon task for completion.

Parameters

• cx - Async task context used to register the current waker.

Returns

Poll::Ready with the task result after completion, or Poll::Pending while the task is still running or queued.

type Output = Result<R, TaskExecutionError<E>>

The type of value produced on completion.