- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for TestQueueBacklog (0.2 sec)
-
src/cmd/go/internal/par/queue_test.go
select { case <-idle: t.Errorf("NewQueue(1) is marked idle while processing work.") default: } close(unblock) <-idle // Should be closed as soon as the Add callback returns. } func TestQueueBacklog(t *testing.T) { const ( maxActive = 2 totalWork = 3 * maxActive ) q := NewQueue(maxActive) t.Logf("q = NewQueue(%d)", maxActive) var wg sync.WaitGroup wg.Add(totalWork)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Aug 24 21:08:46 UTC 2020 - 1.4K bytes - Viewed (0)