jyapayne/Nim
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fix async timers execution. (#5448)

Browse source
This commit is contained in:
Andrey Sobolev 2017-03-01 15:43:24 +07:00 • committed by Andreas Rumpf
commit 78de355ec6
2 changed files with 10 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

6
lib/pure/asyncdispatch.nim
View file

@ -167,8 +167,12 @@ type
callbacks: Deque[proc ()] callbacks: Deque[proc ()]
proc processTimers(p: PDispatcherBase) {.inline.} = proc processTimers(p: PDispatcherBase) {.inline.} =
while p.timers.len > 0 and epochTime() >= p.timers[0].finishAt: #Process just part if timers at a step
var count = p.timers.len
let t = epochTime()
while count > 0 and t >= p.timers[0].finishAt:
p.timers.pop().fut.complete() p.timers.pop().fut.complete()
dec count
proc processPendingCallbacks(p: PDispatcherBase) = proc processPendingCallbacks(p: PDispatcherBase) =
while p.callbacks.len > 0: while p.callbacks.len > 0:

6
lib/upcoming/asyncdispatch.nim
View file

@ -138,8 +138,12 @@ type
callbacks: Deque[proc ()] callbacks: Deque[proc ()]
proc processTimers(p: PDispatcherBase) {.inline.} = proc processTimers(p: PDispatcherBase) {.inline.} =
while p.timers.len > 0 and epochTime() >= p.timers[0].finishAt: #Process just part if timers at a step
var count = p.timers.len
let t = epochTime()
while count > 0 and t >= p.timers[0].finishAt:
p.timers.pop().fut.complete() p.timers.pop().fut.complete()
dec count
proc processPendingCallbacks(p: PDispatcherBase) = proc processPendingCallbacks(p: PDispatcherBase) =
while p.callbacks.len > 0: while p.callbacks.len > 0: