Package com.atlassian.bamboo.util.concurrent

Class BlockingCircularFifoQueue<E>

java.lang.Object

com.atlassian.bamboo.util.concurrent.BlockingCircularFifoQueue<E>

public class BlockingCircularFifoQueue<E>
extends Object

A CircularFifoQueue with non blocking additions and block-on-empty retrievals.

Constructor Summary

Constructors

Constructor	Description
BlockingCircularFifoQueue(int size)

Method Summary

Modifier and Type	Method	Description
void	put(E message)
E	take()

Methods inherited from class java.lang.Object

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

Constructor Details

BlockingCircularFifoQueue

public BlockingCircularFifoQueue(int size)

Method Details

take

public E take()
       throws InterruptedException

Throws:

InterruptedException

put

public void put(E message)