Merge pull request #91 in CORE/base-third from ~ABEL.CHEN/base-third:release/10.0 to release/10.0

* commit 'a82d7332c50dc2f1c89ada4afb56bb49f388a614':
  修改一下命名
  修改一下命名
  在所有生产线程退出的地方，都重新创建新的生产线程
  fix npe

fine-druid/src/com/fr/third/alibaba/druid/pool/DruidDataSource.java

@@ -602,7 +602,7 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat
         this.connectProperties = properties;
     }
 
-    private synchronized void createThreadChange() {
+    private synchronized void doSomethingBeforeCreationThreadBreak() {
         String threadName = "Druid-ConnectionPool-Create-" + System.identityHashCode(this) + this.getUrl();
         createConnectionThread = new CreateConnectionThread(threadName);
         createConnectionThread.setStarted(false);
@@ -613,6 +613,12 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat
     }
 
     private void checkThread() throws SQLException {
+        if (createConnectionThread == null){
+            throw new IllegalStateException("createConnectionThread not start!");
+        }
+        if (destroyConnectionThread == null){
+            throw new IllegalStateException("destroyConnectionThread not start!");
+        }
         if (!createConnectionThread.isStarted() && !destroyConnectionThread.isStarted()) {
             synchronized (this) {//线程安全问题，加个双检锁
                 if (!createConnectionThread.isStarted() && !destroyConnectionThread.isStarted()) {
@@ -2119,6 +2125,7 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat
                 } catch (InterruptedException e) {
                     lastCreateError = e;
                     lastErrorTimeMillis = System.currentTimeMillis();
+                    DruidDataSource.this.doSomethingBeforeCreationThreadBreak();
                     break;
                 } finally {
                     lock.unlock();
@@ -2152,10 +2159,10 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat
 
                         try {
                             Thread.sleep(timeBetweenConnectErrorMillis);
-                        } catch (InterruptedException interruptEx) {
-                            break;
+                        } catch (InterruptedException ignore) {
+
                         }
-                        DruidDataSource.this.createThreadChange();
+                        DruidDataSource.this.doSomethingBeforeCreationThreadBreak();
                         break;
                     }
                 } catch (RuntimeException e) {
@@ -2165,6 +2172,7 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat
                 } catch (Error e) {
                     LOG.error("create connection error", e);
                     setFailContinuous(true);
+                    DruidDataSource.this.doSomethingBeforeCreationThreadBreak();
                     break;
                 }