jhelp.util.thread

Class Conditions

java.lang.Object

jhelp.util.thread.Conditions

public class Conditions
extends java.lang.Object

Create and manage conditions for launching thread.
For example if a thread A need wait that an other thread B have finish computing something (But B may still running to do other work) create a condition C. Then invalidate C with invalidate(String). Then launch B and register A with waitFor(String, ThreadedTask, Object). In B when the condition is complete call validate(String). It will launch A.
If condition is complete before A is register, A will be launch as soon as possible after the registering.
Important, by default a condition is consider like valid, you have to invalidate it to make it invalid

Author:

JHelp

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.HashMap<java.lang.String,java.util.ArrayList<Pair<ThreadedTask,java.lang.Object>>>	conditions Conditions list
static Conditions	CONDITIONS Conditions singleton
private Mutex	mutex Mutex for synchronized

Constructor Summary

Constructors

Modifier	Constructor and Description
private	Conditions() Create a new instance of Conditions

Method Summary

Methods

Modifier and Type	Method and Description
void	invalidate(java.lang.String condition) Invalidate a condition.
boolean	isValid(java.lang.String condition) Indicates if a condition is valid
<PARAMETER> void	validate(java.lang.String condition) Validate a condition and launch all waiting threads
<PARAMETER> void	waitFor(java.lang.String condition, ThreadedTask<PARAMETER,?,?> task, PARAMETER parameter) Register a thread to wait a condition to be valid before launch.

Methods inherited from class java.lang.Object

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

Field Detail

CONDITIONS

public static final Conditions CONDITIONS

Conditions singleton

conditions

private final java.util.HashMap<java.lang.String,java.util.ArrayList<Pair<ThreadedTask,java.lang.Object>>> conditions

Conditions list

mutex

private final Mutex mutex

Mutex for synchronized

Constructor Detail

Conditions

private Conditions()

Create a new instance of Conditions

Method Detail

invalidate

public void invalidate(java.lang.String condition)

Invalidate a condition.
All thread that register, for the given condition, will wait for someone who call validate(String)

Parameters:

condition - Condition to invalidate

isValid

public boolean isValid(java.lang.String condition)

Indicates if a condition is valid

Parameters:

condition - Condition to test

Returns:

Condition validity

validate

public <PARAMETER> void validate(java.lang.String condition)

Validate a condition and launch all waiting threads

Type Parameters:

PARAMETER - Thread parameter type

Parameters:

condition - Condition to validate

waitFor

public <PARAMETER> void waitFor(java.lang.String condition,
                       ThreadedTask<PARAMETER,?,?> task,
                       PARAMETER parameter)

Register a thread to wait a condition to be valid before launch.
If the condition is already valid (As by default) the thread is launch as soon as possible

Type Parameters:

PARAMETER - Thread parameter type

Parameters:

condition - Condition to wait

task - Thread to launch

parameter - Thread parameter