|
|
@@ -231,6 +231,7 @@ class RuleAbstractClusterUniqueTask extends AbstractClusterUniqueTask implements
|
|
|
return Mono.<Void>fromRunnable(this.executor::reload)
|
|
|
.subscribeOn(Schedulers.boundedElastic());
|
|
|
case SHUTDOWN:
|
|
|
+ this.taskState=State.shutdown;
|
|
|
this.executor.shutdown();
|
|
|
//解锁
|
|
|
this.getHeldLockThread().execute(()->this.getLock().unlock());
|