org.apache.hedwig.util

Class ConcurrencyUtils

java.lang.Object

org.apache.hedwig.util.ConcurrencyUtils

public class ConcurrencyUtils
extends Object

Constructor Summary

Constructors

Constructor and Description
ConcurrencyUtils()

Method Summary

Methods

Modifier and Type	Method and Description
static void	await(CyclicBarrier barrier)
static <T,U extends T,V extends BlockingQueue<T>> void	put(V queue, U value)
static <T> T	take(BlockingQueue<T> queue)

Methods inherited from class java.lang.Object

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

Constructor Detail

ConcurrencyUtils

public ConcurrencyUtils()

Method Detail

put

public static <T,U extends T,V extends BlockingQueue<T>> void put(V queue,
                                                  U value)

take

public static <T> T take(BlockingQueue<T> queue)

await

public static void await(CyclicBarrier barrier)