bug fixed for CreateConnectionTask

2023-03-04 19:17:16 +00:00 · 2015-06-20 23:10:27 +08:00
parent 7ae82934e4
commit d553c2d7e9
1 changed files with 18 additions and 1 deletions
@@ -1720,6 +1720,12 @@ public class DruidDataSource extends DruidAbstractDataSource
        try {
            holder = new DruidConnectionHolder(DruidDataSource.this, connection);
        } catch (SQLException ex) {
+            lock.lock();
+            try {
+                createTaskCount--;
+            } finally {
+                lock.unlock();
+            }
            LOG.error("create connection holder error", ex);
            return;
        }
@@ -1791,7 +1797,12 @@ public class DruidDataSource extends DruidAbstractDataSource

                    if (errorCount > connectionErrorRetryAttempts && timeBetweenConnectErrorMillis > 0) {
                        if (breakAfterAcquireFailure) {
-                            createTaskCount--;
+                            lock.lock();
+                            try {
+                                createTaskCount--;
+                            } finally {
+                                lock.unlock();
+                            }
                            return;
                        }

@@ -1802,6 +1813,12 @@ public class DruidDataSource extends DruidAbstractDataSource
                    LOG.error("create connection error", e);
                    continue;
                } catch (Error e) {
+                    lock.lock();
+                    try {
+                        createTaskCount--;
+                    } finally {
+                        lock.unlock();
+                    }
                    LOG.error("create connection error", e);
                    break;
                }