org.jgroups.blocks
Class TCPConnectionMap.TCPConnection.ConnectionPeerReceiver

java.lang.Object
  org.jgroups.blocks.TCPConnectionMap.TCPConnection.ConnectionPeerReceiver

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

TCPConnectionMap.TCPConnection

protected class TCPConnectionMap.TCPConnection.ConnectionPeerReceiver
extends java.lang.Object
implements java.lang.Runnable

Field Summary

protected java.util.concurrent.atomic.AtomicBoolean	receiving
protected java.lang.Thread	recv

Constructor Summary

TCPConnectionMap.TCPConnection.ConnectionPeerReceiver(ThreadFactory f)

Method Summary

boolean	canRun()
boolean	isRunning()
void	run()
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

recv

protected final java.lang.Thread recv

receiving

protected final java.util.concurrent.atomic.AtomicBoolean receiving

Constructor Detail

TCPConnectionMap.TCPConnection.ConnectionPeerReceiver

public TCPConnectionMap.TCPConnection.ConnectionPeerReceiver(ThreadFactory f)

Method Detail

start

public void start()

stop

public void stop()

isRunning

public boolean isRunning()

canRun

public boolean canRun()

run

public void run()

Specified by:

run in interface java.lang.Runnable