X-Git-Url: http://source.jalview.org/gitweb/?a=blobdiff_plain;f=src%2Fjalview%2Fworkers%2FAlignCalcManager.java;fp=src%2Fjalview%2Fworkers%2FAlignCalcManager.java;h=19673753ac029aa1b83fc4551c6191a605a1a650;hb=8dcca4766ed3d696a6160565ef43e21662557008;hp=3a3dc440dbdf2ed3103a0c4bcc4ac965d1fc7f02;hpb=4ad3af6fae856880fea0a982e6f0dc65f3109567;p=jalview.git diff --git a/src/jalview/workers/AlignCalcManager.java b/src/jalview/workers/AlignCalcManager.java index 3a3dc44..1967375 100644 --- a/src/jalview/workers/AlignCalcManager.java +++ b/src/jalview/workers/AlignCalcManager.java @@ -78,6 +78,19 @@ public class AlignCalcManager implements AlignCalcManagerI canUpdate = new HashSet<>(); } + private static boolean listContains(List upd, + AlignCalcWorkerI worker) + { + // avoid use of 'Contains' in case + for (AlignCalcWorkerI _otherworker : upd) + { + if (_otherworker == upd) + { + return true; + } + } + return false; + } @Override public void notifyStart(AlignCalcWorkerI worker) { @@ -91,18 +104,16 @@ public class AlignCalcManager implements AlignCalcManagerI } synchronized (upd) { - // avoid use of 'Contains' in case - for (AlignCalcWorkerI _otherworker : upd) + if (listContains(upd, worker)) { - if (_otherworker == upd) - { - Cache.log.debug( + Cache.log.debug( "Ignoring second call to notifyStart for worker " + worker); - return; - } } + else + { upd.add(worker); + } } } } @@ -139,7 +150,7 @@ public class AlignCalcManager implements AlignCalcManagerI { synchronized (inProgress) { - if (inProgress.contains(worker)) + if (listContains(inProgress, worker)) { return false; // worker is already working, so ask caller to wait around } @@ -156,7 +167,7 @@ public class AlignCalcManager implements AlignCalcManagerI { synchronized (inProgress) { - // System.err.println("Worker " + worker + " marked as complete."); + Cache.log.debug("Worker " + worker + " marked as complete."); inProgress.remove(worker); List upd = updating.get(worker.getClass()); if (upd != null) @@ -224,7 +235,7 @@ public class AlignCalcManager implements AlignCalcManagerI { synchronized (restartable) { - if (!restartable.contains(worker)) + if (!listContains(restartable, worker)) { restartable.add(worker); }