diff options
author | Trygve Laugstøl <trygvis@inamo.no> | 2013-04-30 07:12:56 +0200 |
---|---|---|
committer | Trygve Laugstøl <trygvis@inamo.no> | 2013-04-30 07:12:56 +0200 |
commit | 0a0b01664cf620f983549999b24a7740594a57d4 (patch) | |
tree | 3a226f4e33ec986f3bae598a547690b3f99e2e8d /src/main/java/io/trygvis/queue/TaskRef.java | |
download | jdbc-queue-0a0b01664cf620f983549999b24a7740594a57d4.tar.gz jdbc-queue-0a0b01664cf620f983549999b24a7740594a57d4.tar.bz2 jdbc-queue-0a0b01664cf620f983549999b24a7740594a57d4.tar.xz jdbc-queue-0a0b01664cf620f983549999b24a7740594a57d4.zip |
Diffstat (limited to 'src/main/java/io/trygvis/queue/TaskRef.java')
-rw-r--r-- | src/main/java/io/trygvis/queue/TaskRef.java | 23 |
1 files changed, 23 insertions, 0 deletions
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); + } + } +} |