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) 2014 Eike Stepper (Berlin, 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