Class ThreadpoolSwiftletImpl

java.lang.Object

com.swiftmq.swiftlet.Swiftlet

com.swiftmq.swiftlet.threadpool.ThreadpoolSwiftlet

com.swiftmq.impl.threadpool.standard.ThreadpoolSwiftletImpl

All Implemented Interfaces:

com.swiftmq.swiftlet.timer.event.TimerListener, EventListener

public class ThreadpoolSwiftletImpl
extends com.swiftmq.swiftlet.threadpool.ThreadpoolSwiftlet
implements com.swiftmq.swiftlet.timer.event.TimerListener

Field Summary

Fields

Modifier and Type	Field	Description
static final String	PROP_ADHOC_PLATFORM_THREADS
static final String	PROP_ADHOC_VIRTUAL_THREADS
static final String	PROP_COLLECT_INTERVAL
static final String	PROP_PLATFORM_THREADS
static final String	PROP_VIRTUAL_THREADS

Fields inherited from class com.swiftmq.swiftlet.Swiftlet

STATE_ACTIVE, STATE_INACTIVE, STATE_STANDBY

Constructor Summary

Constructors

Constructor	Description
ThreadpoolSwiftletImpl()

Method Summary

Modifier and Type	Method	Description
com.swiftmq.swiftlet.threadpool.EventLoop	createEventLoop(String id, com.swiftmq.swiftlet.threadpool.EventProcessor eventProcessor)
void	freeze()
void	performTimeAction()
CompletableFuture<?>	runAsync(Runnable runnable)
CompletableFuture<?>	runAsync(Runnable runnable, boolean virtual)
protected void	shutdown()
protected void	startup(com.swiftmq.mgmt.Configuration config)
void	unfreeze()

Methods inherited from class com.swiftmq.swiftlet.Swiftlet

getName, getStartupTime, getState, isSnapshotAvailable, resume, setStartupTime, standby

Methods inherited from class Object

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

Field Details

PROP_COLLECT_INTERVAL

public static final String PROP_COLLECT_INTERVAL

See Also:

• Constant Field Values

PROP_PLATFORM_THREADS

public static final String PROP_PLATFORM_THREADS

See Also:

• Constant Field Values

PROP_VIRTUAL_THREADS

public static final String PROP_VIRTUAL_THREADS

See Also:

• Constant Field Values

PROP_ADHOC_VIRTUAL_THREADS

public static final String PROP_ADHOC_VIRTUAL_THREADS

See Also:

• Constant Field Values

PROP_ADHOC_PLATFORM_THREADS

public static final String PROP_ADHOC_PLATFORM_THREADS

See Also:

• Constant Field Values

Constructor Details

ThreadpoolSwiftletImpl

public ThreadpoolSwiftletImpl()

Method Details

runAsync

public CompletableFuture<?> runAsync(Runnable runnable)

Specified by:

runAsync in class com.swiftmq.swiftlet.threadpool.ThreadpoolSwiftlet

runAsync

public CompletableFuture<?> runAsync(Runnable runnable,
 boolean virtual)

Specified by:

runAsync in class com.swiftmq.swiftlet.threadpool.ThreadpoolSwiftlet

createEventLoop

public com.swiftmq.swiftlet.threadpool.EventLoop createEventLoop(String id,
 com.swiftmq.swiftlet.threadpool.EventProcessor eventProcessor)

Specified by:

createEventLoop in class com.swiftmq.swiftlet.threadpool.ThreadpoolSwiftlet

performTimeAction

public void performTimeAction()

Specified by:

performTimeAction in interface com.swiftmq.swiftlet.timer.event.TimerListener

freeze

public void freeze()

Specified by:

freeze in class com.swiftmq.swiftlet.threadpool.ThreadpoolSwiftlet

unfreeze

public void unfreeze()

Specified by:

unfreeze in class com.swiftmq.swiftlet.threadpool.ThreadpoolSwiftlet

startup

protected void startup(com.swiftmq.mgmt.Configuration config)
                throws com.swiftmq.swiftlet.SwiftletException

Specified by:

startup in class com.swiftmq.swiftlet.Swiftlet

Throws:

com.swiftmq.swiftlet.SwiftletException

shutdown

protected void shutdown()

Specified by:

shutdown in class com.swiftmq.swiftlet.Swiftlet