import saccubus.worker.profile.VideoProfile;
import yukihane.Util;
import yukihane.inqubus.Config;
-import yukihane.inqubus.manager.TaskManager;
+import yukihane.inqubus.manager.TaskManage;
import yukihane.inqubus.model.Target;
import yukihane.inqubus.model.TargetsTableModel;
private static final String FILE_OUTPUTFIELD_TOOLTIP
= "ファイル命名規則入力します。";
private final TargetsTableModel targetModel = new TargetsTableModel();
- private final TaskManager taskManager;
+ private final TaskManage taskManager;
private final DownloadProgressListener downloadProgressListener = new DownloadProgressListener();
private final ConvertProgressListener convertProgressListener = new ConvertProgressListener();
final Config p = Config.INSTANCE;
// TODO コンフィグからスレッド数
- taskManager = new TaskManager(1, 1);
+ taskManager = new TaskManage(1, 1);
}
import saccubus.worker.profile.ConvertProfile;
import saccubus.worker.profile.DownloadProfile;
+
/**
*
* @author yuki
*/
-public class TaskManager {
+public class TaskManage {
private final ExecutorService downloadExecutorService;
private final ExecutorService convertExecutorService;
private final Map<Integer, ManageTarget<DownloadResult>> downloadTargets = new HashMap<>();
private final Map<Integer, ManageTarget<ConvertResult>> convertTargets = new HashMap<>();
- public TaskManager(int maxDownload, int maxConvert) {
+ public TaskManage(int maxDownload, int maxConvert) {
downloadExecutorService = Executors.newFixedThreadPool(maxDownload);
convertExecutorService = Executors.newFixedThreadPool(maxConvert);
}
return false;
}
}
-
class ManageTarget<T> {
private final Request request;