Package lu.kbra.pclib.concurrency

Class ObjectTriggerLatch<T>

java.lang.Object

lu.kbra.pclib.concurrency.ObjectTriggerLatch<T>

All Implemented Interfaces:

GenericTriggerLatch<Object>

public class ObjectTriggerLatch<T>
extends Object
implements GenericTriggerLatch<Object>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	ObjectTriggerLatch.InternalIntPointer

Constructor Summary

Constructors

Constructor	Description
ObjectTriggerLatch(int count, T value)
ObjectTriggerLatch(int count, T value, Consumer<T> onRelease)

Method Summary

Modifier and Type	Method	Description
ObjectTriggerLatch<T>	cancel()
void	countDown()
T	getObject()
int	getValue()
boolean	join()
ObjectTriggerLatch<T>	latch(GenericTriggerLatch<? super T> latch)
ObjectTriggerLatch<T>	then(Consumer<? super T> onRelease)
<R extends Throwable> ObjectTriggerLatch<T>	then(ThrowingConsumer<? super T,R> onRelease)
String	toString()
void	trigger(Object value)
boolean	waitForChange()
boolean	waitForChange(long timeout)
boolean	waitForChange(long timeout, Predicate<Integer> condition)
boolean	waitForChange(Predicate<Integer> condition)
boolean	waitForSet()
boolean	waitForSet(long timeout)
boolean	waitForSet(long timeout, Predicate<Integer> condition)
boolean	waitForSet(Predicate<Integer> condition)

Methods inherited from class java.lang.Object

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

Constructor Details

ObjectTriggerLatch

public ObjectTriggerLatch(int count,
 T value)

ObjectTriggerLatch

public ObjectTriggerLatch(int count,
 T value,
 Consumer<T> onRelease)

Method Details

cancel

public ObjectTriggerLatch<T> cancel()

countDown

public void countDown()

getObject

public T getObject()

getValue

public int getValue()

join

public boolean join()

latch

public ObjectTriggerLatch<T> latch(GenericTriggerLatch<? super T> latch)

then

public ObjectTriggerLatch<T> then(Consumer<? super T> onRelease)

then

public <R extends Throwable> ObjectTriggerLatch<T> then(ThrowingConsumer<? super T,R> onRelease)

toString

public String toString()

Overrides:

toString in class Object

trigger

public void trigger(Object value)

Specified by:

trigger in interface GenericTriggerLatch<T>

waitForChange

public boolean waitForChange()

waitForChange

public boolean waitForChange(long timeout)

waitForChange

public boolean waitForChange(long timeout,
 Predicate<Integer> condition)

waitForChange

public boolean waitForChange(Predicate<Integer> condition)

waitForSet

public boolean waitForSet()

waitForSet

public boolean waitForSet(long timeout)

waitForSet

public boolean waitForSet(long timeout,
 Predicate<Integer> condition)

waitForSet

public boolean waitForSet(Predicate<Integer> condition)