Alawn/Druid
1
0
Fork 0
mirror of https://github.com/alibaba/druid.git synced 2023-03-04 19:17:16 +00:00
Code Issues Releases Wiki Activity

avoid muliti-close

Browse Source
This commit is contained in:
高铁
2021-04-18 21:23:50 +08:00
parent f029fe3cea
commit 1d5ae7929d
1 changed files with 11 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/alibaba/druid/pool/DruidPooledConnection.java
+11 -6
View File
@@ -64,7 +64,7 @@ public class DruidPooledConnection extends PoolableWrapper implements javax.sql.
protected volatile boolean traceEnable = false;
private volatile boolean disable = false;
protected volatile boolean closed = false;
protected volatile boolean closing = false;
static AtomicIntegerFieldUpdater CLOSING_UPDATER = AtomicIntegerFieldUpdater.newUpdater(DruidPooledConnection.class, "closing");
protected final Thread ownerThread;
private long connectedTimeMillis;
private long connectedTimeNano;
@@ -73,6 +73,7 @@ public class DruidPooledConnection extends PoolableWrapper implements javax.sql.
protected StackTraceElement[] connectStackTrace;
protected Throwable disableError = null;
final ReentrantLock lock;
protected volatile int closing = 0;
public DruidPooledConnection(DruidConnectionHolder holder){
super(holder.getConnection());
@@ -259,7 +260,9 @@ public class DruidPooledConnection extends PoolableWrapper implements javax.sql.
return;
}
closing = true;
if (!CLOSING_UPDATER.compareAndSet(this, 0, 1)) {
return;
}
try {
for (ConnectionEventListener listener : holder.getConnectionEventListeners()) {
@@ -274,7 +277,7 @@ public class DruidPooledConnection extends PoolableWrapper implements javax.sql.
recycle();
}
} finally {
closing = false;
CLOSING_UPDATER.set(this, 0);
}
this.disable = true;
@@ -283,7 +286,7 @@ public class DruidPooledConnection extends PoolableWrapper implements javax.sql.
public void syncClose() throws SQLException {
lock.lock();
try {
if (this.disable || closing) {
if (this.disable || CLOSING_UPDATER.get(this) != 0) {
return;
}
@@ -295,7 +298,9 @@ public class DruidPooledConnection extends PoolableWrapper implements javax.sql.
return;
}
closing = true;
if (!CLOSING_UPDATER.compareAndSet(this, 0, 1)) {
return;
}
for (ConnectionEventListener listener : holder.getConnectionEventListeners()) {
listener.connectionClosed(new ConnectionEvent(this));
@@ -312,7 +317,7 @@ public class DruidPooledConnection extends PoolableWrapper implements javax.sql.
this.disable = true;
} finally {
closing = false;
CLOSING_UPDATER.set(this, 0);
lock.unlock();
}
}