Modifier and Type	Class and Description
private static class	BaseContainer.DaemonThreadFactory
protected static interface	BaseContainer.ShutDownCondition

Field Summary

Modifier and Type	Field and Description
private final Object	EXECUTORS_CLEAN_UP_LOCK This lock ensures that only one instance of each type of executors will be created and it also prevents a situation when a client is given an executor that is just about to be shut down.
private volatile ExecutorService	executorService
private static final Logger	LOGGER
private final ExecutorService	managedExecutorService
private final ScheduledExecutorService	managedScheduledExecutorService
private volatile ScheduledExecutorService	scheduledExecutorService
private final ThreadFactory	threadFactory

Constructor Summary

Access	Constructor and Description
public	BaseContainer()

Method Summary

Modifier and Type	Method and Description
public ExecutorService	Returns: executor service. getExecutorService() Implements abstract org.glassfish.tyrus.core.ExecutorServiceProvider.getExecutorService. Returns a container-managed `java.util.concurrent.ExecutorService` registered under `java:comp/DefaultManagedExecutorService` or if the lookup has failed, it returns a `java.util.concurrent.ExecutorService` created and managed by this instance of `org.glassfish.tyrus.core.BaseContainer`.
public ScheduledExecutorService	Returns: scheduled executor service. getScheduledExecutorService() Implements abstract org.glassfish.tyrus.core.ExecutorServiceProvider.getScheduledExecutorService. Returns a container-managed `java.util.concurrent.ScheduledExecutorService` registered under `java:comp/DefaultManagedScheduledExecutorService` or if the lookup has failed it returns a `java.util.concurrent.ScheduledExecutorService` created and managed by this instance of `org.glassfish.tyrus.core.BaseContainer`.
private ExecutorService	lookupManagedExecutorService()
private ScheduledExecutorService	lookupManagedScheduledExecutorService()
public void	shutdown() Release executor services managed by this instance.
protected void	shutdown(BaseContainer.ShutDownCondition condition that will be evaluated before executor services are released and they will be released only if the condition is evaluated to `true`. The condition will be evaluated in a synchronized block in order to make the process of its evaluation and executor services release an atomic operation. shutDownCondition) Release executor services managed by this instance if the condition passed in the parameter is fulfilled.

Field Detail

EXECUTORS_CLEAN_UP_LOCK	back to summary
private final Object EXECUTORS_CLEAN_UP_LOCK This lock ensures that only one instance of each type of executors will be created and it also prevents a situation when a client is given an executor that is just about to be shut down.

executorService	back to summary
private volatile ExecutorService executorService

LOGGER	back to summary
private static final Logger LOGGER

managedExecutorService	back to summary
private final ExecutorService managedExecutorService

managedScheduledExecutorService	back to summary
private final ScheduledExecutorService managedScheduledExecutorService

scheduledExecutorService	back to summary
private volatile ScheduledExecutorService scheduledExecutorService

threadFactory	back to summary
private final ThreadFactory threadFactory

Constructor Detail

BaseContainer	back to summary
public BaseContainer()

Method Detail

getExecutorService back to summary

getExecutorService	back to summary
public ExecutorService getExecutorService() Implements abstract org.glassfish.tyrus.core.ExecutorServiceProvider.getExecutorService. Returns a container-managed `java.util.concurrent.ExecutorService` registered under `java:comp/DefaultManagedExecutorService` or if the lookup has failed, it returns a `java.util.concurrent.ExecutorService` created and managed by this instance of `org.glassfish.tyrus.core.BaseContainer`. Returns:ExecutorService executor service. Annotations @Override

public ExecutorService getExecutorService()

Implements abstract org.glassfish.tyrus.core.ExecutorServiceProvider.getExecutorService.

Returns a container-managed java.util.concurrent.ExecutorService registered under java:comp/DefaultManagedExecutorService or if the lookup has failed, it returns a java.util.concurrent.ExecutorService created and managed by this instance of org.glassfish.tyrus.core.BaseContainer.

Returns:ExecutorService

executor service.

Annotations

@Override

getScheduledExecutorService back to summary

getScheduledExecutorService	back to summary
public ScheduledExecutorService getScheduledExecutorService() Implements abstract org.glassfish.tyrus.core.ExecutorServiceProvider.getScheduledExecutorService. Returns a container-managed `java.util.concurrent.ScheduledExecutorService` registered under `java:comp/DefaultManagedScheduledExecutorService` or if the lookup has failed it returns a `java.util.concurrent.ScheduledExecutorService` created and managed by this instance of `org.glassfish.tyrus.core.BaseContainer`. Returns:ScheduledExecutorService scheduled executor service. Annotations @Override

public ScheduledExecutorService getScheduledExecutorService()

Implements abstract org.glassfish.tyrus.core.ExecutorServiceProvider.getScheduledExecutorService.

Returns a container-managed java.util.concurrent.ScheduledExecutorService registered under java:comp/DefaultManagedScheduledExecutorService or if the lookup has failed it returns a java.util.concurrent.ScheduledExecutorService created and managed by this instance of org.glassfish.tyrus.core.BaseContainer.

Returns:ScheduledExecutorService

scheduled executor service.

Annotations

@Override

lookupManagedExecutorService	back to summary
private ExecutorService lookupManagedExecutorService()

lookupManagedScheduledExecutorService	back to summary
private ScheduledExecutorService lookupManagedScheduledExecutorService()

shutdown	back to summary
public void shutdown() Release executor services managed by this instance. Executor services obtained via JNDI lookup won't be shut down.

shutdown back to summary

shutdown	back to summary
protected void shutdown(BaseContainer.ShutDownCondition shutDownCondition) Release executor services managed by this instance if the condition passed in the parameter is fulfilled. Executor services obtained via JNDI lookup won't be shut down. Parameters shutDownCondition:BaseContainer.ShutDownCondition condition that will be evaluated before executor services are released and they will be released only if the condition is evaluated to `true`. The condition will be evaluated in a synchronized block in order to make the process of its evaluation and executor services release an atomic operation.

protected void shutdown(BaseContainer.ShutDownCondition shutDownCondition)

Release executor services managed by this instance if the condition passed in the parameter is fulfilled. Executor services obtained via JNDI lookup won't be shut down.

Parameters

shutDownCondition:BaseContainer.ShutDownCondition: condition that will be evaluated before executor services are released and they will be released only if the condition is evaluated to true. The condition will be evaluated in a synchronized block in order to make the process of its evaluation and executor services release an atomic operation.

org.glassfish.tyrus.core back to summary

private Class BaseContainer.DaemonThreadFactory

Class Inheritance

extends Object
implements ThreadFactory

java.lang.Object
org.glassfish.tyrus.core.BaseContainer.DaemonThreadFactory

All Implemented Interfaces

java.util.concurrent.ThreadFactory

Field Summary

Modifier and Type	Field and Description
pack-priv final String	namePrefix
pack-priv static final AtomicInteger	poolNumber
pack-priv final AtomicInteger	threadNumber

Constructor Summary

Access	Constructor and Description
pack-priv	DaemonThreadFactory()

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

namePrefix	back to summary
pack-priv final String namePrefix

poolNumber	back to summary
pack-priv static final AtomicInteger poolNumber

threadNumber	back to summary
pack-priv final AtomicInteger threadNumber

Constructor Detail

DaemonThreadFactory	back to summary
pack-priv DaemonThreadFactory()

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

public abstract Class BaseContainer

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class BaseContainer.DaemonThreadFactory

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

protected Interface BaseContainer.ShutDownCondition

Method Summary

Method Detail