Struct quickjs_runtime::utils::single_threaded_event_queue::SingleThreadedEventQueue

pub struct SingleThreadedEventQueue { /* fields omitted */ }

the EsEventQueue is a single threaded thread pool which is used to act as the only thread using an instance of a script runtime besides being able to add tasks from any thread by add_task a running task can add jobs to the current thread by calling add_task_from_worker those tasks need not impl the Send trait and there is no locking happening to add the task to the queue

Implementations

impl SingleThreadedEventQueue

pub fn new() -> Arc<Self>

pub fn shutdown(&self)

pub fn add_task<T: FnOnce() + Send + 'static>(&self, task: T)

add a task which will run asynchronously

pub fn async_task<T: FnOnce() -> R + Send + 'static, R: Send + 'static>(
    &self,
    task: T
) -> impl Future<Output = R>

pub fn exe_task<R: Send + 'static, T: FnOnce() -> R + Send + 'static>(
    &self,
    task: T
) -> R

execute a task synchronously in the worker thread

pub fn add_task_from_worker<T: FnOnce() + 'static>(&self, task: T)

method for adding tasks from worker, these do not need to impl Send also there is no locks we need to wait for

pub fn schedule_task_from_worker<T: Fn() + 'static>(
    &self,
    task: T,
    interval: Option<Duration>,
    delay: Duration
) -> i32

pub fn remove_schedule_task_from_worker(&self, id: i32)

pub fn todo_count(&self) -> usize

pub fn assert_is_worker_thread(&self)

Trait Implementations

impl Drop for SingleThreadedEventQueue

fn drop(&mut self)

Executes the destructor for this type.