com.fr.third.jgroups.protocols

类 CENTRAL_EXECUTOR

java.lang.Object

com.fr.third.jgroups.stack.Protocol

com.fr.third.jgroups.protocols.Executing

com.fr.third.jgroups.protocols.CENTRAL_EXECUTOR

public class CENTRAL_EXECUTOR
extends Executing

This is a central executor service where each request is sent to the coordinator for either a task or a current waiting thread.

从以下版本开始:

2.12.0

作者:

wburns

嵌套类概要

从类继承的嵌套类/接口 com.fr.third.jgroups.protocols.Executing

Executing.ExecutorHeader, Executing.Owner, Executing.Request, Executing.RequestWithThread, Executing.Type

字段概要

字段

限定符和类型	字段和说明
protected java.util.List<Address>	backups
protected Address	coord
protected boolean	is_coord
protected int	num_backups

从类继承的字段 com.fr.third.jgroups.protocols.Executing

_awaitingConsumer, _awaitingReturn, _consumerId, _consumerLock, _consumersAvailable, _requestId, _runnableThreads, _running, _runRequests, _taskBarriers, _tasks, bypass_bundling, counter, local_addr, notifiers, PRESENT, view

从类继承的字段 com.fr.third.jgroups.stack.Protocol

down_prot, ergonomics, id, log, name, stack, stats, up_prot

构造器概要

构造器

构造器和说明
CENTRAL_EXECUTOR()

方法概要

方法

限定符和类型	方法和说明
protected void	copyQueueTo(java.util.List<Address> new_joiners)
java.lang.String	getBackups()
Address	getCoord()
java.lang.String	getCoordinator()
int	getNumberOfBackups()
void	handleView(View view)
boolean	isCoord()
protected void	sendNewConsumerRequest(Executing.Owner sender)
protected void	sendNewRunRequest(Executing.Owner sender)
protected void	sendRemoveConsumerRequest(Executing.Owner sender)
protected void	sendRemoveRunRequest(Executing.Owner sender)
protected void	sendToCoordinator(Executing.Type type, long requestId, Address value)
void	setNumberOfBackups(int num_backups)
protected void	updateBackups(Executing.Type type, Executing.Owner obj)

从类继承的方法 com.fr.third.jgroups.protocols.Executing

addExecutorListener, down, getAddress, getBypassBundling, getView, handleConsumerFoundResponse, handleConsumerReadyRequest, handleConsumerUnreadyRequest, handleExceptionResponse, handleInterruptRequest, handleNewConsumer, handleNewRunRequest, handleRemoveConsumer, handleRemoveRunRequest, handleTaskRejectedResponse, handleTaskRequest, handleTaskSubmittedRequest, handleValueResponse, removeKeyForValue, sendRequest, sendThreadRequest, setBypassBundling, up

从类继承的方法 com.fr.third.jgroups.stack.Protocol

accept, destroy, dumpStats, enableStats, getConfigurableObjects, getDownProtocol, getDownServices, getId, getIdsAbove, getLevel, getName, getProtocolStack, getSocketFactory, getThreadFactory, getTransport, getUpProtocol, getUpServices, getValue, init, isErgonomics, level, parse, printStats, providedDownServices, providedUpServices, requiredDownServices, requiredUpServices, resetStatistics, resetStats, setDownProtocol, setErgonomics, setId, setLevel, setProtocolStack, setSocketFactory, setUpProtocol, setValue, setValues, start, statsEnabled, stop, up

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

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

字段详细资料

num_backups

protected int num_backups

coord

protected Address coord

is_coord

protected boolean is_coord

backups

protected final java.util.List<Address> backups

构造器详细资料

CENTRAL_EXECUTOR

public CENTRAL_EXECUTOR()

方法详细资料

getCoord

public Address getCoord()

isCoord

public boolean isCoord()

getCoordinator

public java.lang.String getCoordinator()

getNumberOfBackups

public int getNumberOfBackups()

setNumberOfBackups

public void setNumberOfBackups(int num_backups)

getBackups

public java.lang.String getBackups()

handleView

public void handleView(View view)

覆盖:

handleView 在类中 Executing

updateBackups

protected void updateBackups(Executing.Type type,
                 Executing.Owner obj)

copyQueueTo

protected void copyQueueTo(java.util.List<Address> new_joiners)

sendToCoordinator

protected void sendToCoordinator(Executing.Type type,
                     long requestId,
                     Address value)

指定者:

sendToCoordinator 在类中 Executing

sendNewRunRequest

protected void sendNewRunRequest(Executing.Owner sender)

指定者:

sendNewRunRequest 在类中 Executing

sendRemoveRunRequest

protected void sendRemoveRunRequest(Executing.Owner sender)

指定者:

sendRemoveRunRequest 在类中 Executing

sendNewConsumerRequest

protected void sendNewConsumerRequest(Executing.Owner sender)

指定者:

sendNewConsumerRequest 在类中 Executing

sendRemoveConsumerRequest

protected void sendRemoveConsumerRequest(Executing.Owner sender)

指定者:

sendRemoveConsumerRequest 在类中 Executing