Package com.ticxo.modelengine.api.utils.ticker

Class AbstractLoadBalancer<KEY,SER extends LoadBalancer.Server>

java.lang.Object

com.ticxo.modelengine.api.utils.ticker.AbstractLoadBalancer<KEY,SER>

All Implemented Interfaces:

LoadBalancer<KEY,SER>

Direct Known Subclasses:

EntityDataTrackers

public abstract class AbstractLoadBalancer<KEY,SER extends LoadBalancer.Server>
extends Object
implements LoadBalancer<KEY,SER>

Nested Class Summary

Nested classes/interfaces inherited from interface com.ticxo.modelengine.api.utils.ticker.LoadBalancer

LoadBalancer.Server

Field Summary

Fields

Modifier and Type	Field	Description
protected final Set<SER>	available
protected final Map<KEY,SER>	reference

Constructor Summary

Constructors

Constructor	Description
AbstractLoadBalancer(int counts)

Method Summary

Modifier and Type	Method	Description
void	execute(KEY key, BiConsumer<KEY,SER> balConsumer)
SER	get(KEY key)
Set<SER>	getAvailable()
SER	getOrRegister(KEY key)
void	unregister(KEY key)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.ticxo.modelengine.api.utils.ticker.LoadBalancer

map, supply

Field Details

available

protected final Set<SER extends LoadBalancer.Server> available

reference

protected final Map<KEY,SER extends LoadBalancer.Server> reference

Constructor Details

AbstractLoadBalancer

public AbstractLoadBalancer(int counts)

Method Details

getOrRegister

public SER getOrRegister(KEY key)

Specified by:

getOrRegister in interface LoadBalancer<KEY,SER extends LoadBalancer.Server>

get

public SER get(KEY key)

Specified by:

get in interface LoadBalancer<KEY,SER extends LoadBalancer.Server>

unregister

public void unregister(KEY key)

Specified by:

unregister in interface LoadBalancer<KEY,SER extends LoadBalancer.Server>

execute

public void execute(KEY key,
 BiConsumer<KEY,SER> balConsumer)

Specified by:

execute in interface LoadBalancer<KEY,SER extends LoadBalancer.Server>

getAvailable

public Set<SER> getAvailable()