gpt4 book ai didi

java - 在 StreamObserver.onNext() 内部阻塞

转载 作者:行者123 更新时间:2023-12-02 03:01:46 24 4
gpt4 key购买 nike

我在 GRPC 文档中找不到任何与此相关的内容。 GRPC 是否期望我的 StreamObserver.onNext() 实现是非阻塞的?如果 GRPC 确实阻塞(例如拒绝新请求、对新请求排队等),会对 GRPC 产生什么影响?

最佳答案

如果需要屏蔽,可以屏蔽。

由于 RPC 的回调被认为是非线程安全的,因此阻塞会延迟其他回调,直到您返回。其中包括 ClientCallStreamObserverServerCallStreamObserver 中的 setOnReadyHandlersetOnCancelHandler

在流式 RPC 中,gRPC 在您从 onNext() 返回后自动请求另一条消息,因此如果您阻止 gRPC 将避免接收太多消息。不过,gRPC 仍然允许缓冲一些消息。

阻塞对新的 RPC 没有影响。

关于java - 在 StreamObserver.onNext() 内部阻塞,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/53614704/

24 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com