Package com.oracle.coherence.grpc

Class SimpleDaemonPoolExecutor

java.lang.Object

com.oracle.coherence.grpc.SimpleDaemonPoolExecutor

All Implemented Interfaces:

ClassLoaderAware, Controllable, Executor

Direct Known Subclasses:

DaemonPoolExecutor

public class SimpleDaemonPoolExecutor
extends Object
implements Executor, Controllable

An Executor that uses a DaemonPool to execute tasks.

Instances of SimpleDaemonPoolExecutor are created with a DaemonPool that is stopped. The executor should be started by calling the start() method.

Tasks submitted without calling start will be executed immediately on the calling thread.

Since:

20.06

Author:

Jonathan Knight 2020.06.24

Field Summary

Fields

Modifier and Type	Field	Description
protected com.tangosol.internal.util.DaemonPool	f_pool	The DaemonPool that will be used to execute tasks.

Constructor Summary

Constructors

Constructor	Description
SimpleDaemonPoolExecutor(com.tangosol.internal.util.DaemonPool pool)	Create a SimpleDaemonPoolExecutor.
SimpleDaemonPoolExecutor(com.tangosol.internal.util.DefaultDaemonPoolDependencies dependencies)
SimpleDaemonPoolExecutor(String sName)
SimpleDaemonPoolExecutor(String sName, int cThreads, int cThreadsMin, int cThreadsMax)

Method Summary

Modifier and Type	Method	Description
void	configure(XmlElement xmlElement)	Configure the controllable service.
void	execute(Runnable command)
ClassLoader	getContextClassLoader()	Retrieve the context ClassLoader for this object.
com.tangosol.internal.util.DaemonPool	getPool()	Obtain the underlying DaemonPool.
boolean	isRunning()	Determine whether or not the controllable service is running.
boolean	isStuck()	Return true if the pool is stuck.
void	setContextClassLoader(ClassLoader loader)	Specify the context ClassLoader for this object.
void	shutdown()	Stop the controllable service.
void	start()	Start the controllable service.
void	stop()	Hard-stop the controllable service.

Methods inherited from class java.lang.Object

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

Field Detail

f_pool

protected final com.tangosol.internal.util.DaemonPool f_pool

The DaemonPool that will be used to execute tasks.

Constructor Detail

SimpleDaemonPoolExecutor

public SimpleDaemonPoolExecutor(String sName)

SimpleDaemonPoolExecutor

public SimpleDaemonPoolExecutor(String sName,
                                int cThreads,
                                int cThreadsMin,
                                int cThreadsMax)

SimpleDaemonPoolExecutor

public SimpleDaemonPoolExecutor(com.tangosol.internal.util.DefaultDaemonPoolDependencies dependencies)

SimpleDaemonPoolExecutor

public SimpleDaemonPoolExecutor(com.tangosol.internal.util.DaemonPool pool)

Create a SimpleDaemonPoolExecutor.

Parameters:

pool - the DaemonPool to use

Method Detail

execute

public void execute(Runnable command)

Specified by:

execute in interface Executor

configure

public void configure(XmlElement xmlElement)

Description copied from interface: Controllable

Configure the controllable service.

This method can only be called before the controllable service is started.

Specified by:

configure in interface Controllable

Parameters:

xmlElement - an XmlElement carrying configuration information specific to the Controllable object

start

public void start()

Description copied from interface: Controllable

Start the controllable service.

This method should only be called once per the life cycle of the Controllable service. This method has no affect if the service is already running.

Specified by:

start in interface Controllable

isRunning

public boolean isRunning()

Description copied from interface: Controllable

Determine whether or not the controllable service is running. This method returns false before a service is started, while the service is starting, while a service is shutting down and after the service has stopped. It only returns true after completing its start processing and before beginning its shutdown processing.

Specified by:

isRunning in interface Controllable

Returns:

true if the service is running; false otherwise

isStuck

public boolean isStuck()

Return true if the pool is stuck.

Returns:

true if the pool is stuck

shutdown

public void shutdown()

Description copied from interface: Controllable

Stop the controllable service. This is a controlled shut-down, and is preferred to the Controllable.stop() method.

This method should only be called once per the life cycle of the controllable service. Calling this method for a service that has already stopped has no effect.

Specified by:

shutdown in interface Controllable

stop

public void stop()

Description copied from interface: Controllable

Hard-stop the controllable service. Use Controllable.shutdown() for normal service termination. Calling this method for a service that has already stopped has no effect.

Specified by:

stop in interface Controllable

getContextClassLoader

public ClassLoader getContextClassLoader()

Description copied from interface: ClassLoaderAware

Retrieve the context ClassLoader for this object. The context ClassLoader is provided by the creator of the object for use by the object when loading classes and resources.

Specified by:

getContextClassLoader in interface ClassLoaderAware

Returns:

the context ClassLoader for this object

See Also:

Thread.getContextClassLoader()

setContextClassLoader

public void setContextClassLoader(ClassLoader loader)

Description copied from interface: ClassLoaderAware

Specify the context ClassLoader for this object. The context ClassLoader can be set when the object is created, and allows the creator to provide the appropriate class loader to be used by the object when when loading classes and resources.

Specified by:

setContextClassLoader in interface ClassLoaderAware

Parameters:

loader - the context ClassLoader for this object

getPool

public com.tangosol.internal.util.DaemonPool getPool()

Obtain the underlying DaemonPool.

Returns:

the underlying DaemonPool