pack-priv final Class ShutdownFallbackExecutor

ShutdownFallbackExecutor wrapper around a single threaded executor which will execute pending tasks when the worker has been shut down.

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv static class	ShutdownFallbackExecutor.ShutdownFallbackThreadFactory

Field Summary

Modifier and Type	Field and Description
private static volatile Executor	EXECUTOR

Constructor Summary

Access	Constructor and Description
private	ShutdownFallbackExecutor()

Modifier and Type	Method and Description
pack-priv static void	execute(Runnable runnable)

Modifier and Type

Method and Description

pack-priv static void

execute(Runnable runnable)

Field Detail

EXECUTOR	back to summary
private static volatile Executor EXECUTOR

Constructor Detail

ShutdownFallbackExecutor	back to summary
private ShutdownFallbackExecutor()

Method Detail

execute	back to summary
pack-priv static void execute(Runnable runnable)

io.undertow.server.protocol.framed back to summary

pack-priv final Class ShutdownFallbackExecutor.ShutdownFallbackThreadFactory

Class Inheritance

extends Object
implements ThreadFactory

java.lang.Object
io.undertow.server.protocol.framed.ShutdownFallbackExecutor.ShutdownFallbackThreadFactory

All Implemented Interfaces

java.util.concurrent.ThreadFactory

Field Summary

Modifier and Type	Field and Description
private final AtomicLong	count
private final ThreadFactory	threadFactory

Constructor Summary

Access	Constructor and Description
pack-priv	ShutdownFallbackThreadFactory()

Method Summary

Modifier and Type	Method and Description
public Thread	newThread(Runnable a runnable to be executed by new thread instance r) Implements java.util.concurrent.ThreadFactory.newThread. Constructs a new unstarted `Thread` to run the given runnable.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

count	back to summary
private final AtomicLong count

threadFactory	back to summary
private final ThreadFactory threadFactory

Constructor Detail

ShutdownFallbackThreadFactory	back to summary
pack-priv ShutdownFallbackThreadFactory()

Method Detail

newThread back to summary

newThread	back to summary
public Thread newThread(Runnable r) Implements java.util.concurrent.ThreadFactory.newThread. Doc from java.util.concurrent.ThreadFactory.newThread. Constructs a new unstarted `Thread` to run the given runnable. Parameters r:Runnable a runnable to be executed by new thread instance Returns:Thread constructed thread, or `null` if the request to create a thread is rejected Annotations @Override

public Thread newThread(Runnable r)

Implements java.util.concurrent.ThreadFactory.newThread.

Doc from java.util.concurrent.ThreadFactory.newThread.

Constructs a new unstarted Thread to run the given runnable.

Parameters

r:Runnable: a runnable to be executed by new thread instance

Returns:Thread

constructed thread, or null if the request to create a thread is rejected

Annotations

@Override