From 4c974ca21d544634097b4d287c0f98bfacdefc55 Mon Sep 17 00:00:00 2001 From: Simon Rettberg Date: Mon, 28 Sep 2015 18:01:35 +0200 Subject: Handle some uncaught runtime errors, fix race condition --- daemon/src/main/java/org/openslx/taskmanager/main/Taskmanager.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) (limited to 'daemon') diff --git a/daemon/src/main/java/org/openslx/taskmanager/main/Taskmanager.java b/daemon/src/main/java/org/openslx/taskmanager/main/Taskmanager.java index 1325dca..69c190a 100644 --- a/daemon/src/main/java/org/openslx/taskmanager/main/Taskmanager.java +++ b/daemon/src/main/java/org/openslx/taskmanager/main/Taskmanager.java @@ -38,9 +38,7 @@ public class Taskmanager implements FinishCallback, Runnable private final Map> tasks = new ConcurrentHashMap<>(); /** - * All the running/finished task instances. The mainloop will call wait() on this and this object - * is notified as soon as the mainloop should check if there is any task available that can be - * run. + * All the running/finished task instances. */ private final Map instances = new ConcurrentHashMap<>(); @@ -166,6 +164,7 @@ public class Taskmanager implements FinishCallback, Runnable if ( task.canStart() ) { log.debug( "Started Task " + task.getClass().getSimpleName() + " (" + task.getId() + ")" ); threadPool.execute( task ); + task.markAsStarting(); } } } catch ( RejectedExecutionException e ) { -- cgit v1.2.3-55-g7522