Skip to content

Commit b5a175e

Browse files
committed
number of executors
1 parent 0f3e411 commit b5a175e

File tree

1 file changed

+6
-5
lines changed

1 file changed

+6
-5
lines changed

Sources/PostgresNIO/Pool/PostgresClient.swift

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -272,12 +272,13 @@ public final class PostgresClient: Sendable, ServiceLifecycle.Service {
272272
let idGenerator = ConnectionIDGenerator.globalGenerator
273273

274274
if configuration.options.maximumConnections > 50 {
275-
// make as many executors as we have NIO els
276-
let executors = (0..<10).map { _ in NothingConnectionPoolExecutor() }
275+
// make as many executors as we have NIO else
276+
let executorCount = Int(ceil(Double(configuration.options.maximumConnections) / 50.0))
277+
let executors = (0..<executorCount).map { _ in NothingConnectionPoolExecutor() }
277278
var poolManagerConfiguration = ConnectionPoolManagerConfiguration()
278-
poolManagerConfiguration.minimumConnectionPerExecutorCount = configuration.options.minimumConnections / executors.count
279-
poolManagerConfiguration.maximumConnectionPerExecutorSoftLimit = configuration.options.maximumConnections / executors.count
280-
poolManagerConfiguration.maximumConnectionPerExecutorHardLimit = configuration.options.maximumConnections / executors.count
279+
poolManagerConfiguration.minimumConnectionPerExecutorCount = configuration.options.minimumConnections / executorCount
280+
poolManagerConfiguration.maximumConnectionPerExecutorSoftLimit = configuration.options.maximumConnections / executorCount
281+
poolManagerConfiguration.maximumConnectionPerExecutorHardLimit = configuration.options.maximumConnections / executorCount
281282

282283
self = .manager(
283284
ConnectionPoolManager(

0 commit comments

Comments
 (0)