From 0a0b01664cf620f983549999b24a7740594a57d4 Mon Sep 17 00:00:00 2001
From: Trygve Laugstøl <trygvis@inamo.no>
Date: Tue, 30 Apr 2013 07:12:56 +0200
Subject: o Initial import.

---
 src/main/java/io/trygvis/queue/TaskRef.java | 23 +++++++++++++++++++++++
 1 file changed, 23 insertions(+)
 create mode 100644 src/main/java/io/trygvis/queue/TaskRef.java

(limited to 'src/main/java/io/trygvis/queue/TaskRef.java')

diff --git a/src/main/java/io/trygvis/queue/TaskRef.java b/src/main/java/io/trygvis/queue/TaskRef.java
new file mode 100644
index 0000000..e465ee7
--- /dev/null
+++ b/src/main/java/io/trygvis/queue/TaskRef.java
@@ -0,0 +1,23 @@
+package io.trygvis.queue;
+
+/**
+ * TODO: Implement waitForSuccess(). Rename waitFor to waitForAny(). Let waitForAny() throw TargetInvocationException
+ * which contains the exception that the task threw.
+ */
+public class TaskRef {
+    private Task task;
+
+    public TaskRef(Task task) {
+        this.task = task;
+    }
+
+    public Task getTask() {
+        return task;
+    }
+
+    public void waitFor(int timeout) throws InterruptedException {
+        synchronized (this) {
+            wait(timeout);
+        }
+    }
+}
-- 
cgit v1.2.3