remove a sleep that's not needed (#117)

substratusai · Jul 10, 2024 · c4dc1da · c4dc1da
1 parent 4bbddf3
commit c4dc1da
Showing 1 changed file with 0 additions and 3 deletions.
diff --git a/pkg/queue/queue.go b/pkg/queue/queue.go
@@ -6,7 +6,6 @@ import (
 	"log"
 	"sync"
 	"sync/atomic"
-	"time"
 )
 
 func New(initialConcurrency int) *Queue {
@@ -155,8 +154,6 @@ func (q *Queue) Start() {
 		itm := e.Value.(*item)
 		q.dequeue(itm, true)
 		log.Println("Dequeued: ", itm.id)
-
-		time.Sleep(time.Second / 100)
 	}
 }