java vertx中setWriteQueueMaxSize()使用什么值
我正在编写代码,以便在处理背压时将文件从一个异步复制到另一个
我知道有一个方便的类Pump
执行复制工作,但是,我正在手动执行复制工作,因为我想在将数据写入目标之前转换数据
为了处理背压,我使用以下代码
fileRead.handler(buffer -> {
fileWrite.write(applyTransform(buffer));
//check if reader is out of capacity for taking more data
if(fileWrite.writeQueueFull()){
System.out.println("writing queue full:");
//this pauses file handler from being called
fileRead.pause();
//Once, the writer is ready to accept more data, let it take up more
fileWrite.drainHandler(done -> {
System.out.println("write queue drained, so resuming now...");
//allow file reader handler to resume so, that it accepts incoming data
fileRead.resume();
});
}
});
我的问题只是关于{
This will return true if there are more bytes in the write queue than the value set using setWriteQueueMaxSize(int)
问题是如何确定setWriteQueueMaxSize(int)
的int值
共 (0) 个答案