Хай, у меня такой вопрос по Reactor Core:

Question

Хай, у меня такой вопрос по Reactor Core:

CountDownLatch countdownLatch = new CountDownLatch(1);

Disposable subscription = client.receiveMessages()
.subscribe(
message -> System.out.println(message.getBody()),
System.err::println
);

countdownLatch.await(1, MINUTES);

У библиотеки для работы с Azure очередями есть два клиента - блокирующий и неблокирующий.
Я использую Async Client у которого есть метод receiveMessages(), который возвращает infinite Flux, на Flux я создаю subscribe который просто печатает в консоль текст сообщения. Суть в том что версия на неблокирующем клиенте работает медленнее чем на блокирующем - обрабатывает меньше сообщений за минуту.

Почему так происходит, что я упускаю?

#backend #java #programming #russian

0

19.08.2021

8 ответов

9 просмотров

Mykyta Berehulia Автор вопроса

Alexey Genus 😎
Печать в консоль занимает время, это может влиять ...

Суть в том что конечная цель - это эндпоинт который забирает сообщения из очереди и печатает их в консоль

0

19.08.2021

Alexey Genus 😎

Mykyta Berehulia
Суть в том что конечная цель - это эндпоинт которы...

Ну попробуйте на терминале с аппаратным ускорением или писать в dev/null. Так можно будет устранить этот боттлнек. Если результат не изменится, можно попрофилировать

0

19.08.2021

Dmitry Bekrenev

А countdownlatch тебе зачем?

0

19.08.2021

central hardware

Mykyta Berehulia
Суть в том что конечная цель - это эндпоинт которы...

Печатай в /dev/null тогда будет более реалистичный тест

0

19.08.2021

Artem Z