com.illumon.util.locks

Interface FunctionalLock

All Superinterfaces:

Lock

All Known Subinterfaces:

AwareFunctionalLock

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 and 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.

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

lock, lockInterruptibly, newCondition, tryLock, tryLock, unlock

Method Detail

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

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