step.grid.tokenpool

Class TokenPool<P extends Identity,F extends Identity>

java.lang.Object

step.grid.tokenpool.TokenPool<P,F>

All Implemented Interfaces:

Closeable, AutoCloseable

public class TokenPool<P extends Identity,F extends Identity>
extends Object
implements Closeable

Constructor Summary

Constructors

Constructor and Description
TokenPool(AffinityEvaluator<P,F> affinityEval)

Method Summary

Modifier and Type	Method and Description
void	addReturnTokenListener(String tokenId, java.util.function.Consumer<F> consumer)
protected void	callListener(F object, java.util.function.Consumer<F> listener)
void	close()
int	getSize()
Token<F>	getToken(String id)
List<Token<F>>	getTokens()
List<P>	getWaitingPretenders()
void	invalidate(String id)
void	invalidateToken(F object)
void	keepaliveToken(String id)
String	offerToken(F object)
void	returnToken(F object)
F	selectToken(P pretender, long timeout)
F	selectToken(P pretender, long matchExistsTimeout, long noMatchExistsTimeout)
void	setKeepaliveTimeout(long timeout)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TokenPool

public TokenPool(AffinityEvaluator<P,F> affinityEval)

Method Detail

setKeepaliveTimeout

public void setKeepaliveTimeout(long timeout)

selectToken

public F selectToken(P pretender,
                     long timeout)
              throws TimeoutException,
                     InterruptedException

Throws:

TimeoutException

InterruptedException

selectToken

public F selectToken(P pretender,
                     long matchExistsTimeout,
                     long noMatchExistsTimeout)
              throws TimeoutException,
                     InterruptedException

Throws:

TimeoutException

InterruptedException

addReturnTokenListener

public void addReturnTokenListener(String tokenId,
                                   java.util.function.Consumer<F> consumer)

returnToken

public void returnToken(F object)

callListener

protected void callListener(F object,
                            java.util.function.Consumer<F> listener)

offerToken

public String offerToken(F object)

keepaliveToken

public void keepaliveToken(String id)

getToken

public Token<F> getToken(String id)

invalidate

public void invalidate(String id)

invalidateToken

public void invalidateToken(F object)

getSize

public int getSize()

getTokens

public List<Token<F>> getTokens()

getWaitingPretenders

public List<P> getWaitingPretenders()

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException