Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for DelayQueueWorkers (0.69 sec)

  1. 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)
  2. 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)
Back to top