Package com.google.mu.util.concurrent

Class StructuredConcurrencyExecutorPlugin

java.lang.Object

com.google.mu.util.concurrent.StructuredConcurrencyExecutorPlugin

public abstract class StructuredConcurrencyExecutorPlugin
extends Object

SPI Used by ServiceLoader to plug in the executor used by Fanout.

Steps to create a plugin:

• Create a public subclass of StructuredConcurrencyExecutorPlugin and override createExecutor().
• Annotate your class with @AutoService(StructuredConcurrencyExecutorPlugin.class).

Since:

8.1

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	StructuredConcurrencyExecutorPlugin.Priority	Plugin priority from low to high.

Constructor Summary

Constructors

Constructor	Description
StructuredConcurrencyExecutorPlugin()

Method Summary

Modifier and Type	Method	Description
protected abstract ExecutorService	createExecutor()	Subclasses override this method to create the executor that runs all structured concurrency fanout tasks.
protected StructuredConcurrencyExecutorPlugin.Priority	priority()	Returns the priority of this plugin when multiple plugins are available.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

StructuredConcurrencyExecutorPlugin

public StructuredConcurrencyExecutorPlugin()

Method Details

createExecutor

protected abstract ExecutorService createExecutor()

Subclasses override this method to create the executor that runs all structured concurrency fanout tasks. The returned executor will be used as a singleton and never shut down. It's recommended for the executor to use virtual and daemon threads.

priority

protected StructuredConcurrencyExecutorPlugin.Priority priority()

Returns the priority of this plugin when multiple plugins are available. Defaults to StructuredConcurrencyExecutorPlugin.Priority.FRAMEWORK_STANDARD, intended for server frameworks to implement.

toString

public String toString()

Overrides:

toString in class Object