Package com.illumon.util.locks

Interface FunctionalLock

All Superinterfaces:

Lock

All Known Subinterfaces:

AwareFunctionalLock

All Known Implementing Classes:

FunctionalReentrantLock

public interface FunctionalLock
extends Lock

Extension to the Lock interface to enable locking for the duration of a lambda or other FunctionalInterface invocation.

Method Summary

Modifier and Type	Method	Description
default <RESULT_TYPE, EXCEPTION_TYPE extends Exception> RESULT_TYPE	computeLocked(FunctionalInterfaces.ThrowingSupplier<RESULT_TYPE,EXCEPTION_TYPE> supplier)	Acquire the lock, invoke FunctionalInterfaces.ThrowingSupplier.get() while holding the lock, and release the lock before returning the result.
default <RESULT_TYPE, EXCEPTION_TYPE extends Exception> RESULT_TYPE	computeLockedInterruptibly(FunctionalInterfaces.ThrowingSupplier<RESULT_TYPE,EXCEPTION_TYPE> supplier)	Acquire the lock interruptibly, invoke FunctionalInterfaces.ThrowingSupplier.get() while holding the lock, and release the lock before returning the result.
default <EXCEPTION_TYPE extends Exception> void	doLocked(FunctionalInterfaces.ThrowingRunnable<EXCEPTION_TYPE> runnable)	Acquire the lock, invoke FunctionalInterfaces.ThrowingRunnable.run() while holding the lock, and release the lock before returning.
default <EXCEPTION_TYPE extends Exception> void	doLockedInterruptibly(FunctionalInterfaces.ThrowingRunnable<EXCEPTION_TYPE> runnable)	Acquire the lock interruptibly, invoke FunctionalInterfaces.ThrowingRunnable.run() while holding the lock, and release the lock before returning.
default <EXCEPTION_TYPE extends Exception> boolean	testLocked(FunctionalInterfaces.ThrowingBooleanSupplier<EXCEPTION_TYPE> supplier)	Acquire the lock, invoke FunctionalInterfaces.ThrowingBooleanSupplier.get() while holding the lock, and release the lock before returning the result.

Methods inherited from interface java.util.concurrent.locks.Lock

lock, lockInterruptibly, newCondition, tryLock, tryLock, unlock

Method Details

doLocked

default <EXCEPTION_TYPE extends Exception> void doLocked(@NotNull FunctionalInterfaces.ThrowingRunnable<EXCEPTION_TYPE> runnable) throws EXCEPTION_TYPE extends Exception

Acquire the lock, invoke FunctionalInterfaces.ThrowingRunnable.run() while holding the lock, and release the lock before returning.

Parameters:

runnable - The FunctionalInterfaces.ThrowingRunnable to run

Throws:

EXCEPTION_TYPE - If runnable throws its declared exception

EXCEPTION_TYPE extends Exception

doLockedInterruptibly

default <EXCEPTION_TYPE extends Exception> void doLockedInterruptibly(@NotNull FunctionalInterfaces.ThrowingRunnable<EXCEPTION_TYPE> runnable) throws InterruptedException, EXCEPTION_TYPE extends Exception

Acquire the lock interruptibly, invoke FunctionalInterfaces.ThrowingRunnable.run() while holding the lock, and release the lock before returning.

Parameters:

runnable - The FunctionalInterfaces.ThrowingRunnable.run() to run

Throws:

InterruptedException - If the current thread was interrupted while waiting to acquire the lock

EXCEPTION_TYPE - If runnable throws its declared exception

EXCEPTION_TYPE extends Exception

computeLocked

default <RESULT_TYPE, EXCEPTION_TYPE extends Exception> RESULT_TYPE computeLocked(@NotNull FunctionalInterfaces.ThrowingSupplier<RESULT_TYPE,EXCEPTION_TYPE> supplier) throws EXCEPTION_TYPE extends Exception

Acquire the lock, invoke FunctionalInterfaces.ThrowingSupplier.get() while holding the lock, and release the lock before returning the result.

Parameters:

supplier - The FunctionalInterfaces.ThrowingSupplier to get

Returns:

The result of invoking supplier

Throws:

EXCEPTION_TYPE - If supplier throws its declared exception

EXCEPTION_TYPE extends Exception

testLocked

default <EXCEPTION_TYPE extends Exception> boolean testLocked(@NotNull FunctionalInterfaces.ThrowingBooleanSupplier<EXCEPTION_TYPE> supplier) throws EXCEPTION_TYPE extends Exception

Acquire the lock, invoke FunctionalInterfaces.ThrowingBooleanSupplier.get() while holding the lock, and release the lock before returning the result.

Parameters:

supplier - The FunctionalInterfaces.ThrowingBooleanSupplier to get

Returns:

The result of invoking supplier

Throws:

EXCEPTION_TYPE - If supplier throws its declared exception

EXCEPTION_TYPE extends Exception

computeLockedInterruptibly

default <RESULT_TYPE, EXCEPTION_TYPE extends Exception> RESULT_TYPE computeLockedInterruptibly(@NotNull FunctionalInterfaces.ThrowingSupplier<RESULT_TYPE,EXCEPTION_TYPE> supplier) throws InterruptedException, EXCEPTION_TYPE extends Exception

Acquire the lock interruptibly, invoke FunctionalInterfaces.ThrowingSupplier.get() while holding the lock, and release the lock before returning the result.

Parameters:

supplier - The FunctionalInterfaces.ThrowingSupplier to get

Returns:

The result of invoking supplier

Throws:

InterruptedException - If the current thread was interrupted while waiting to acquire the lock

EXCEPTION_TYPE - If supplier throws its declared exception

EXCEPTION_TYPE extends Exception