org.eclipse.net4j.util.concurrent
Class SynchronizingCorrelator<CORRELATION,RESULT>

java.lang.Object
  org.eclipse.net4j.util.concurrent.SynchronizingCorrelator<CORRELATION,RESULT>

All Implemented Interfaces:

ICorrelator<CORRELATION,ISynchronizer<RESULT>>

public class SynchronizingCorrelator<CORRELATION,RESULT>

extends Object

implements ICorrelator<CORRELATION,ISynchronizer<RESULT>>

SynchronizingCorrelator

public SynchronizingCorrelator()

getSynchronizer

public ISynchronizer<RESULT> getSynchronizer(CORRELATION correlation)

Since:

3.0

isCorrelated

public boolean isCorrelated(CORRELATION correlation)

Specified by:

isCorrelated in interface ICorrelator<CORRELATION,ISynchronizer<RESULT>>

correlate

public ISynchronizer<RESULT> correlate(CORRELATION correlation)

Specified by:

correlate in interface ICorrelator<CORRELATION,ISynchronizer<RESULT>>

correlateUnique

public ISynchronizer<RESULT> correlateUnique(CORRELATION correlation)

Specified by:

correlateUnique in interface ICorrelator<CORRELATION,ISynchronizer<RESULT>>

uncorrelate

public ISynchronizer<RESULT> uncorrelate(CORRELATION correlation)

Specified by:

uncorrelate in interface ICorrelator<CORRELATION,ISynchronizer<RESULT>>

get

public RESULT get(CORRELATION correlation,
                  long timeout)

put

public void put(CORRELATION correlation,
                RESULT result)

putIfCorrelated

public boolean putIfCorrelated(CORRELATION correlation,
                               RESULT result)

Since:

3.0

put

public boolean put(CORRELATION correlation,
                   RESULT result,
                   long timeout)

createSynchronizer

protected ISynchronizer<RESULT> createSynchronizer(CORRELATION correlation)

toString

public String toString()

Overrides:

toString in class Object