From e52088bbd8f4f15b0d49ced8a24c5a2fc8c8c11f Mon Sep 17 00:00:00 2001 From: Emil Fresk Date: Mon, 22 Feb 2021 20:15:13 +0100 Subject: [PATCH] Of by 1 --- src/tq.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/tq.rs b/src/tq.rs index 6697f100b2..541ffcd13b 100644 --- a/src/tq.rs +++ b/src/tq.rs @@ -82,7 +82,7 @@ where mono.clear_compare_flag(); if let Some(instant) = self.0.peek().map(|p| p.instant) { - if instant < Self::unwrapper(Clock::try_now(mono)) { + if instant <= Self::unwrapper(Clock::try_now(mono)) { // task became ready let nr = unsafe { self.0.pop_unchecked() }; @@ -96,7 +96,7 @@ where // dequeue. If the monotonic is fast enough it can happen that from the // read of now to the set of the compare, the time can overflow. This is to // guard against this. - if instant < Self::unwrapper(Clock::try_now(mono)) { + if instant <= Self::unwrapper(Clock::try_now(mono)) { let nr = unsafe { self.0.pop_unchecked() }; Some((nr.task, nr.index))