Блог

Я создал приложение на основе webflux, которое, по сути, должно сериализовать некоторую сущность, считанную из источника данных newo4j, реактивным способом в потоковом режиме (новая строка JSON для каждого объекта). Мы говорим о процессах, связанных с вводом-выводом, в которых почти не задействованы операции с процессором (кроме сериализации плоской сущности в DTO и DTO в json). То, что мы испытываем, — это то, что мы знаем: количество ядер ограничено, поэтому у нас всего 4 разных потока, которые сериализуют данные. Но можем ли мы перенести фазу сериализации в другие потоки? Поскольку процесс связан с вводом-выводом, с уровнем параллелизма > 4, мы ждем, пока освободится первый поток reactor-epoll, в то время как на самом деле мы уже могли бы выполнить запрос и сопоставить результат. Можем ли мы переместить часть сериализации в потоковом режиме в какой-либо другой поток?

Спасибо, ФБ