(t *testing.T)
| 199 | } |
| 200 | |
| 201 | func TestPoolAcquireReturnsWorker(t *testing.T) { |
| 202 | p, err := newPool(2) |
| 203 | if err != nil { |
| 204 | t.Fatalf("newPool failed: %v", err) |
| 205 | } |
| 206 | defer p.close() |
| 207 | |
| 208 | w := p.acquire(50 * time.Millisecond) |
| 209 | if w == nil { |
| 210 | t.Fatal("acquire returned nil but pool has free workers") |
| 211 | } |
| 212 | } |
| 213 | |
| 214 | func TestPoolAcquireReturnsNilWhenExhausted(t *testing.T) { |
| 215 | p, err := newPool(2) |