com.cloudhopper.commons.util.windowing.Window.complete()方法的使用及代码示例

x33g5p2x  于2022-02-03 转载在 其他  
字(1.6k)|赞(0)|评价(0)|浏览(119)

本文整理了Java中com.cloudhopper.commons.util.windowing.Window.complete()方法的一些代码示例,展示了Window.complete()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Window.complete()方法的具体详情如下:
包路径:com.cloudhopper.commons.util.windowing.Window
类名称:Window
方法名:complete

Window.complete介绍

[英]Successfully completes a request by setting the response on the associated future. Any callers/threads waiting for completion will be signaled. Also, since this frees up a slot in the window, one caller/thread blocked with a pending offer will be signaled to continue.
[中]通过设置相关未来的响应,成功完成请求。等待完成的所有调用方/线程都将收到信号。此外,由于这会释放窗口中的一个插槽,一个被挂起的报价阻塞的调用方/线程将收到继续的信号。

代码示例

代码示例来源:origin: com.cloudhopper/ch-smpp

WindowFuture<Integer,PduRequest,PduResponse> future = this.sendWindow.complete(receivedPduSeqNum, responsePdu);
if (future != null) {
  logger.trace("Found a future in the window for seqNum [{}]", receivedPduSeqNum);

代码示例来源:origin: twitter-archive/cloudhopper-smpp

WindowFuture<Integer,PduRequest,PduResponse> future = this.sendWindow.complete(receivedPduSeqNum, responsePdu);
if (future != null) {
  logger.trace("Found a future in the window for seqNum [{}]", receivedPduSeqNum);

代码示例来源:origin: org.restcomm.smpp/ch-smpp

WindowFuture<Integer,PduRequest,PduResponse> future = this.sendWindow.complete(receivedPduSeqNum, responsePdu);
if (future != null) {
  logger.trace("Found a future in the window for seqNum [{}]", receivedPduSeqNum);

代码示例来源:origin: com.fizzed/ch-smpp

WindowFuture<Integer,PduRequest,PduResponse> future = this.sendWindow.complete(receivedPduSeqNum, responsePdu);
if (future != null) {
  logger.trace("Found a future in the window for seqNum [{}]", receivedPduSeqNum);

相关文章