Struct open_coroutine_core::scheduler::join::JoinHandleImpl

#[repr(C)]
pub struct JoinHandleImpl<'j>(/* private fields */);

Trait Implementations

impl<'j> Debug for JoinHandleImpl<'j>

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

Formats the value using the given formatter.

impl<'j> JoinHandle<SchedulerImpl<'j>> for JoinHandleImpl<'j>

fn new(pool: *const SchedulerImpl<'j>, name: &str) -> Self

create JoinHandle instance.

fn get_name(&self) -> Result<&str>

get the task name.

fn timeout_at_join( &self, timeout_time: u64 ) -> Result<Result<Option<usize>, &str>>

join with timeout.

fn err() -> Self

where Self: Sized,

create JoinHandle instance.

fn timeout_join(&self, dur: Duration) -> Result<Result<Option<usize>, &str>>

join with Duration.

fn join(&self) -> Result<Result<Option<usize>, &str>>

join.

impl<'s> Scheduler<'s, JoinHandleImpl<'s>> for SchedulerImpl<'s>

fn get_stack_size(&self) -> usize

Get the default stack stack size for the coroutines in this scheduler. If it has not been set, it will be crate::constant::DEFAULT_STACK_SIZE.

fn set_stack_size(&self, stack_size: usize)

Set the default stack stack size for the coroutines in this scheduler. If it has not been set, it will be crate::constant::DEFAULT_STACK_SIZE.

fn submit_raw_co(&self, coroutine: SchedulableCoroutine<'static>) -> Result<()>

Submit a closure to create new coroutine, then the coroutine will be push into ready queue.

fn try_resume(&self, co_name: &str) -> Result<()>

Resume a coroutine from the system call table to the ready queue, it’s generally only required for framework level crates.

fn try_timeout_schedule(&self, timeout_time: u64) -> Result<u64>

Attempt to schedule the coroutines before the timeout_time timestamp.

fn try_get_co_result( &self, co_name: &str ) -> Option<Result<Option<usize>, &'s str>>

Attempt to obtain coroutine result with the given co_name.

fn size(&self) -> usize

Returns the number of coroutines owned by this scheduler.

fn add_listener(&mut self, listener: impl Listener + 's)

Add a listener to this scheduler.

fn submit_co( &self, f: impl FnOnce(&dyn Suspender<'_, Resume = (), Yield = ()>, ()) -> Option<usize> + UnwindSafe + 'static, stack_size: Option<usize> ) -> Result<Join>

Submit a closure to create new coroutine, then the coroutine will be push into ready queue.

fn try_schedule(&self) -> Result<()>

Schedule the coroutines.

fn try_timed_schedule(&self, dur: Duration) -> Result<u64>

Try scheduling the coroutines for up to dur.

fn is_empty(&self) -> bool

Returns true if the ready queue, suspend queue, and syscall queue are all empty.