From 19c8b41621a73d19ba74f3b2fc82ae53206d242c Mon Sep 17 00:00:00 2001 From: Kevin Keuning Date: Fri, 14 Apr 2017 16:18:12 -0500 Subject: simpler throttle --- system/db/content.go | 15 +++++++-------- 1 file changed, 7 insertions(+), 8 deletions(-) (limited to 'system') diff --git a/system/db/content.go b/system/db/content.go index e573e79..b503a60 100644 --- a/system/db/content.go +++ b/system/db/content.go @@ -600,16 +600,15 @@ func enoughTime(key string) bool { // dispatch a delayed invocation in case no additional one follows go func() { - lastInvocationBeforeTicker, _ := lastInvocation(key) // zero value can be handled, no need for ok - enoughTicker := time.NewTicker(waitDuration) - select { - case <-enoughTicker.C: - lastInvocationAfterTicker, _ := lastInvocation(key) - if !lastInvocationAfterTicker.After(lastInvocationBeforeTicker) { - SortContent(key) - } + lastInvocationBeforeTimer, _ := lastInvocation(key) // zero value can be handled, no need for ok + enoughTimer := time.NewTimer(waitDuration) + <-enoughTimer.C + lastInvocationAfterTimer, _ := lastInvocation(key) + if !lastInvocationAfterTimer.After(lastInvocationBeforeTimer) { + SortContent(key) } }() + return false } -- cgit v1.2.3