com.mulesoft.mule.runtime.module.cluster.internal

Class HazelcastTimeoutUtils

java.lang.Object

com.mulesoft.mule.runtime.module.cluster.internal.HazelcastTimeoutUtils

public class HazelcastTimeoutUtils
extends Object

Utility class for dealing with timeouts in Hazelcast calls

Since:

4.3.0, 4.2.2

Method Summary

Modifier and Type	Method and Description
protected static <T> T	execute(org.mule.runtime.core.api.util.func.CheckedFunction<Long,T> closure, long timeout)
static <T> T	executeWithTimeoutIntervals(long timeoutMillis, org.mule.runtime.core.api.util.func.CheckedFunction<Long,T> closure, Predicate<T> breakCondition) Hazelcast may take a while to actually throw the Interrupted exception, so we must do the operation in shorter consecutive intervals so in the case of interruption we can be notified as soon as possible and proceed with the shutdown normally.

Methods inherited from class java.lang.Object

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

Method Detail

executeWithTimeoutIntervals

public static <T> T executeWithTimeoutIntervals(long timeoutMillis,
                                                org.mule.runtime.core.api.util.func.CheckedFunction<Long,T> closure,
                                                Predicate<T> breakCondition)
                                         throws InterruptedException

Hazelcast may take a while to actually throw the Interrupted exception, so we must do the operation in shorter consecutive intervals so in the case of interruption we can be notified as soon as possible and proceed with the shutdown normally. Ref: https://github.com/hazelcast/hazelcast/issues/5526#issuecomment-224488784

Parameters:

timeoutMillis - The total timeout in milliseconds. The partial timeouts of the intervals will add up to this value.

closure - the actual call to make, receiving the calculated partial timeout as a parameter.

breakCondition - The condition under which the returned value will be considered valid and returned by this method. When false is returned, another interval with a partial timeout will take place.

Returns:

the last value returned by closure when breakCondition becomes true or the timeoutMillis is completed.

Throws:

InterruptedException - if the thread is interrupted during this method. As per the Hazelcast behavior, InterruptedException may not be thrown until the partial interval is complete.

execute

protected static <T> T execute(org.mule.runtime.core.api.util.func.CheckedFunction<Long,T> closure,
                               long timeout)
                        throws InterruptedException

Throws:

InterruptedException