io.funtom.util.concurrent

Class PerKeyReadWriteSynchronizedExecutor<KEY_TYPE>

java.lang.Object

io.funtom.util.concurrent.PerKeyReadWriteSynchronizedExecutor<KEY_TYPE>

public final class PerKeyReadWriteSynchronizedExecutor<KEY_TYPE>
extends Object

An Executor which executes tasks on the caller thread. The tasks will be executed synchronously on a per-key basis. By saying per-key, we mean that thread safety is guaranteed for threads calling it with equals keys. For different threads calling the executor with equals keys,

Calls to readExecute(...) methods:

• Never lock each other
• Have the same memory semantics as locking and unlocking the read lock of a java.util.concurrent.lock.ReadWriteLock

Calls to writeExecute(...) methods:

• Never overlaps with any other calls to execute methods
• Have the same memory semantics as locking and unlocking the write lock of a java.util.concurrent.lock.ReadWriteLock

On the other hand, the executor is implemented so calls from different threads, with keys that are not equals, will be executed concurrently with minimal contention between the calls. Calling threads might be suspended.

Constructor Summary

Constructors

Constructor and Description
PerKeyReadWriteSynchronizedExecutor()

Method Summary

Modifier and Type	Method and Description
void	readExecute(KEY_TYPE key, Runnable task)
<R> R	readExecute(KEY_TYPE key, Supplier<R> task)
void	writeExecute(KEY_TYPE key, Runnable task)
<R> R	writeExecute(KEY_TYPE key, Supplier<R> task)

Methods inherited from class java.lang.Object

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

Constructor Detail

PerKeyReadWriteSynchronizedExecutor

public PerKeyReadWriteSynchronizedExecutor()

Method Detail

readExecute

public void readExecute(KEY_TYPE key,
                        Runnable task)

readExecute

public <R> R readExecute(KEY_TYPE key,
                         Supplier<R> task)
                  throws Exception

Throws:

Exception

writeExecute

public void writeExecute(KEY_TYPE key,
                         Runnable task)

writeExecute

public <R> R writeExecute(KEY_TYPE key,
                          Supplier<R> task)