Groovy Documentation

org.gradle.util.queues
Class AbstractBlockingQueueItemConsumer

java.lang.Object
  org.gradle.util.queues.AbstractBlockingQueueItemConsumer
All Implemented Interfaces:
java.lang.Runnable

class AbstractBlockingQueueItemConsumer
extends java.lang.Object

author:
Tom Eyckmans


Constructor Summary
protected AbstractBlockingQueueItemConsumer(BlockingQueue toConsumeQueue, long pollTimeout, TimeUnit pollTimeoutTimeUnit)

 
Method Summary
protected boolean consume(T queueItem)

java.lang.Throwable getEndCause()

boolean isEnded()

void run()

protected void setUp()

void stopConsuming()

protected void tearDown()

 
Methods inherited from class java.lang.Object
hashCode, getClass, equals, toString, wait, wait, wait, notify, notifyAll
 

Constructor Detail

AbstractBlockingQueueItemConsumer

protected AbstractBlockingQueueItemConsumer(BlockingQueue toConsumeQueue, long pollTimeout, TimeUnit pollTimeoutTimeUnit)


 
Method Detail

consume

protected boolean consume(T queueItem)


getEndCause

public java.lang.Throwable getEndCause()


isEnded

public boolean isEnded()


run

public final void run()


setUp

protected void setUp()


stopConsuming

public void stopConsuming()


tearDown

protected void tearDown()


 

Groovy Documentation