如何从多个线程调用Sinks.Many<T>.tryEmitNext？

我遇到了同样的问题，从支持多线程安全发射的处理器迁移。我使用这个自定义 EmitFailureHandler 来执行 EmitFailureHandler 文档建议的繁忙循环。

public static EmitFailureHandler etryOnNonSerializedElse(EmitFailureHandler fallback){
return (signalType, emitResult) -> {
if (emitResult == EmitResult.FAIL_NON_SERIALIZED) {
LockSupport.parkNanos(10);
return true;
} else
return fallback.onEmitFailure(signalType, emitResult);
};
}


关于 3.4.0 实现有各种令人困惑的方面

• 这意味着除非使用 Unsafe 变体，否则接收器支持序列化发射，但实际上所有序列化版本都会在并发发射的情况下快速失败。


• Flux.Create 提供的 Sink 确实支持线程安全发射。

我希望图书馆在某个时候会提供一个可靠的工程替代方案。