diff options
Diffstat (limited to 'src/main/java/org/openslx/taskmanager/tasks/RemoteExec.java')
| -rw-r--r-- | src/main/java/org/openslx/taskmanager/tasks/RemoteExec.java | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/main/java/org/openslx/taskmanager/tasks/RemoteExec.java b/src/main/java/org/openslx/taskmanager/tasks/RemoteExec.java index cc7631d..b60b990 100644 --- a/src/main/java/org/openslx/taskmanager/tasks/RemoteExec.java +++ b/src/main/java/org/openslx/taskmanager/tasks/RemoteExec.java @@ -18,6 +18,7 @@ import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.openslx.satserver.util.Util; import org.openslx.taskmanager.api.AbstractTask; +import org.openslx.util.PrioThreadFactory; import com.google.gson.annotations.Expose; import com.jcraft.jsch.ChannelExec; @@ -117,7 +118,8 @@ public class RemoteExec extends AbstractTask @Override protected boolean execute() { - ExecutorService tp = Executors.newFixedThreadPool( clients.length > 4 ? 4 : clients.length ); + ExecutorService tp = Executors.newFixedThreadPool( clients.length > 4 ? 4 : clients.length, + new PrioThreadFactory( "RemExec" ) ); for ( final Client client : clients ) { if ( Util.isEmpty( client.clientip ) ) continue; |