|
|
@ -609,8 +609,10 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat |
|
|
|
createConnectionThread.setStarted(false); |
|
|
|
createConnectionThread.setStarted(false); |
|
|
|
String destroyName = "Druid-ConnectionPool-Destroy-" + System.identityHashCode(this) + this.getUrl(); |
|
|
|
String destroyName = "Druid-ConnectionPool-Destroy-" + System.identityHashCode(this) + this.getUrl(); |
|
|
|
if (destroyConnectionThread != null) { |
|
|
|
if (destroyConnectionThread != null) { |
|
|
|
|
|
|
|
if (!destroyConnectionThread.isInterrupted()) { |
|
|
|
destroyConnectionThread.interrupt(); |
|
|
|
destroyConnectionThread.interrupt(); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
destroyConnectionThread = new DestroyConnectionThread(destroyName); |
|
|
|
destroyConnectionThread = new DestroyConnectionThread(destroyName); |
|
|
|
destroyConnectionThread.setStarted(false); |
|
|
|
destroyConnectionThread.setStarted(false); |
|
|
|
initedLatch = new CountDownLatch(2); |
|
|
|
initedLatch = new CountDownLatch(2); |
|
|
|