Struct meli::jobs::JobExecutor

pub struct JobExecutor {
    global_queue: Arc<Injector<MeliTask>>,
    workers: Vec<Stealer<MeliTask>>,
    sender: Sender<ThreadEvent>,
    parkers: Vec<Unparker>,
    timers: Arc<Mutex<HashMap<Uuid, TimerPrivate>>>,
}

Fields

global_queue: Arc<Injector<MeliTask>>

workers: Vec<Stealer<MeliTask>>

sender: Sender<ThreadEvent>

parkers: Vec<Unparker>

timers: Arc<Mutex<HashMap<Uuid, TimerPrivate>>>

Implementations

impl JobExecutor

pub fn new(sender: Sender<ThreadEvent>) -> Self

A queue that holds scheduled tasks.

pub fn spawn_specialized<F, R>(&self, future: F) -> JoinHandle<R> where
    F: Future<Output = R> + Send + 'static,
    R: Send + 'static, 

Spawns a future with a generic return value R

pub fn spawn_blocking<F, R>(&self, future: F) -> JoinHandle<R> where
    F: Future<Output = R> + Send + 'static,
    R: Send + 'static, 

Spawns a future with a generic return value R that might block on a new thread

pub fn create_timer(
    self: Arc<JobExecutor>,
    interval: Duration,
    value: Duration
) -> Timer

pub fn rearm(&self, timer_id: Uuid)

fn arm_timer(&self, id: Uuid, value: Duration)

fn disable_timer(&self, id: Uuid)

Trait Implementations

impl Debug for JobExecutor

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

Formats the value using the given formatter.