@@ -16,9 +16,9 @@ func TestParallel(t *testing.T) {
1616 a .NilNow (err )
1717 a .EqualNow (out , [][]any {})
1818
19- a .PanicNow (func () {
19+ a .PanicOfNow (func () {
2020 Parallel (- 1 )
21- })
21+ }, ErrInvalidConcurrency )
2222}
2323
2424func TestParallelWithoutConcurrencyLimit (t * testing.T ) {
@@ -37,7 +37,7 @@ func TestParallelWithoutConcurrencyLimit(t *testing.T) {
3737 out , err := Parallel (0 , funcs ... )
3838 dur := time .Since (start )
3939 a .NilNow (err )
40- a .TrueNow (dur - 100 * time . Millisecond < 30 * time .Millisecond ) // allow 30ms deviation
40+ a .TrueNow (dur < 130 * time .Millisecond ) // allow 30ms deviation
4141 a .EqualNow (out , [][]any {{0 , nil }, {1 , nil }, {2 , nil }, {3 , nil }, {4 , nil }})
4242}
4343
@@ -57,7 +57,7 @@ func TestParallelWithConcurrencyLimit(t *testing.T) {
5757 out , err := Parallel (2 , funcs ... )
5858 dur := time .Since (start )
5959 a .NilNow (err )
60- a .TrueNow (dur - 300 * time . Millisecond < 30 * time .Millisecond ) // allow 30ms deviation
60+ a .TrueNow (dur < 350 * time .Millisecond ) // allow 50ms deviation
6161 a .EqualNow (out , [][]any {{0 , nil }, {1 , nil }, {2 , nil }, {3 , nil }, {4 , nil }})
6262}
6363
@@ -85,7 +85,7 @@ func TestParallelWithFailedTask(t *testing.T) {
8585 dur := time .Since (start )
8686 a .NotNilNow (err )
8787 a .EqualNow (err .Error (), "function 2 error: expected error" )
88- a .TrueNow (dur - 150 * time . Millisecond < 30 * time .Millisecond ) // allow 30ms deviation
88+ a .TrueNow (dur < 180 * time .Millisecond ) // allow 30ms deviation
8989 a .EqualNow (out , [][]any {{0 , nil }, {1 , nil }, {2 , expectedErr }, nil , nil })
9090}
9191
@@ -158,9 +158,9 @@ func TestParallelCompleted(t *testing.T) {
158158 a .NilNow (err )
159159 a .EqualNow (out , [][]any {})
160160
161- a .PanicNow (func () {
161+ a .PanicOfNow (func () {
162162 ParallelCompleted (- 1 )
163- })
163+ }, ErrInvalidConcurrency )
164164}
165165
166166func TestParallelCompletedWithoutConcurrencyLimit (t * testing.T ) {
@@ -179,7 +179,7 @@ func TestParallelCompletedWithoutConcurrencyLimit(t *testing.T) {
179179 out , err := ParallelCompleted (0 , funcs ... )
180180 dur := time .Since (start )
181181 a .NilNow (err )
182- a .TrueNow (dur - 100 * time . Millisecond < 30 * time .Millisecond ) // allow 30ms deviation
182+ a .TrueNow (dur < 130 * time .Millisecond ) // allow 30ms deviation
183183 a .EqualNow (out , [][]any {{0 , nil }, {1 , nil }, {2 , nil }, {3 , nil }, {4 , nil }})
184184}
185185
@@ -200,7 +200,7 @@ func TestParallelCompletedWithConcurrencyLimit(t *testing.T) {
200200 dur := time .Since (start )
201201 a .NilNow (err )
202202 a .EqualNow (out , [][]any {{0 , nil }, {1 , nil }, {2 , nil }, {3 , nil }, {4 , nil }})
203- a .TrueNow (dur - 300 * time . Millisecond < 30 * time .Millisecond ) // allow 30ms deviation
203+ a .TrueNow (dur < 350 * time .Millisecond ) // allow 50ms deviation
204204}
205205
206206func TestParallelCompletedWithFailedTask (t * testing.T ) {
0 commit comments