diff --git a/taskman.go b/taskman.go index a530288..fa6a6c9 100644 --- a/taskman.go +++ b/taskman.go @@ -30,15 +30,14 @@ func newTaskMan(delay int, callUrl string) *TaskMan { go func() { for { <-t.waitChan - if len(t.waitQueue) < 1 { - return + if len(t.waitQueue) >= 1 { + cf := t.waitQueue[len(t.waitQueue)-1] + if len(t.waitQueue) > 1 { + logInfo("redundant tasks dropped:", len(t.waitQueue)-1) + } + t.waitQueue = []*changedFile{} + go t.preRun(cf) } - cf := t.waitQueue[len(t.waitQueue)-1] - if len(t.waitQueue) > 1 { - logInfo("redundant tasks dropped:", len(t.waitQueue)-1) - } - t.waitQueue = []*changedFile{} - go t.preRun(cf) } }() }