Skip to content

Commit c582490

Browse files
committed
fix: if the pool is saturated, execute the job in the current goroutine
1 parent 34efbd4 commit c582490

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

pool_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@ func TestPool_FallbackToSyncMode(t *testing.T) {
4747
defer cancel()
4848

4949
dispatcher := events.SyncDispatcher{}
50-
p := newPool(WithTimeout(time.Second), WithConcurrency(1), WithShutdownEvents())(&dispatcher)
50+
p := NewPool(WithTimeout(time.Second), WithConcurrency(1), WithShutdownEvents())(&dispatcher)
5151
p.Run(ctx)
5252

5353
var executed = make(chan struct{})

0 commit comments

Comments
 (0)