public class SynchronizingCorrelator<CORRELATION,RESULT> extends java.lang.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) |
java.lang.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)
public java.lang.String toString()
toString
in class java.lang.Object
Copyright (c) 2004-2019 Eike Stepper (Loehne, Germany) and others.
All rights reserved. This program and the accompanying materials are made available under the terms of the Eclipse Public License v1.0 which accompanies this distribution, and is available at http://www.eclipse.org/legal/epl-v10.html