com.fr.third.jgroups.blocks

类 Request

java.lang.Object

com.fr.third.jgroups.blocks.Request

所有已实现的接口:

RspCollector, NotifyingFuture, java.util.concurrent.Future

直接已知子类:

GroupRequest, UnicastRequest

public abstract class Request
extends java.lang.Object
implements RspCollector, NotifyingFuture

Abstract class for a unicast or multicast request

作者:

Bela Ban

字段概要

字段

限定符和类型	字段和说明
protected boolean	block_for_results
protected java.util.concurrent.locks.Condition	completed Is set as soon as the request has received all required responses
protected RequestCorrelator	corr
protected boolean	done
protected FutureListener	listener
protected java.util.concurrent.locks.Lock	lock
protected static Log	log
protected RequestOptions	options
protected long	req_id
protected static java.util.concurrent.atomic.AtomicLong	REQUEST_ID To generate unique request IDs (see getRequestId())
protected Message	request_msg

构造器概要

构造器

构造器和说明
Request(Message request, RequestCorrelator corr, RequestOptions options)

方法概要

方法

限定符和类型	方法和说明
boolean	cancel(boolean mayInterruptIfRunning)
protected void	checkCompletion(java.util.concurrent.Future future)
boolean	execute()
boolean	getBlockForResults()
protected static long	getRequestId() Generates a new unique request ID
boolean	getResponsesComplete()
boolean	isCancelled()
boolean	isDone()
abstract void	receiveResponse(java.lang.Object response_value, Address sender, boolean is_exception)
protected abstract boolean	responsesComplete()
protected boolean	responsesComplete(long timeout) This method runs with lock locked (called by execute()).
protected abstract void	sendRequest()
void	setBlockForResults(boolean block_for_results)
NotifyingFuture	setListener(FutureListener listener) Attaches a listener and returns the same future instance, to allow for 'building' futures.
void	setResponseFilter(RspFilter filter)
abstract void	siteUnreachable(java.lang.String site)
abstract void	suspect(Address mbr)
java.lang.String	toString()
abstract void	viewChange(View new_view)
protected boolean	waitForResults(long timeout)

从类继承的方法 java.lang.Object

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

从接口继承的方法 com.fr.third.jgroups.blocks.RspCollector

transportClosed

从接口继承的方法 java.util.concurrent.Future

get, get

字段详细资料

log

protected static final Log log

REQUEST_ID

protected static final java.util.concurrent.atomic.AtomicLong REQUEST_ID

To generate unique request IDs (see getRequestId())

lock

protected final java.util.concurrent.locks.Lock lock

completed

protected final java.util.concurrent.locks.Condition completed

Is set as soon as the request has received all required responses

request_msg

protected final Message request_msg

corr

protected final RequestCorrelator corr

options

protected final RequestOptions options

done

protected volatile boolean done

block_for_results

protected boolean block_for_results

req_id

protected final long req_id

listener

protected volatile FutureListener listener

构造器详细资料

Request

public Request(Message request,
       RequestCorrelator corr,
       RequestOptions options)

方法详细资料

setResponseFilter

public void setResponseFilter(RspFilter filter)

getBlockForResults

public boolean getBlockForResults()

setBlockForResults

public void setBlockForResults(boolean block_for_results)

setListener

public NotifyingFuture setListener(FutureListener listener)

从接口复制的说明: NotifyingFuture

Attaches a listener and returns the same future instance, to allow for 'building' futures.

指定者:

setListener 在接口中 NotifyingFuture

参数:

listener - listener to attach

返回:

the same future instance

execute

public boolean execute()
                throws java.lang.Exception

抛出:

java.lang.Exception

sendRequest

protected abstract void sendRequest()
                             throws java.lang.Exception

抛出:

java.lang.Exception

receiveResponse

public abstract void receiveResponse(java.lang.Object response_value,
                   Address sender,
                   boolean is_exception)

指定者:

receiveResponse 在接口中 RspCollector

viewChange

public abstract void viewChange(View new_view)

指定者:

viewChange 在接口中 RspCollector

suspect

public abstract void suspect(Address mbr)

指定者:

suspect 在接口中 RspCollector

siteUnreachable

public abstract void siteUnreachable(java.lang.String site)

指定者:

siteUnreachable 在接口中 RspCollector

responsesComplete

protected abstract boolean responsesComplete()

getResponsesComplete

public boolean getResponsesComplete()

cancel

public boolean cancel(boolean mayInterruptIfRunning)

指定者:

cancel 在接口中 java.util.concurrent.Future

isCancelled

public boolean isCancelled()

指定者:

isCancelled 在接口中 java.util.concurrent.Future

isDone

public boolean isDone()

指定者:

isDone 在接口中 java.util.concurrent.Future

toString

public java.lang.String toString()

覆盖:

toString 在类中 java.lang.Object

checkCompletion

protected void checkCompletion(java.util.concurrent.Future future)

getRequestId

protected static long getRequestId()

Generates a new unique request ID

responsesComplete

protected boolean responsesComplete(long timeout)
                             throws java.lang.InterruptedException

This method runs with lock locked (called by execute()).

抛出:

java.lang.InterruptedException

waitForResults

protected boolean waitForResults(long timeout)