diff --git a/utils/sync2/bucket_pool.go b/utils/sync2/bucket_pool.go index f5fa633..d3b4114 100644 --- a/utils/sync2/bucket_pool.go +++ b/utils/sync2/bucket_pool.go @@ -52,12 +52,12 @@ func (p *BucketPool[T]) GetFilled() (T, bool) { p.filledCond.L.Lock() defer p.filledCond.L.Unlock() - if p.closed { - var t T - return t, false - } - if len(p.filled) == 0 { + if p.closed { + var t T + return t, false + } + p.filledCond.Wait() }