Skip to content

Commit b37af81

Browse files
committed
thread interrupted
1 parent 7d914d3 commit b37af81

1 file changed

Lines changed: 3 additions & 0 deletions

File tree

ebean-datasource/src/main/java/io/ebean/datasource/pool/PooledConnectionQueue.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -246,6 +246,9 @@ private int registerBusyConnection(PooledConnection connection) {
246246

247247
private PooledConnection _obtainConnection(Object affinitiyId) throws InterruptedException, SQLException {
248248
var start = System.nanoTime();
249+
if (Thread.interrupted()) {
250+
throw new InterruptedException();
251+
}
249252
lock.lockInterruptibly();
250253
try {
251254
if (doingShutdown) {

0 commit comments

Comments
 (0)