io.servicetalk.concurrent.internal

Class SignalOffloaders

java.lang.Object

io.servicetalk.concurrent.internal.SignalOffloaders

public final class SignalOffloaders
extends java.lang.Object

A factory for creating different SignalOffloaders.

Method Summary

Modifier and Type	Method and Description
static SignalOffloaderFactory	defaultOffloaderFactory() Return a default SignalOffloaderFactory.
static boolean	hasThreadAffinity(Executor executor) Returns true if the passed Executor honors thread affinity.
static SignalOffloader	newOffloaderFor(Executor executor) Create a new instance of SignalOffloader using the passed executor.
static SignalOffloader	newTaskBasedOffloader(Executor executor) Create a new instance of SignalOffloader using the passed executor that uses granular tasks for sending signals.
static SignalOffloader	newThreadBasedOffloader(Executor executor) Create a new instance of SignalOffloader using the passed executor that captures a thread for its lifetime.
static SignalOffloaderFactory	taskBasedOffloaderFactory() Return a SignalOffloaderFactory that uses granular tasks for sending signals.
static SignalOffloaderFactory	threadBasedOffloaderFactory() Return a SignalOffloaderFactory with thread affinity.

Methods inherited from class java.lang.Object

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

Method Detail

defaultOffloaderFactory

public static SignalOffloaderFactory defaultOffloaderFactory()

Return a default SignalOffloaderFactory.

Returns:

The default SignalOffloaderFactory.

threadBasedOffloaderFactory

public static SignalOffloaderFactory threadBasedOffloaderFactory()

Return a SignalOffloaderFactory with thread affinity.

Returns:

A SignalOffloaderFactory with thread affinity..

taskBasedOffloaderFactory

public static SignalOffloaderFactory taskBasedOffloaderFactory()

Return a SignalOffloaderFactory that uses granular tasks for sending signals.

Returns:

A SignalOffloaderFactory that uses granular tasks for sending signals.

newOffloaderFor

public static SignalOffloader newOffloaderFor(Executor executor)

Create a new instance of SignalOffloader using the passed executor.

Parameters:

executor - Executor to be used by the returned SignalOffloader to offload signals.

Returns:

Newly created SignalOffloader.

newTaskBasedOffloader

public static SignalOffloader newTaskBasedOffloader(Executor executor)

Create a new instance of SignalOffloader using the passed executor that uses granular tasks for sending signals.

Parameters:

executor - Executor to be used by the returned SignalOffloader to offload signals.

Returns:

Newly created SignalOffloader.

newThreadBasedOffloader

public static SignalOffloader newThreadBasedOffloader(Executor executor)

Create a new instance of SignalOffloader using the passed executor that captures a thread for its lifetime.

Parameters:

executor - Executor to be used by the returned SignalOffloader to offload signals.

Returns:

Newly created SignalOffloader.

hasThreadAffinity

public static boolean hasThreadAffinity(Executor executor)

Returns true if the passed Executor honors thread affinity.

Parameters:

executor - Executor to inspect.

Returns:

true if the passed Executor honors thread affinity.