X-Git-Url: http://source.jalview.org/gitweb/?a=blobdiff_plain;f=src%2Fjalview%2Fworkers%2FAlignCalcManager2.java;h=1d5c1edf136eba7d59d0843e517f1ac9dbe1b7c5;hb=747167089ecf8d6afc70d417f5a20352e029bd95;hp=eba241a7e64a50411f08eb6fa37925927e9f350c;hpb=d043ce47fc710d3eb2629ba926a8a7417bd67d8c;p=jalview.git diff --git a/src/jalview/workers/AlignCalcManager2.java b/src/jalview/workers/AlignCalcManager2.java index eba241a..1d5c1ed 100644 --- a/src/jalview/workers/AlignCalcManager2.java +++ b/src/jalview/workers/AlignCalcManager2.java @@ -111,19 +111,15 @@ public class AlignCalcManager2 implements AlignCalcManagerI2 task = executor.submit(() -> { try { - Console.debug(format("Worker %s started", - getWorker().getClass().getName())); + Console.debug(format("Worker %s started", getWorker())); getWorker().run(); - Console.debug(format("Worker %s finished", - getWorker().getClass().getName())); + Console.debug(format("Worker %s finished", getWorker())); } catch (InterruptedException e) { - Console.debug(format("Worker %s interrupted", - getWorker().getClass().getName())); + Console.debug(format("Worker %s interrupted", getWorker())); } catch (Throwable th) { - Console.debug(format("Worker %s failed", - getWorker().getClass().getName()), th); + Console.debug(format("Worker %s failed", getWorker()), th); } finally { if (!isRegistered()) @@ -142,8 +138,7 @@ public class AlignCalcManager2 implements AlignCalcManagerI2 { return; } - Console.debug(format("Cancelling worker %s", - getWorker().getClass().getName())); + Console.debug(format("Cancelling worker %s", getWorker())); task.cancel(true); } } @@ -177,7 +172,7 @@ public class AlignCalcManager2 implements AlignCalcManagerI2 "Cannot submit new task if the prevoius one is still running"); } Console.debug( - format("Worker %s queued", getWorker().getClass().getName())); + format("Worker %s queued", getWorker())); final var runnable = new Runnable() { private boolean started = false; @@ -193,26 +188,22 @@ public class AlignCalcManager2 implements AlignCalcManagerI2 { if (!started) { - Console.debug(format("Worker %s started", - getWorker().getClass().getName())); + Console.debug(format("Worker %s started", getWorker())); getWorker().startUp(); started = true; } else if (!completed) { - Console.debug(format("Polling worker %s", - getWorker().getClass().getName())); + Console.debug(format("Polling worker %s", getWorker())); if (getWorker().poll()) { - Console.debug(format("Worker %s finished", - getWorker().getClass().getName())); + Console.debug(format("Worker %s finished", getWorker())); completed = true; } } } catch (Throwable th) { - Console.debug(format("Worker %s failed", - getWorker().getClass().getName()), th); + Console.debug(format("Worker %s failed", getWorker()), th); completed = true; } if (completed) @@ -220,8 +211,7 @@ public class AlignCalcManager2 implements AlignCalcManagerI2 final var worker = getWorker(); if (!isRegistered()) PollableWorkerManager.super.worker = null; - Console.debug(format("Finalizing completed worker %s", - worker.getClass().getName())); + Console.debug(format("Finalizing completed worker %s", worker)); worker.done(); // almost impossible, but the future may be null at this point // let it throw NPE to cancel forcefully @@ -239,8 +229,7 @@ public class AlignCalcManager2 implements AlignCalcManagerI2 { return; } - Console.debug(format("Cancelling worker %s", - getWorker().getClass().getName())); + Console.debug(format("Cancelling worker %s", getWorker())); task.cancel(false); executor.submit(() -> { final var worker = getWorker(); @@ -249,8 +238,7 @@ public class AlignCalcManager2 implements AlignCalcManagerI2 if (worker != null) { worker.cancel(); - Console.debug(format("Finalizing cancelled worker %s", - worker.getClass().getName())); + Console.debug(format("Finalizing cancelled worker %s", worker)); worker.done(); } });