#296 fix thread pool reject problem

vipshop · Dec 11, 2017 · d5f6085 · d5f6085
1 parent 5d45af9
commit d5f6085
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/saturn-core/src/main/java/com/vip/saturn/job/internal/sharding/ShardingListenerManager.java b/saturn-core/src/main/java/com/vip/saturn/job/internal/sharding/ShardingListenerManager.java
@@ -143,6 +143,9 @@ class NecessaryWatcher implements CuratorWatcher {
 
 		@Override
 		public void process(WatchedEvent event) throws Exception {
+			if (isShutdown) {
+				return;
+			}
 			switch (event.getType()) {
 			case NodeCreated:
 			case NodeDataChanged: // NOSONAR