com.sleepycat.je.rep.utilint

Class RepUtils.ExceptionAwareCountDownLatch

java.lang.Object

java.util.concurrent.CountDownLatch

com.sleepycat.je.rep.utilint.RepUtils.ExceptionAwareCountDownLatch

Enclosing class:

RepUtils

public static class RepUtils.ExceptionAwareCountDownLatch
extends java.util.concurrent.CountDownLatch

Like CountDownLatch, but makes provision in the await for the await, or more specifically the new awaitOrException method to be exited via an exception.

Field Summary

Fields

Modifier and Type	Field and Description
(package private) EnvironmentImpl	envImpl

Constructor Summary

Constructors

Constructor and Description
RepUtils.ExceptionAwareCountDownLatch(EnvironmentImpl envImpl, int count)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	await(long timeout, java.util.concurrent.TimeUnit unit) Deprecated.
void	awaitOrException()
boolean	awaitOrException(long timeout, java.util.concurrent.TimeUnit unit) Blocks, waiting for the latch to count down to zero, or until an Exception is provided.
void	releaseAwait(java.lang.Exception exception) The method used to free an await, ensuring that it throws an exception at the awaitOrException.

Methods inherited from class java.util.concurrent.CountDownLatch

await, countDown, getCount, toString

Methods inherited from class java.lang.Object

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

Field Detail

envImpl

final EnvironmentImpl envImpl

Constructor Detail

RepUtils.ExceptionAwareCountDownLatch

public RepUtils.ExceptionAwareCountDownLatch(EnvironmentImpl envImpl,
                                     int count)

Method Detail

releaseAwait

public void releaseAwait(java.lang.Exception exception)

The method used to free an await, ensuring that it throws an exception at the awaitOrException.

Parameters:

exception - the exception to be wrapped in a DatabaseException and thrown.

awaitOrException

public boolean awaitOrException(long timeout,
                       java.util.concurrent.TimeUnit unit)
                         throws java.lang.InterruptedException,
                                DatabaseException

Blocks, waiting for the latch to count down to zero, or until an Exception is provided. The exception is thrown in every thread that is waiting in this method.

Throws:

java.lang.InterruptedException

DatabaseException

See Also:

releaseAwait(java.lang.Exception)

awaitOrException

public void awaitOrException()
                      throws java.lang.InterruptedException,
                             DatabaseException

Throws:

java.lang.InterruptedException

DatabaseException

await

@Deprecated
public boolean await(long timeout,
                       java.util.concurrent.TimeUnit unit)

Deprecated.

DO NOT use this method. Use awaitOrException instead, so that any outstanding exceptions are thrown.

Overrides:

await in class java.util.concurrent.CountDownLatch