fix: use double check to fix concurrent problem (#1909)

Co-authored-by: zhangwenhe <zhangwh@ehualu.com>
iluwatar · Nov 11, 2021 · 89b2072 · 89b2072
1 parent 0a7b524
commit 89b2072
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/leader-followers/src/main/java/com/iluwatar/leaderfollowers/Worker.java b/leader-followers/src/main/java/com/iluwatar/leaderfollowers/Worker.java
@@ -57,9 +57,11 @@ public void run() {
       try {
         if (workCenter.getLeader() != null && !workCenter.getLeader().equals(this)) {
           synchronized (workCenter) {
-            workCenter.wait();
+            if (workCenter.getLeader() != null && !workCenter.getLeader().equals(this)) {
+              workCenter.wait();
+              continue;
+            }
           }
-          continue;
         }
         final Task task = taskSet.getTask();
         synchronized (workCenter) {