summaryrefslogtreecommitdiffstats
path: root/src/main/java/org/openslx/taskmanager/tasks/DownloadFiles.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/org/openslx/taskmanager/tasks/DownloadFiles.java')
-rw-r--r--src/main/java/org/openslx/taskmanager/tasks/DownloadFiles.java4
1 files changed, 3 insertions, 1 deletions
diff --git a/src/main/java/org/openslx/taskmanager/tasks/DownloadFiles.java b/src/main/java/org/openslx/taskmanager/tasks/DownloadFiles.java
index be3569d..ae67ec8 100644
--- a/src/main/java/org/openslx/taskmanager/tasks/DownloadFiles.java
+++ b/src/main/java/org/openslx/taskmanager/tasks/DownloadFiles.java
@@ -26,6 +26,7 @@ import org.apache.commons.io.FilenameUtils;
import org.openslx.satserver.util.Exec;
import org.openslx.satserver.util.Util;
import org.openslx.taskmanager.api.AbstractTask;
+import org.openslx.util.PrioThreadFactory;
import com.google.gson.annotations.Expose;
@@ -120,7 +121,8 @@ public class DownloadFiles extends AbstractTask
}
final Path tmpDir = td;
- ExecutorService tp = Executors.newFixedThreadPool( files.length > 3 ? 3 : files.length );
+ ExecutorService tp = Executors.newFixedThreadPool( files.length > 3 ? 3 : files.length,
+ new PrioThreadFactory( "DL" ) );
final AtomicBoolean retval = new AtomicBoolean( true );
for ( final Task t : this.files ) {
final FileStatus status = new FileStatus();