protected void maybeSignalForMoreConnections ( ConnectionPartition connectionPartition ) { if ( ! connectionPartition . isUnableToCreateMoreTransactions ( ) && ! this . poolShuttingDown && connectionPartition . getAvailableConnections ( ) * 100 / connectionPartition . getMaxConnections ( ) <= this . poolAvailabilityThreshold ) { connectionPartition . getPoolWatchThreadSignalQueue ( ) . offer ( new Object ( ) ) ; // item being pushed is not important. } }
Tests if this partition has hit a threshold and signal to the pool watch thread to create new connections