假設(shè)我有一個(gè) grpc-java 服務(wù)器，代碼如下：@Overridepublic void getData(RequestValue requestValue, StreamObserver<ResponseValue>responseObserver) { ResponseValue rv = ... // blocking code here responseObserver.onNext(rv); responseObserver.onCompleted();}因此，由于阻塞代碼（來自數(shù)據(jù)庫或其他服務(wù)的數(shù)據(jù)），我有一個(gè) responseValue。我想避免使用另一個(gè)線程池來阻塞當(dāng)前線程來執(zhí)行阻塞任務(wù)。例如，在 Netty 中，我可以使用特定的 EventExecutorGroup 來完成此類任務(wù)。如何使用 grpc-java 服務(wù)正確管理它？
1 回答
慕田峪9158850
TA貢獻(xiàn)1794條經(jīng)驗(yàn) 獲得超8個(gè)贊
最簡單的方法是將 responseObserver 傳遞給長時(shí)間運(yùn)行的任務(wù)：
@Override
public void getData(RequestValue requestValue, StreamObserver<ResponseValue> responseObserver) {
Runnable r = () -> {
try {
ResponseValue rv = ... // blocking code here
responseObserver.onNext(rv);
responseObserver.onCompleted();
} catch (Exception e) {
responseObserver.onError(e);
}
executor.schedule(r);
}
重要的是您在某個(gè)時(shí)間完成調(diào)用，即使發(fā)生意外錯(cuò)誤也是如此。否則你會(huì)泄漏調(diào)用（在超時(shí)發(fā)生之前保持打開狀態(tài)，如果有的話）。
添加回答
舉報(bào)
0/150
提交
取消