Struct sqlxmq::JobRunnerHandle
source · pub struct JobRunnerHandle { /* private fields */ }
Expand description
Job runner handle
Implementations§
source§impl JobRunnerHandle
impl JobRunnerHandle
sourcepub fn num_running_jobs(&self) -> usize
pub fn num_running_jobs(&self) -> usize
Return the number of still running jobs
sourcepub async fn wait_jobs_finish(&self, timeout: Duration)
pub async fn wait_jobs_finish(&self, timeout: Duration)
Wait for the jobs to finish, but not more than timeout
Auto Trait Implementations§
impl !RefUnwindSafe for JobRunnerHandle
impl Send for JobRunnerHandle
impl Sync for JobRunnerHandle
impl Unpin for JobRunnerHandle
impl !UnwindSafe for JobRunnerHandle
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more