Гарантии видимости резьбы и трубопроводы реактора проекта ⇐ JAVA

[Anonymous]

Я работал с Project Reactor/WebFlux над созданием реактивных микросервисов на Java. Поскольку ранее я работал со Scala, меня беспокоят некоторые практики, с которыми я столкнулся. Рассмотрим следующий шаблон, в котором мы модифицируем изменяемый объект с помощью реактивного конвейера:

Код: Выделить всё

public Mono process(MyClass myclass) {
return doSomething(myclass)
.flatMap(result -> doSomethingElse(result, myclass))
.onErrorResume(throwable -> {
myclass.setErrors(toErrors(throwable)); // errors field does not have volatile modifier
return someFallback;
})
.flatMap(result -> postprocess(result, myclass));
}

Хотя все операции в конвейере выполняются последовательно, каждый этап потенциально может выполняться в отдельном потоке (например, может быть больше этапов, обеспечивающих переходы между потоками). Это вызывает беспокойство по поводу видимости памяти: мы можем изменить объект в одном потоке и прочитать его из другого. Без надлежащей синхронизации (например, изменяемых полей или синхронизированных блоков) между этими операциями не существует гарантии «случится до того».
Насколько я понимаю, несмотря на последовательные операции в конвейере, существует потенциальный риск: изменения, внесенные в объект в одном потоке, могут быть не сразу видны другому потоку из-за отсутствия надлежащих барьеров памяти или механизмов синхронизации. Это может привести к проблемам, которые трудно обнаружить и воспроизвести.
Однако мне не удалось воспроизвести проблему. Это может быть связано с современными оптимизациями JVM и механизмами согласованности кэша (проверено на Apple Silicon и процессоре Intel) или с тем, что я ошибаюсь в своем понимании.
Вопросы:

• Правильно ли я понимаю потенциальные проблемы видимости в реактивных конвейерах? И если да:
• Может ли кто-нибудь предоставить рабочий пример, демонстрирующий эту проблему видимости с энергонезависимыми полями (со строго последовательными этапами)?

Подробнее здесь: https://stackoverflow.com/questions/793 ... -pipelines