Skip to content

Commit 7f259d3

Browse files
committed
fix tests
1 parent 0a29120 commit 7f259d3

1 file changed

Lines changed: 4 additions & 6 deletions

File tree

sync/task/queue/queue_test.go

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -9,15 +9,13 @@ import (
99

1010
func TestTaskQueue_Submit(t *testing.T) {
1111
_, err := queue.New(queue.Config{
12-
NumWorkers: -1,
13-
Size: 10,
14-
PreAlloc: true,
12+
GoroutinePoolSize: -1,
13+
Size: 10,
1514
})
1615
require.Error(t, err)
1716
q, err := queue.New(queue.Config{
18-
NumWorkers: 1,
19-
Size: 2,
20-
PreAlloc: true,
17+
GoroutinePoolSize: 1,
18+
Size: 2,
2119
})
2220
require.NoError(t, err)
2321
err = q.Submit(func() {}, func() {}, func() {})

0 commit comments

Comments
 (0)