Update modules/queue/queue_disk.go

6 years ago · 402e4dfe96
1 changed files with 0 additions and 1 deletions
--- a/modules/queue/queue_disk.go
+++ b/modules/queue/queue_disk.go
@ -148,7 +148,6 @@ func (l *LevelQueue) readToChan() {

 			log.Trace("LevelQueue %s: Task found: %#v", l.name, data)
 			l.pool.Push(data)
-			time.Sleep(time.Millisecond * 10)

 		}
 	}