- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for DelayQueueWorkers (0.69 sec)
-
pkg/queue/delay_test.go
t.Fatalf("pop %d was not in order", i) } if peeked != popped { t.Fatalf("did not peek at the next item to be popped") } } } func TestDelayQueueOrdering(t *testing.T) { dq := NewDelayed(DelayQueueWorkers(2)) stop := make(chan struct{}) defer close(stop) go dq.Run(stop) mu := sync.Mutex{} var t0, t1, t2 time.Time done := make(chan struct{}) dq.PushDelayed(func() error { mu.Lock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jul 20 06:27:31 UTC 2023 - 4.3K bytes - Viewed (0) -
pkg/queue/delay.go
if queue.enqueue != nil { close(queue.enqueue) } queue.enqueue = make(chan *delayTask, bufferSize) } } // DelayQueueWorkers sets the number of background worker goroutines await tasks to execute. Effectively the // maximum number of concurrent tasks. func DelayQueueWorkers(workers int) DelayQueueOption { return func(queue *delayQueue) { queue.workers = workers } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jul 20 06:27:31 UTC 2023 - 6.7K bytes - Viewed (0)