(t *testing.T)
| 83 | } |
| 84 | |
| 85 | func TestTimeout(t *testing.T) { |
| 86 | initialWorkers := 1 |
| 87 | extraWorkers := 10 |
| 88 | |
| 89 | pool := workerpool.New(initialWorkers, 2) |
| 90 | |
| 91 | pool.Expand(extraWorkers, time.Millisecond*10, nil) |
| 92 | |
| 93 | assert.NoError(t, waitFunc(pool.Stop, _timeout)) |
| 94 | } |
| 95 | |
| 96 | func TestQuit(t *testing.T) { |
| 97 | initialWorkers := 1 |