Package com.atlassian.bamboo.concurrent

Class CoalescingBlockedCallsReference<T>

java.lang.Object

com.atlassian.bamboo.concurrent.CoalescingBlockedCallsReference<T>

public class CoalescingBlockedCallsReference<T>
extends Object

get() on this reference has the following properties: When a call (call A) to get is made and is in progress, any get() call done while the call A is still pending will block the new call until call A is finished. After is finished, a get() will be called once and all threads that used to be blocked will get the same return value from get(). If there's no call in progress, this reference works just like a regular supplier.

Method Summary

Modifier and Type	Method	Description
T	get()
static CoalescingBlockedCallsReference<Void>	make(Runnable runnable)
static <T> CoalescingBlockedCallsReference<T>	make(Supplier<T> supplier)

Methods inherited from class java.lang.Object

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

Method Details

get

public T get()
      throws ExecutionException,
InterruptedException

Throws:

ExecutionException

InterruptedException

make

public static <T>
CoalescingBlockedCallsReference<T> make(Supplier<T> supplier)

make

public static CoalescingBlockedCallsReference<Void> make(Runnable runnable)