org.eclipse.net4j.util.concurrent
Class ConcurrentValue<T>

java.lang.Object
  org.eclipse.net4j.util.concurrent.ConcurrentValue<T>

public final class ConcurrentValue<T>

extends Object

Allow synchronization between many threads for a specific value.

 MainThread cv.set(1);
 Thread1 cv.acquire(3);
 Thread2 cv.acquire(4);
 Thread3 cv.acquire(100);
 Thread4 cv.acquire(new Object()
   {
     public boolean equals(Object other)
     {
       return other.equals(2) || other.equals(3);
     }
   });
 Thread5 cv.acquire(1);
 ...
 // Thread 1,2,3 and 4 are blocked
 // Thread 5 isn't blocked.

 MainThread cv.set(3);

 // Thread 1 and 4 are unblocked.
 // Thread 2 and 3 are still blocked.
 

Since:

2.0

ConcurrentValue

public ConcurrentValue(T value)

get

public T get()

set

public void set(T newValue)

Specify the new value.

reevaluate

public void reevaluate()

Reevaluate the condition. It is only useful if a thread is blocked at acquire(Object) and the parameter passed changed. acquire(Object) generates a reevaluation automatically.

acquire

public void acquire(Object accept)
             throws InterruptedException

Blocking call.

Return when value accept is equal to get().

Throws:

InterruptedException