replace thread interrupted test method

which can clean interrupted status
Chris2018998 · Oct 21, 2022 · 50f5554 · 50f5554
1 parent a8544e9
commit 50f5554
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/src/main/java/cn/beecp/pool/FastConnectionPool.java b/src/main/java/cn/beecp/pool/FastConnectionPool.java
@@ -424,8 +424,7 @@ private PooledConnection getPooledConnection() throws SQLException {
             boolean failed = false;
             Throwable cause = null;
             deadline += this.maxWaitNs;
-            Thread thd = b.thread;
-
+
             do {
                 Object s = b.state;//PooledConnection,Throwable,BOWER_NORMAL
                 if (s instanceof PooledConnection) {
@@ -452,7 +451,7 @@ private PooledConnection getPooledConnection() throws SQLException {
                                 LockSupport.unpark(this);
 
                             LockSupport.parkNanos(t);//block exit:1:get transfer 2:timeout 3:interrupted
-                            if (thd.isInterrupted()) {
+                            if (Thread.interrupted()) {//auto clear interrupted status
                                 failed = true;
                                 cause = new SQLException("Interrupted during getting connection");
                                 BorrowStUpd.compareAndSet(b, BOWER_WAITING, cause);