Преглед на файлове

add 设置网桥初始值

18339543638 преди 4 години
родител
ревизия
4066deda92
променени са 1 файла, в които са добавени 1 реда и са изтрити 1 реда
  1. 1 1
      jetlinks-core/src/main/java/org/jetlinks/core/cluster/AbstractClusterUniqueTask.java

+ 1 - 1
jetlinks-core/src/main/java/org/jetlinks/core/cluster/AbstractClusterUniqueTask.java

@@ -110,7 +110,7 @@ public abstract class AbstractClusterUniqueTask<T> implements Serializable, Clus
                         //副本且占据锁资源,解锁
                         if (this.lock.isHeldByThread(Thread.currentThread().getId())) {
                             this.lock.unlock();
-                        }else if(!this.lock.isLocked()){
+                        }else if(!this.isAlive.get()&&!this.lock.isLocked()){
                             fightLock();
                         }
                     });