Package com.epam.common.thread.queue

Class SynchronizeBlockingQueue<E>

java.lang.Object

com.epam.common.thread.queue.SynchronizeBlockingQueue<E>

All Implemented Interfaces:

SimpleBlockingQueue<E>

public class SynchronizeBlockingQueue<E>
extends Object
implements SimpleBlockingQueue<E>

User: Mykhailo_Sereda Date: 05.11.12 Time: 18:42

Constructor Summary

Constructors

Constructor	Description
SynchronizeBlockingQueue(int limit)

Method Summary

Modifier and Type	Method	Description
boolean	isEmpty()
void	put(E item)
int	size()	Returns the number of elements in this queue.
E	take()

Methods inherited from class java.lang.Object

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

Constructor Details

SynchronizeBlockingQueue

public SynchronizeBlockingQueue(int limit)

Method Details

put

public void put(E item)
         throws InterruptedException

Specified by:

put in interface SimpleBlockingQueue<E>

Throws:

InterruptedException

take

public E take()
       throws InterruptedException

Specified by:

take in interface SimpleBlockingQueue<E>

Throws:

InterruptedException

size

public int size()

Returns the number of elements in this queue.

Specified by:

size in interface SimpleBlockingQueue<E>

Returns:

the number of elements in this queue

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface SimpleBlockingQueue<E>