reactor.core

接口 Fuseable

所有已知实现类:

Operators.MonoSubscriber, ReplayProcessor, UnicastProcessor

public interface Fuseable

A micro API for stream fusion, in particular marks producers that support a Fuseable.QueueSubscription.

嵌套类概要

嵌套类

限定符和类型	接口和说明
static interface	Fuseable.ConditionalSubscriber<T> A subscriber variant that can immediately tell if it consumed the value or not, directly allowing a new value to be sent if it didn't.
static interface	Fuseable.QueueSubscription<T> Support contract for queue-fusion based optimizations on subscriptions.
static interface	Fuseable.ScalarCallable<T> Marker interface indicating that the target can return a value or null, otherwise fail immediately and thus a viable target for assembly-time optimizations.
static interface	Fuseable.SynchronousSubscription<T> Base class for synchronous sources which have fixed size and can emit their items in a pull fashion, thus avoiding the request-accounting overhead in many cases.

字段概要

字段

限定符和类型	字段和说明
static int	ANY Indicates the QueueSubscription should decide what fusion it performs (input only).
static int	ASYNC Indicates the QueueSubscription can perform only async-fusion.
static int	NONE Indicates the QueueSubscription can't support the requested mode.
static int	SYNC Indicates the QueueSubscription can perform sync-fusion.
static int	THREAD_BARRIER Indicates that the queue will be drained from another thread thus any queue-exit computation may be invalid at that point.

方法概要

限定符和类型	方法和说明
static java.lang.String	fusionModeName(int mode) Attempt to convert a fusion mode int code into a human-readable representation.
static java.lang.String	fusionModeName(int mode, boolean ignoreThreadBarrier) Attempt to convert a fusion mode int code into a human-readable representation.

字段详细资料

NONE

static final int NONE

Indicates the QueueSubscription can't support the requested mode.

另请参阅:

常量字段值

SYNC

static final int SYNC

Indicates the QueueSubscription can perform sync-fusion.

另请参阅:

常量字段值

ASYNC

static final int ASYNC

Indicates the QueueSubscription can perform only async-fusion.

另请参阅:

常量字段值

ANY

static final int ANY

Indicates the QueueSubscription should decide what fusion it performs (input only).

另请参阅:

常量字段值

THREAD_BARRIER

static final int THREAD_BARRIER

Indicates that the queue will be drained from another thread thus any queue-exit computation may be invalid at that point.

For example, an asyncSource.map().publishOn().subscribe() sequence where asyncSource is async-fuseable: publishOn may fuse the whole sequence into a single Queue. That in turn could invoke the mapper function from its poll() method from another thread, whereas the unfused sequence would have invoked the mapper on the previous thread. If such mapper invocation is costly, it would escape its thread boundary this way.

另请参阅:

常量字段值

方法详细资料

fusionModeName

static java.lang.String fusionModeName(int mode)

Attempt to convert a fusion mode int code into a human-readable representation. Note that this can include the THREAD_BARRIER flag, as an appended +THREAD_BARRIER.

This method accepts -1 as a special code, mainly for the benefit of supporting testing scenarios where fusion can be entirely deactivated (returns Disabled). Other negative values and unknown positive codes on the other hand return Unknown(x).

Note that as this is a human-facing representation, the different values could evolve in the future. As such, never compare the returned string to a constant, but always use this method on both sides of a comparison.

参数:

mode - the fusion mode int code

返回:

a human-readable String representation of the code

fusionModeName

static java.lang.String fusionModeName(int mode,
                                       boolean ignoreThreadBarrier)

Attempt to convert a fusion mode int code into a human-readable representation. Note that this can include the THREAD_BARRIER flag, as an appended +THREAD_BARRIER, unless the ignoreThreadBarrier parameter is set to true.

This method accepts -1 as a special code, mainly for the benefit of supporting testing scenarios where fusion can be entirely deactivated (returns Disabled). Other negative values and unknown positive codes on the other hand return Unknown(x).

Note that as this is a human-facing representation, the different values could evolve in the future. As such, never compare the returned string to a constant, but always use this method on both sides of a comparison.

参数:

mode - the fusion mode int code

ignoreThreadBarrier - whether or not to ignore the THREAD_BARRIER flag in the representation

返回:

a human-readable String representation of the code