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

Update RandomDataSourceSelector.java

Browse Source 
if threads are running, interrupt them first, and then start new threads
This commit is contained in:
DigitalSonic
2019-11-05 18:00:48 +08:00
parent b6e6812d9d
commit ea16b58cc0
1 changed files with 12 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/alibaba/druid/pool/ha/selector/RandomDataSourceSelector.java
+12 -2
View File
@@ -50,6 +50,8 @@ public class RandomDataSourceSelector implements DataSourceSelector {
private HighAvailableDataSource highAvailableDataSource;
private RandomDataSourceValidateThread validateThread;
private RandomDataSourceRecoverThread recoverThread;
private Thread runningValidateThread;
private Thread runningRecoverThread;
private int checkingIntervalSeconds = 15;
private int recoveryIntervalSeconds = 120;
@@ -161,14 +163,22 @@ public class RandomDataSourceSelector implements DataSourceSelector {
validateThread.setValidationSleepSeconds(validationSleepSeconds);
validateThread.setBlacklistThreshold(blacklistThreshold);
}
new Thread(validateThread, "RandomDataSourceSelector-validate-thread").start();
if (runningValidateThread != null) {
runningValidateThread.interrupt();
}
runningValidateThread = new Thread(validateThread, "RandomDataSourceSelector-validate-thread");
runningValidateThread.start();
if (recoverThread == null) {
recoverThread = new RandomDataSourceRecoverThread(this);
recoverThread.setSleepSeconds(recoveryIntervalSeconds);
recoverThread.setValidationSleepSeconds(validationSleepSeconds);
}
new Thread(recoverThread, "RandomDataSourceSelector-recover-thread").start();
if (runningRecoverThread != null) {
runningRecoverThread.interrupt();
}
runningRecoverThread = new Thread(recoverThread, "RandomDataSourceSelector-recover-thread");
runningRecoverThread.start();
}
private Collection<DataSource> removeBlackList(Map<String, DataSource> dataSourceMap) {