Struct open_coroutine_core::scheduler::SchedulerImpl

#[repr(C)]
pub struct SchedulerImpl<'s> { /* private fields */ }

Implementations

impl<'s> SchedulerImpl<'s>

pub fn new(name: String, stack_size: usize) -> Self

Trait Implementations

impl<'s> Current<'s> for SchedulerImpl<'s>

fn init_current(current: &Self)

where Self: Sized,

Init the current.

fn current() -> Option<&'s Self>

where Self: Sized,

Get the current if has.

fn clean_current()

where Self: Sized,

clean the current.

impl<'s> Debug for SchedulerImpl<'s>

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

Formats the value using the given formatter.

impl Default for SchedulerImpl<'_>

fn default() -> Self

Returns the “default value” for a type.

impl Drop for SchedulerImpl<'_>

fn drop(&mut self)

Executes the destructor for this type.

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 Listener for SchedulerImpl<'_>

fn on_create(&self, coroutine: &SchedulableCoroutine<'_>)

callback when a coroutine is created. This will be called by Scheduler when a coroutine is created.

fn on_schedule(&self, timeout_time: u64)

callback before scheduling coroutines. This will be called by Scheduler before scheduling coroutines.

fn on_resume(&self, timeout_time: u64, coroutine: &SchedulableCoroutine<'_>)

callback before resuming the coroutine. This will be called by Scheduler before resuming the coroutine.

fn on_suspend(&self, timeout_time: u64, coroutine: &SchedulableCoroutine<'_>)

callback when a coroutine is suspended. This will be called by Scheduler when a coroutine is suspended.

fn on_syscall( &self, timeout_time: u64, coroutine: &SchedulableCoroutine<'_>, syscall: Syscall, state: SyscallState )

callback when a coroutine enters syscall. This will be called by Scheduler when a coroutine enters syscall.

fn on_complete( &self, timeout_time: u64, coroutine: &SchedulableCoroutine<'_>, result: Option<usize> )

callback when a coroutine is completed. This will be called by Scheduler when a coroutine is completed.

fn on_error( &self, timeout_time: u64, coroutine: &SchedulableCoroutine<'_>, message: &str )

callback when a coroutine is panic. This will be called by Scheduler when a coroutine is panic.

impl Named for SchedulerImpl<'_>

fn get_name(&self) -> &str

Get the name of this object.

impl PartialEq for SchedulerImpl<'_>

fn eq(&self, other: &Self) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

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.

impl Eq for SchedulerImpl<'_>