add 规则引擎集群

jetlinks-components/rule-engine-component/src/main/java/org/jetlinks/community/rule/engine/cluster/ClusterUniqueTask.java

@@ -244,6 +244,12 @@ class ClusterUniqueTask implements Task ,Serializable{
                             isAlive.set(false);
                             workerId=null;
                         }))
+                        .doOnNext(__->{
+                            if(executor.getState().equals(State.running)){
+                                this.taskState=State.running;
+                                executor.pause();
+                            }
+                        })
                         .publishOn(Schedulers.boundedElastic())
                         .flatMap(obj -> {
                             if(generatePingMsgDisposable!=null&&!generatePingMsgDisposable.isDisposed()){