com.edorasware.commons.core.util.concurrency

Class ConcurrencyUtils

java.lang.Object

com.edorasware.commons.core.util.concurrency.ConcurrencyUtils

public class ConcurrencyUtils
extends Object

Provides utility methods related to concurrency.

Method Summary

Modifier and Type	Method and Description
static void	awaitCondition(Operation<Boolean> condition, long maxWaitTimeMillis, long intervalMillis, String errorMessage) Waits a given amount of time for a certain condition to become true.
static void	sleep(long duration, TimeUnit timeUnit) Sleeps the given amount of time.

Methods inherited from class java.lang.Object

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

Method Detail

awaitCondition

public static void awaitCondition(Operation<Boolean> condition,
                                  long maxWaitTimeMillis,
                                  long intervalMillis,
                                  String errorMessage)

Waits a given amount of time for a certain condition to become true. The condition is checked for in the given interval.

Parameters:

condition - the condition to wait for to become true

maxWaitTimeMillis - the maximum amount of time to wait for the condition to become true

intervalMillis - the amount of time to wait between checking for the condition to become true

errorMessage - the error message of the exception thrown when the condition does not become true

Throws:

IllegalStateException - thrown if the condition does not become true in the given maximum amount of time

sleep

public static void sleep(long duration,
                         TimeUnit timeUnit)

Sleeps the given amount of time.

Parameters:

duration - the duration to sleep

timeUnit - the time unit of the duration to sleep