diff --git a/leader-followers/src/main/java/com/iluwatar/leaderfollowers/Worker.java b/leader-followers/src/main/java/com/iluwatar/leaderfollowers/Worker.java index 6c7caed24..21326bb0a 100644 --- 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 class Worker implements Runnable { 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) {