Module com.semanticcms.core.servlet

Package com.semanticcms.core.servlet

Class ConcurrencyCoordinator

java.lang.Object

com.semanticcms.core.servlet.ConcurrencyCoordinator

All Implemented Interfaces:

ServletContextListener, ServletRequestAttributeListener, EventListener

@WebListener("Decides whether to use concurrent or sequential implementations.")
public class ConcurrencyCoordinator
extends Object
implements ServletContextListener, ServletRequestAttributeListener

Determines if concurrent processing is recommended for the current request.

See Also:

• CountConcurrencyListener

Constructor Summary

Constructors

Constructor	Description
ConcurrencyCoordinator()

Method Summary

Modifier and Type	Method	Description
void	attributeAdded(ServletRequestAttributeEvent event)
void	attributeRemoved(ServletRequestAttributeEvent event)
void	attributeReplaced(ServletRequestAttributeEvent event)
void	contextDestroyed(ServletContextEvent event)
void	contextInitialized(ServletContextEvent event)
static Executor	getRecommendedExecutor(ServletContext servletContext, ServletRequest request)	Gets the executor to use for per-processor tasks.
static boolean	isConcurrentProcessingRecommended(ServletRequest request)	Checks if concurrent processing is recommended.
static boolean	useConcurrentSubrequests(ServletRequest request)	Determines if concurrent subrequests are currently allowed and advised for the given request.

Methods inherited from class java.lang.Object

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

Constructor Details

ConcurrencyCoordinator

public ConcurrencyCoordinator()

Method Details

contextInitialized

public void contextInitialized(ServletContextEvent event)

Specified by:

contextInitialized in interface ServletContextListener

contextDestroyed

public void contextDestroyed(ServletContextEvent event)

Specified by:

contextDestroyed in interface ServletContextListener

attributeAdded

public void attributeAdded(ServletRequestAttributeEvent event)

Specified by:

attributeAdded in interface ServletRequestAttributeListener

attributeRemoved

public void attributeRemoved(ServletRequestAttributeEvent event)

Specified by:

attributeRemoved in interface ServletRequestAttributeListener

attributeReplaced

public void attributeReplaced(ServletRequestAttributeEvent event)

Specified by:

attributeReplaced in interface ServletRequestAttributeListener

isConcurrentProcessingRecommended

public static boolean isConcurrentProcessingRecommended(ServletRequest request)

Checks if concurrent processing is recommended. Recommended when the overall request concurrency is less than the preferred concurrency. This value will remain consistent throughout the processing of a request.

See Also:

• Executors.getPreferredConcurrency()

useConcurrentSubrequests

public static boolean useConcurrentSubrequests(ServletRequest request)

Determines if concurrent subrequests are currently allowed and advised for the given request.

1. Concurrent subrequests must be enabled: SemanticCMS.getConcurrentSubrequests()
2. Request concurrency must be less than the executor per-processor thread limit: isConcurrentProcessingRecommended(jakarta.servlet.ServletRequest)

getRecommendedExecutor

public static Executor getRecommendedExecutor(ServletContext servletContext,
 ServletRequest request)

Gets the executor to use for per-processor tasks. If isConcurrentProcessingRecommended(jakarta.servlet.ServletRequest), is Executors.getPerProcessor(), otherwise is Executors.getSequential()