net.thevpc.nuts.runtime.standalone.concurrent

Class NWorkBalancerImpl<T>

java.lang.Object

net.thevpc.nuts.runtime.standalone.concurrent.NWorkBalancerImpl<T>

All Implemented Interfaces:

net.thevpc.nuts.concurrent.NWorkBalancer<T>

public class NWorkBalancerImpl<T>
extends Object
implements net.thevpc.nuts.concurrent.NWorkBalancer<T>

Constructor Summary

Constructors

Constructor and Description
NWorkBalancerImpl(net.thevpc.nuts.concurrent.NWorkBalancerModel model, NWorkBalancerFactoryImpl factory)

Method Summary

Modifier and Type	Method and Description
net.thevpc.nuts.util.NOptional<net.thevpc.nuts.elem.NElement>	getOption(String name)
net.thevpc.nuts.util.NOptional<net.thevpc.nuts.concurrent.NWorkBalancerWorkerLoad>	getWorkerLoad(String workerName)
boolean	isRunning()
net.thevpc.nuts.concurrent.NCallable<T>	of(String name, net.thevpc.nuts.concurrent.NWorkBalancerJob<T> job)
Map<String,net.thevpc.nuts.elem.NElement>	options()
List<net.thevpc.nuts.concurrent.NWorkBalancerRunningJob>	runningJobs()
int	runningJobsCount()
Map<String,net.thevpc.nuts.concurrent.NWorkBalancerWorkerLoad>	workerLoads()
List<net.thevpc.nuts.concurrent.NWorkBalancerWorker>	workers()

Methods inherited from class java.lang.Object

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

Constructor Detail

NWorkBalancerImpl

public NWorkBalancerImpl(net.thevpc.nuts.concurrent.NWorkBalancerModel model,
                         NWorkBalancerFactoryImpl factory)

Method Detail

of

public net.thevpc.nuts.concurrent.NCallable<T> of(String name,
                                                  net.thevpc.nuts.concurrent.NWorkBalancerJob<T> job)

Specified by:

of in interface net.thevpc.nuts.concurrent.NWorkBalancer<T>

runningJobs

public List<net.thevpc.nuts.concurrent.NWorkBalancerRunningJob> runningJobs()

Specified by:

runningJobs in interface net.thevpc.nuts.concurrent.NWorkBalancer<T>

isRunning

public boolean isRunning()

Specified by:

isRunning in interface net.thevpc.nuts.concurrent.NWorkBalancer<T>

runningJobsCount

public int runningJobsCount()

Specified by:

runningJobsCount in interface net.thevpc.nuts.concurrent.NWorkBalancer<T>

workers

public List<net.thevpc.nuts.concurrent.NWorkBalancerWorker> workers()

Specified by:

workers in interface net.thevpc.nuts.concurrent.NWorkBalancer<T>

getWorkerLoad

public net.thevpc.nuts.util.NOptional<net.thevpc.nuts.concurrent.NWorkBalancerWorkerLoad> getWorkerLoad(String workerName)

Specified by:

getWorkerLoad in interface net.thevpc.nuts.concurrent.NWorkBalancer<T>

workerLoads

public Map<String,net.thevpc.nuts.concurrent.NWorkBalancerWorkerLoad> workerLoads()

Specified by:

workerLoads in interface net.thevpc.nuts.concurrent.NWorkBalancer<T>

getOption

public net.thevpc.nuts.util.NOptional<net.thevpc.nuts.elem.NElement> getOption(String name)

Specified by:

getOption in interface net.thevpc.nuts.concurrent.NWorkBalancer<T>

options

public Map<String,net.thevpc.nuts.elem.NElement> options()

Specified by:

options in interface net.thevpc.nuts.concurrent.NWorkBalancer<T>