有 Java 编程相关的问题?

你可以在下面搜索框中键入要查询的问题!

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();
                    });
                }
            });

我的问题只是关于{}的{a1}所说的{}

This will return true if there are more bytes in the write queue than the value set using setWriteQueueMaxSize(int)

问题是如何确定setWriteQueueMaxSize(int)的int值


共 (0) 个答案