com.fr.third.jgroups.blocks

类 AbstractConnectionMap<V extends Connection>

java.lang.Object

com.fr.third.jgroups.blocks.AbstractConnectionMap<V>

所有已实现的接口:

ConnectionMap<V>

直接已知子类:

TCPConnectionMap.Mapper

public abstract class AbstractConnectionMap<V extends Connection>
extends java.lang.Object
implements ConnectionMap<V>

嵌套类概要

嵌套类

限定符和类型	类和说明
static interface	AbstractConnectionMap.ConnectionMapListener<V>

字段概要

字段

限定符和类型	字段和说明
protected java.util.List<AbstractConnectionMap.ConnectionMapListener<V>>	conn_listeners
protected java.util.Map<Address,V>	conns
protected ThreadFactory	factory
protected java.util.concurrent.locks.Lock	lock
protected com.fr.third.jgroups.blocks.AbstractConnectionMap.Reaper	reaper
protected long	reaperInterval
protected java.util.concurrent.locks.Lock	sock_creation_lock

构造器概要

构造器

构造器和说明
AbstractConnectionMap(ThreadFactory factory)
AbstractConnectionMap(ThreadFactory factory, long reaperInterval)

方法概要

方法

限定符和类型	方法和说明
void	addConnection(Address address, V conn)
void	addConnectionMapListener(AbstractConnectionMap.ConnectionMapListener<V> cml)
protected void	clear()
java.util.concurrent.locks.Lock	getLock()
int	getNumConnections()
int	getNumOpenConnections()
ThreadFactory	getThreadFactory()
boolean	hasConnection(Address address)
protected void	notifyConnectionClosed(Address address)
protected void	notifyConnectionOpened(Address address, V conn)
java.lang.String	printConnections()
void	removeConnectionIfPresent(Address address, V conn) Only removes the connection if conns.get(address) == conn
void	removeConnectionMapListener(AbstractConnectionMap.ConnectionMapListener<V> cml)
void	retainAll(java.util.Collection<Address> current_mbrs) Removes all connections which are not in current_mbrs
void	start()
void	stop()

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

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

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

getConnection

字段详细资料

conn_listeners

protected final java.util.List<AbstractConnectionMap.ConnectionMapListener<V extends Connection>> conn_listeners

conns

protected final java.util.Map<Address,V extends Connection> conns

lock

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

sock_creation_lock

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

factory

protected final ThreadFactory factory

reaperInterval

protected final long reaperInterval

reaper

protected final com.fr.third.jgroups.blocks.AbstractConnectionMap.Reaper reaper

构造器详细资料

AbstractConnectionMap

public AbstractConnectionMap(ThreadFactory factory)

AbstractConnectionMap

public AbstractConnectionMap(ThreadFactory factory,
                     long reaperInterval)

方法详细资料

getLock

public java.util.concurrent.locks.Lock getLock()

hasConnection

public boolean hasConnection(Address address)

addConnection

public void addConnection(Address address,
                 V conn)

addConnectionMapListener

public void addConnectionMapListener(AbstractConnectionMap.ConnectionMapListener<V> cml)

getNumConnections

public int getNumConnections()

getNumOpenConnections

public int getNumOpenConnections()

printConnections

public java.lang.String printConnections()

getThreadFactory

public ThreadFactory getThreadFactory()

removeConnectionIfPresent

public void removeConnectionIfPresent(Address address,
                             V conn)

Only removes the connection if conns.get(address) == conn

removeConnectionMapListener

public void removeConnectionMapListener(AbstractConnectionMap.ConnectionMapListener<V> cml)

retainAll

public void retainAll(java.util.Collection<Address> current_mbrs)

Removes all connections which are not in current_mbrs

参数:

current_mbrs -

start

public void start()
           throws java.lang.Exception

抛出:

java.lang.Exception

stop

public void stop()

clear

protected void clear()

notifyConnectionClosed

protected void notifyConnectionClosed(Address address)

notifyConnectionOpened

protected void notifyConnectionOpened(Address address,
                          V conn)