org.apache.logging.log4j.core.util

Class DefaultShutdownCallbackRegistry

java.lang.Object

org.apache.logging.log4j.core.util.DefaultShutdownCallbackRegistry

All Implemented Interfaces:

java.lang.Runnable, LifeCycle, LifeCycle2, ShutdownCallbackRegistry

public class DefaultShutdownCallbackRegistry
extends java.lang.Object
implements ShutdownCallbackRegistry, LifeCycle2, java.lang.Runnable

ShutdownRegistrationStrategy that simply uses Runtime.addShutdownHook(Thread). If no strategy is specified, this one is used for shutdown hook registration.

Since:

2.1

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	DefaultShutdownCallbackRegistry.RegisteredCancellable

Nested classes/interfaces inherited from interface org.apache.logging.log4j.core.LifeCycle

LifeCycle.State

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.Collection<Cancellable>	hooks
protected static Logger	LOGGER Status logger.
private java.lang.ref.Reference<java.lang.Thread>	shutdownHookRef
private java.util.concurrent.atomic.AtomicReference<LifeCycle.State>	state
private java.util.concurrent.ThreadFactory	threadFactory

Fields inherited from interface org.apache.logging.log4j.core.util.ShutdownCallbackRegistry

SHUTDOWN_CALLBACK_REGISTRY, SHUTDOWN_HOOK_ENABLED, SHUTDOWN_HOOK_MARKER

Constructor Summary

Constructors

Modifier	Constructor and Description
	DefaultShutdownCallbackRegistry() Constructs a DefaultShutdownRegistrationStrategy.
protected	DefaultShutdownCallbackRegistry(java.util.concurrent.ThreadFactory threadFactory) Constructs a DefaultShutdownRegistrationStrategy using the given ThreadFactory.

Method Summary

Modifier and Type	Method and Description
Cancellable	addShutdownCallback(java.lang.Runnable callback) Adds a Runnable shutdown callback to this class.
private void	addShutdownHook(java.lang.Thread thread)
LifeCycle.State	getState() Gets the life-cycle state.
void	initialize()
boolean	isStarted() Indicates if this can accept shutdown hooks.
boolean	isStopped()
private void	removeShutdownHook()
void	run() Executes the registered shutdown callbacks.
void	start() Registers the shutdown thread only if this is initialized.
void	stop()
boolean	stop(long timeout, java.util.concurrent.TimeUnit timeUnit) Cancels the shutdown thread only if this is started.

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

protected static final Logger LOGGER

Status logger.

state

private final java.util.concurrent.atomic.AtomicReference<LifeCycle.State> state

threadFactory

private final java.util.concurrent.ThreadFactory threadFactory

hooks

private final java.util.Collection<Cancellable> hooks

shutdownHookRef

private java.lang.ref.Reference<java.lang.Thread> shutdownHookRef

Constructor Detail

DefaultShutdownCallbackRegistry

public DefaultShutdownCallbackRegistry()

Constructs a DefaultShutdownRegistrationStrategy.

DefaultShutdownCallbackRegistry

protected DefaultShutdownCallbackRegistry(java.util.concurrent.ThreadFactory threadFactory)

Constructs a DefaultShutdownRegistrationStrategy using the given ThreadFactory.

Parameters:

threadFactory - the ThreadFactory to use to create a Runtime shutdown hook thread

Method Detail

run

public void run()

Executes the registered shutdown callbacks.

Specified by:

run in interface java.lang.Runnable

addShutdownCallback

public Cancellable addShutdownCallback(java.lang.Runnable callback)

Description copied from interface: ShutdownCallbackRegistry

Adds a Runnable shutdown callback to this class.

Specified by:

addShutdownCallback in interface ShutdownCallbackRegistry

Parameters:

callback - the shutdown callback to be executed upon shutdown.

Returns:

a Cancellable wrapper of the provided callback or null if the shutdown hook is disabled and cannot be added.

initialize

public void initialize()

Specified by:

initialize in interface LifeCycle

start

public void start()

Registers the shutdown thread only if this is initialized.

Specified by:

start in interface LifeCycle

addShutdownHook

private void addShutdownHook(java.lang.Thread thread)

stop

public void stop()

Specified by:

stop in interface LifeCycle

stop

public boolean stop(long timeout,
                    java.util.concurrent.TimeUnit timeUnit)

Cancels the shutdown thread only if this is started.

Specified by:

stop in interface LifeCycle2

Parameters:

timeout - the maximum time to wait

timeUnit - the time unit of the timeout argument

Returns:

true if the receiver was stopped cleanly and normally, false otherwise.

removeShutdownHook

private void removeShutdownHook()

getState

public LifeCycle.State getState()

Description copied from interface: LifeCycle

Gets the life-cycle state.

Specified by:

getState in interface LifeCycle

Returns:

the life-cycle state

isStarted

public boolean isStarted()

Indicates if this can accept shutdown hooks.

Specified by:

isStarted in interface LifeCycle

Returns:

true if this can accept shutdown hooks

isStopped

public boolean isStopped()

Specified by:

isStopped in interface LifeCycle