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

SynchronizeBlockingQueue(int limit)

Method Summary

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 Detail

SynchronizeBlockingQueue

public SynchronizeBlockingQueue(int limit)

Method Detail

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>