From 62b938d31692414f86c8f306b855e2f3bc7cf536 Mon Sep 17 00:00:00 2001
From: Kai Reinhard <K.Reinhard@micromata.de>
Date: Fri, 28 Dec 2018 11:16:30 +0000
Subject: [PATCH] Job queueing...
---
borgbutler-core/src/main/java/de/micromata/borgbutler/jobs/AbstractJob.java | 8 ++++++--
1 files changed, 6 insertions(+), 2 deletions(-)
diff --git a/borgbutler-core/src/main/java/de/micromata/borgbutler/jobs/AbstractJob.java b/borgbutler-core/src/main/java/de/micromata/borgbutler/jobs/AbstractJob.java
index 92515a6..9941110 100644
--- a/borgbutler-core/src/main/java/de/micromata/borgbutler/jobs/AbstractJob.java
+++ b/borgbutler-core/src/main/java/de/micromata/borgbutler/jobs/AbstractJob.java
@@ -6,7 +6,9 @@
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public abstract class AbstractJob {
+import java.util.concurrent.Future;
+
+public abstract class AbstractJob<T> {
private Logger logger = LoggerFactory.getLogger(AbstractJob.class);
public enum Status {DONE, RUNNING, QUEUED, STOPPED, FAILED}
@Getter
@@ -23,6 +25,8 @@
@Setter
private String statusText;
+ private Future<T> future;
+
protected void failed() {
if (this.status != Status.RUNNING) {
logger.error("Internal error, illegal state! You shouldn't set the job status to FAILED if not in status RUNNING: " + this.status);
@@ -40,7 +44,7 @@
return false;
}
- public abstract void execute();
+ public abstract T execute();
/**
* A job is identified by this id. If a job with the same id is already queued (not yet finished), this job will
--
Gitblit v1.10.0