com.bigdata.util.concurrent

Class ThreadGuard

java.lang.Object

com.bigdata.util.concurrent.ThreadGuard

public class ThreadGuard
extends Object

Pattern used to guard critical regions that await Conditions when a concurrent event may cause the Condition to become unsatisfiable.

Author:

Bryan Thompson

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ThreadGuard.Guard

Constructor Summary

Constructors

Constructor and Description
ThreadGuard()

Method Summary

Methods

Modifier and Type	Method and Description
void	decThread() Decrement thread in critical region awaiting a Condition.
<T> T	guard(Callable<T> r) Execute a critical region which needs to be interrupted if some condition is violated.
void	guard(Runnable r) Execute a critical region which needs to be interrupted if some condition is violated.
void	guard(ThreadGuard.Guard r) Execute a critical region which needs to be interrupted if some condition is violated.
void	interruptAll() Interrupt any threads in critical regions awaiting a Condition.

Methods inherited from class java.lang.Object

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

Constructor Detail

ThreadGuard

public ThreadGuard()

Method Detail

guard

public void guard(Runnable r)

Execute a critical region which needs to be interrupted if some condition is violated.

Parameters:

r - The lambda.

guard

public void guard(ThreadGuard.Guard r)
           throws InterruptedException

Execute a critical region which needs to be interrupted if some condition is violated.

Parameters:

r - The lambda.

Throws:

InterruptedException

guard

public <T> T guard(Callable<T> r)
        throws Exception

Execute a critical region which needs to be interrupted if some condition is violated.

Parameters:

r - The lambda.

Returns:

The result (if any).

Throws:

Exception

decThread

public void decThread()

Decrement thread in critical region awaiting a Condition.

interruptAll

public void interruptAll()

Interrupt any threads in critical regions awaiting a Condition.