public class DefaultSshFuture<T extends SshFuture> extends Object implements SshFuture<T>
SshFuture
.Constructor and Description |
---|
DefaultSshFuture(Object lock)
Creates a new instance.
|
Modifier and Type | Method and Description |
---|---|
T |
addListener(SshFutureListener<T> listener)
Adds an event listener which is notified when
this future is completed.
|
T |
await()
Wait for the asynchronous operation to complete.
|
boolean |
await(long timeoutMillis)
Wait for the asynchronous operation to complete with the specified timeout.
|
boolean |
await(long timeout,
TimeUnit unit)
Wait for the asynchronous operation to complete with the specified timeout.
|
T |
awaitUninterruptibly()
Wait for the asynchronous operation to complete uninterruptibly.
|
boolean |
awaitUninterruptibly(long timeoutMillis)
Wait for the asynchronous operation to complete with the specified timeout
uninterruptibly.
|
boolean |
awaitUninterruptibly(long timeout,
TimeUnit unit)
Wait for the asynchronous operation to complete with the specified timeout
uninterruptibly.
|
void |
cancel() |
protected Object |
getValue()
Returns the result of the asynchronous operation.
|
boolean |
isCanceled() |
boolean |
isDone()
Returns if the asynchronous operation is completed.
|
T |
removeListener(SshFutureListener<T> listener)
Removes an existing event listener so it won't be notified when
the future is completed.
|
void |
setValue(Object newValue)
Sets the result of the asynchronous operation, and mark it as finished.
|
public DefaultSshFuture(Object lock)
public T await() throws InterruptedException
await
in interface SshFuture<T extends SshFuture>
InterruptedException
public boolean await(long timeout, TimeUnit unit) throws InterruptedException
await
in interface SshFuture<T extends SshFuture>
InterruptedException
public boolean await(long timeoutMillis) throws InterruptedException
await
in interface SshFuture<T extends SshFuture>
InterruptedException
public T awaitUninterruptibly()
awaitUninterruptibly
in interface SshFuture<T extends SshFuture>
public boolean awaitUninterruptibly(long timeout, TimeUnit unit)
awaitUninterruptibly
in interface SshFuture<T extends SshFuture>
public boolean awaitUninterruptibly(long timeoutMillis)
awaitUninterruptibly
in interface SshFuture<T extends SshFuture>
public boolean isDone()
public void setValue(Object newValue)
protected Object getValue()
public T addListener(SshFutureListener<T> listener)
addListener
in interface SshFuture<T extends SshFuture>
public T removeListener(SshFutureListener<T> listener)
removeListener
in interface SshFuture<T extends SshFuture>
public boolean isCanceled()
public void cancel()
Copyright © 2008-2014 The Apache Software Foundation. All Rights Reserved.