public class SynchronizingCorrelator<CORRELATION,RESULT> extends Object implements ICorrelator<CORRELATION,ISynchronizer<RESULT>>
Constructor and Description |
---|
SynchronizingCorrelator() |
Modifier and Type | Method and Description |
---|---|
ISynchronizer<RESULT> |
correlate(CORRELATION correlation) |
ISynchronizer<RESULT> |
correlateUnique(CORRELATION correlation) |
protected ISynchronizer<RESULT> |
createSynchronizer(CORRELATION correlation) |
RESULT |
get(CORRELATION correlation,
long timeout) |
ISynchronizer<RESULT> |
getSynchronizer(CORRELATION correlation) |
boolean |
isCorrelated(CORRELATION correlation) |
void |
put(CORRELATION correlation,
RESULT result) |
boolean |
put(CORRELATION correlation,
RESULT result,
long timeout) |
boolean |
putIfCorrelated(CORRELATION correlation,
RESULT result) |
String |
toString() |
ISynchronizer<RESULT> |
uncorrelate(CORRELATION correlation) |
public ISynchronizer<RESULT> getSynchronizer(CORRELATION correlation)
public boolean isCorrelated(CORRELATION correlation)
isCorrelated
in interface ICorrelator<CORRELATION,ISynchronizer<RESULT>>
public ISynchronizer<RESULT> correlate(CORRELATION correlation)
correlate
in interface ICorrelator<CORRELATION,ISynchronizer<RESULT>>
public ISynchronizer<RESULT> correlateUnique(CORRELATION correlation)
correlateUnique
in interface ICorrelator<CORRELATION,ISynchronizer<RESULT>>
public ISynchronizer<RESULT> uncorrelate(CORRELATION correlation)
uncorrelate
in interface ICorrelator<CORRELATION,ISynchronizer<RESULT>>
public RESULT get(CORRELATION correlation, long timeout)
public void put(CORRELATION correlation, RESULT result)
public boolean putIfCorrelated(CORRELATION correlation, RESULT result)
public boolean put(CORRELATION correlation, RESULT result, long timeout)
protected ISynchronizer<RESULT> createSynchronizer(CORRELATION correlation)
Copyright (c) 2011-2014 Eike Stepper (Berlin, Germany) and others.