org.modeshape.common.collection.ring

Class RingBuffer.ConsumerRunner

java.lang.Object

org.modeshape.common.collection.ring.RingBuffer.ConsumerRunner

All Implemented Interfaces:

Runnable

Enclosing class:

RingBuffer<T,C>

protected class RingBuffer.ConsumerRunner
extends Object
implements Runnable

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ConsumerRunner(C consumer, int timesToRetryUponTimeout)

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	equals(Object obj)
protected C	getConsumer()
protected Pointer	getPointer()
int	hashCode()
void	run()
protected void	waitForCompletion()

Methods inherited from class java.lang.Object

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

Constructor Detail

ConsumerRunner

protected ConsumerRunner(C consumer,
                         int timesToRetryUponTimeout)

Method Detail

getPointer

protected Pointer getPointer()

getConsumer

protected C getConsumer()

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

close

public void close()

waitForCompletion

protected void waitForCompletion()

run

public void run()

Specified by:

run in interface Runnable