Блокировка внутри StreamObserver.onNext ()

Я не смог найти ничего об этом в документации GRPC. Ожидает ли GRPC, что моя реализация StreamObserver.onNext() будет неблокирующей? Каковы последствия для GRPC, если он блокирует (например, отклоняет новые запросы, ставит новые запросы в очередь и т. д.)?

java grpc

04.12.2018 15:04

Пользовательский скаляр GraphQL

Листовые узлы системы типов GraphQL называются скалярами. Достигнув скалярного типа, невозможно спуститься дальше по иерархии типов. Скалярный тип...

Как вычислять биты и понимать побитовые операторы в Java - объяснение с примерами

В компьютерном программировании биты играют важнейшую роль в представлении и манипулировании данными на двоичном уровне. Побитовые операции...

Поднятие тревоги для долго выполняющихся методов в Spring Boot

Приходилось ли вам сталкиваться с требованиями, в которых вас могли попросить поднять тревогу или выдать ошибку, когда метод Java занимает больше...

Принятие принципов SOLID в Spring Boot: Создание обслуживаемых и масштабируемых приложений

Коллекции (ArrayList , HashSet , HashMap)

Полный курс Java для разработчиков веб-сайтов и приложений

Получите сертификат Java Web и Application Developer, используя наш курс.

677

Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

Вы можете заблокировать, если вам нужно заблокировать.

Поскольку обратные вызовы для RPC не считаются потокобезопасными, блокировка задержит другие обратные вызовы до тех пор, пока вы не вернетесь. Это включает setOnReadyHandler и setOnCancelHandler в ClientCallStreamObserver и ServerCallStreamObserver.

При потоковой передаче RPC gRPC автоматически запрашивает другое сообщение после того, как вы вернетесь с вашего onNext(), поэтому, если вы заблокируете gRPC, вы избежите получения слишком большого количества сообщений. Однако gRPC по-прежнему позволяет буферизовать некоторые сообщения.

Блокировка не влияет на новые RPC.

04.12.2018 16:54

Другие вопросы по теме

Реализация map <string, string> в grpc для .netCore

C# в Unity: вызов асинхронного метода стиля обещания без блокировки основного потока

GRPC Interceptor - Изменить сообщение по числовому индикатору

C++ terminate вызывается после выброса экземпляра 'std :: system_error'

Я не могу установить GRPC на Mac OS X Mojave

--go_out: protoc-gen-go: система не может найти файл, указанный в Windows 10

Как заставить мой gRPC-клиент открывать несколько подключений к серверу?

Как создать ClassificationRequest со структурированными данными для отправки в TensorFlow Serving с gRPC

TLS для службы GRPC, работающей за Nginx с использованием Golang

Как отменить вызов Read () для grpc :: ClientReader в C++?

Блокировка внутри StreamObserver.onNext ()

Ответы 1

Другие вопросы по теме

Похожие вопросы