Merge pull request #1562 from 4el0ve4ek/fix-pool-item-close

Fix pool item close

Author: asmyasnikov

CHANGELOG.md

@@ -1,7 +1,10 @@
+* Fixed connections pool leak on closing
+
 ## v3.92.3
 * Fixed error with incompleted data returen from transaction.ReadQueryResult method
 * Added option `query/WithResponsePartLimitSizeBytes(...)` for queries with query service
 
+
 ## v3.92.2
 * Added `table/options.WithShardNodesInfo()` experimental option to get shard nodeId for describe table call
 

internal/pool/pool.go

@@ -296,15 +296,15 @@ func makeAsyncCloseItemFunc[PT ItemConstraint[T], T any](
 	p *Pool[PT, T],
 ) func(ctx context.Context, item PT) {
 	return func(ctx context.Context, item PT) {
-		closeItemCtx, closeItemCancel := xcontext.WithDone(xcontext.ValueOnly(ctx), p.done)
-		defer closeItemCancel()
-
-		if d := p.config.closeTimeout; d > 0 {
-			closeItemCtx, closeItemCancel = xcontext.WithTimeout(ctx, d)
+		go func() {
+			closeItemCtx, closeItemCancel := xcontext.WithDone(xcontext.ValueOnly(ctx), p.done)
 			defer closeItemCancel()
-		}
 
-		go func() {
+			if d := p.config.closeTimeout; d > 0 {
+				closeItemCtx, closeItemCancel = xcontext.WithTimeout(ctx, d)
+				defer closeItemCancel()
+			}
+
 			_ = item.Close(closeItemCtx)
 		}()
 	}