Package com.liferay.portal.kernel.cluster

Class FutureClusterResponses

java.lang.Object

java.util.concurrent.FutureTask<ClusterNodeResponses>

com.liferay.petra.concurrent.DefaultNoticeableFuture<ClusterNodeResponses>

com.liferay.portal.kernel.cluster.FutureClusterResponses

All Implemented Interfaces:

com.liferay.petra.concurrent.NoticeableFuture<ClusterNodeResponses>, Runnable, Future<ClusterNodeResponses>, RunnableFuture<ClusterNodeResponses>

public class FutureClusterResponses
extends com.liferay.petra.concurrent.DefaultNoticeableFuture<ClusterNodeResponses>

Author:

Tina Tian

Nested Class Summary

Nested classes/interfaces inherited from interface java.util.concurrent.Future

Future.State

Constructor Summary

Constructors

Constructor	Description
FutureClusterResponses(Set<String> clusterNodeIds)

Method Summary

Modifier and Type	Method	Description
boolean	addClusterNodeResponse(ClusterNodeResponse clusterNodeResponse)
ClusterNodeResponses	get()
ClusterNodeResponses	get(long timeout, TimeUnit unit)
BlockingQueue<ClusterNodeResponse>	getPartialResults()

Methods inherited from class com.liferay.petra.concurrent.DefaultNoticeableFuture

addFutureListener, done, removeFutureListener, set, setException

Methods inherited from class java.util.concurrent.FutureTask

cancel, exceptionNow, isCancelled, isDone, resultNow, run, runAndReset, state, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.concurrent.Future

cancel, exceptionNow, isCancelled, isDone, resultNow, state

Constructor Details

FutureClusterResponses

public FutureClusterResponses(Set<String> clusterNodeIds)

Method Details

addClusterNodeResponse

public boolean addClusterNodeResponse(ClusterNodeResponse clusterNodeResponse)

get

public ClusterNodeResponses get()
                         throws InterruptedException

Specified by:

get in interface Future<ClusterNodeResponses>

Overrides:

get in class FutureTask<ClusterNodeResponses>

Throws:

InterruptedException

get

public ClusterNodeResponses get(long timeout,
 TimeUnit unit)
                         throws InterruptedException,
TimeoutException

Specified by:

get in interface Future<ClusterNodeResponses>

Overrides:

get in class FutureTask<ClusterNodeResponses>

Throws:

InterruptedException

TimeoutException

getPartialResults

public BlockingQueue<ClusterNodeResponse> getPartialResults()