From 3522ba6a3998c7248ae8bbdadda613c5d5954e1e Mon Sep 17 00:00:00 2001
From: Kai Reinhard <K.Reinhard@micromata.de>
Date: Sat, 29 Dec 2018 22:33:24 +0000
Subject: [PATCH] Unchecked warnings fixed.
---
borgbutler-core/src/main/java/de/micromata/borgbutler/jobs/JobQueue.java | 18 +++++++++---------
1 files changed, 9 insertions(+), 9 deletions(-)
diff --git a/borgbutler-core/src/main/java/de/micromata/borgbutler/jobs/JobQueue.java b/borgbutler-core/src/main/java/de/micromata/borgbutler/jobs/JobQueue.java
index 8cd3ac2..fae9913 100644
--- a/borgbutler-core/src/main/java/de/micromata/borgbutler/jobs/JobQueue.java
+++ b/borgbutler-core/src/main/java/de/micromata/borgbutler/jobs/JobQueue.java
@@ -12,15 +12,15 @@
public class JobQueue<T> {
private static final int MAX_DONE_JOBS_SIZE = 50;
private Logger log = LoggerFactory.getLogger(JobQueue.class);
- private List<AbstractJob> queue = new ArrayList<>();
- private List<AbstractJob> doneJobs = new LinkedList<>();
+ private List<AbstractJob<T>> queue = new ArrayList<>();
+ private List<AbstractJob<T>> doneJobs = new LinkedList<>();
private ExecutorService executorService = Executors.newSingleThreadExecutor();
public int getQueueSize() {
return queue.size();
}
- public List<AbstractJob> getDoneJobs() {
+ public List<AbstractJob<T>> getDoneJobs() {
return Collections.unmodifiableList(doneJobs);
}
@@ -30,9 +30,9 @@
* @param job
* @return The given job (if it's not already running or queued), otherwise the already running or queued job.
*/
- public AbstractJob append(AbstractJob job) {
+ public AbstractJob append(AbstractJob<T> job) {
synchronized (queue) {
- for (AbstractJob queuedJob : queue) {
+ for (AbstractJob<T> queuedJob : queue) {
if (Objects.equals(queuedJob.getId(), job.getId())) {
log.info("Job is already in the queue, don't run twice (OK): " + job.getId());
return queuedJob;
@@ -69,9 +69,9 @@
if (queue.isEmpty()) {
return;
}
- Iterator<AbstractJob> it = queue.iterator();
+ Iterator<AbstractJob<T>> it = queue.iterator();
while (it.hasNext()) {
- AbstractJob job = it.next();
+ AbstractJob<T> job = it.next();
if (job.isFinished()) {
it.remove();
doneJobs.add(0, job);
@@ -84,9 +84,9 @@
}
private class CallableTask implements Callable<JobResult<T>> {
- private AbstractJob job;
+ private AbstractJob<T> job;
- private CallableTask(AbstractJob job) {
+ private CallableTask(AbstractJob<T> job) {
this.job = job;
}
--
Gitblit v1.10.0