类 com.fr.third.jgroups.util.Table
的使用

使用Table的程序包

程序包	说明
com.fr.third.jgroups.protocols	Provides implementations of transport protocols which are responsible for sending and receiving messages to/from the network.
com.fr.third.jgroups.protocols.pbcast	Supports probabilistic broadcasts.

com.fr.third.jgroups.protocols中Table的使用

声明为Table的com.fr.third.jgroups.protocols中的字段

限定符和类型	字段和说明
protected Table<Message>	UNICAST3.Entry.msgs
protected Table<Message>	UNICAST2.ReceiverEntry.received_msgs
protected Table<Message>	UNICAST.ReceiverEntry.received_msgs
protected Table<Message>	SEQUENCER2.received_msgs

参数类型为Table的com.fr.third.jgroups.protocols中的方法

限定符和类型	方法和说明
protected void	UNICAST3.processInternalMessage(Table<Message> win, Address sender)
protected void	UNICAST3.removeAndDeliver(java.util.concurrent.atomic.AtomicBoolean processing, Table<Message> win, Address sender) Try to remove as many messages as possible from the table as pass them up.
protected int	UNICAST.removeAndDeliver(java.util.concurrent.atomic.AtomicBoolean processing, Table<Message> win, Address sender) Try to remove as many messages as possible from the table as pass them up.
protected void	SEQUENCER2.removeAndDeliver(java.util.concurrent.atomic.AtomicBoolean processing, Table<Message> win, Address sender)
protected void	UNICAST2.removeAndPassUp(Table<Message> win, Address sender) Try to remove as many messages as possible and pass them up.

参数类型为Table的com.fr.third.jgroups.protocols中的构造器

构造器和说明
UNICAST.ReceiverEntry(Table<Message> received_msgs, short recv_conn_id)
UNICAST2.ReceiverEntry(Table<Message> received_msgs, short recv_conn_id)
UNICAST3.Entry(short conn_id, Table<Message> msgs)
UNICAST3.ReceiverEntry(Table<Message> received_msgs, short recv_conn_id)

com.fr.third.jgroups.protocols.pbcast中Table的使用

类型参数类型为Table的com.fr.third.jgroups.protocols.pbcast中的字段

限定符和类型	字段和说明
protected java.util.concurrent.ConcurrentMap<Address,Table<Message>>	NAKACK2.xmit_table Map to store sent and received messages (keyed by sender)

返回Table的com.fr.third.jgroups.protocols.pbcast中的方法

限定符和类型	方法和说明
protected Table<Message>	NAKACK2.createTable(long initial_seqno)
Table<Message>	NAKACK2.getWindow(Address sender) Returns the receive window for sender; only used for testing.

参数类型为Table的com.fr.third.jgroups.protocols.pbcast中的方法

限定符和类型	方法和说明
protected void	NAKACK2.removeAndPassUp(Table<Message> buf, Address sender, boolean loopback, AsciiString cluster_name) Efficient way of checking whether another thread is already processing messages from sender.
protected static long	NAKACK2.sizeOfAllMessages(Table<Message> buf, boolean include_headers)