如何在NIO.2的AsynchronousFileChannel.write(ByteBuffer src, long position)中正确设置位置？

Question

我的 Java 程序执行多线程 XSLT 转换并将结果写入文件。为了避免 IO 瓶颈，我正在尝试新的 AsynchronousFileChannel。 XSLT-Threads 应该将其输出作为字符串提交（这可以工作），而 Writer 应该将它们附加到文件中（这还不能工作）。

我为写操作编写了一个自定义 Writer 类。我的线程调用 Writer.write(String text) 方法。在那里，我想将字符串作为 ByteBuffer 附加到 AsynchronousFileChannel。 不幸的是，我找不到在 asyncOutput.write(ByteBuffer, Long) 中使用什么作为位置值的提示。我尝试了不同的位置值但没有成功（输出被扰乱）。我很确定，同步没有问题，因为代码可以很好地与 FileChannels 配合使用（不支持简单的非阻塞 io 模式）：

• asyncOutput.size()
• asyncOutput.size() + future.get().longValue( )
• 0

这是我尝试执行此操作的代码：

public class MyWriter {
private AsynchronousFileChannel asyncOutput;    

    MyWriter(String filename) throws IOException {
        asyncOutput = AsynchronousFileChannel.open(Paths.get(filename), StandardOpenOption.CREATE, StandardOpenOption.WRITE, StandardOpenOption.TRUNCATE_EXISTING);
    }

    public void write(String output) throws IOException, ExecutionException, InterruptedException {
        System.err.println("Write was called");
        this.future = asyncOutput.write(string2ByteBuffer(output), asyncOutput.size());
    }

    public ByteBuffer string2ByteBuffer (String text){
    ...
    }
}

从 XSLT 线程（可运行）调用该方法，如下所示：

synchronized (this) {
        this.write2Writer(outputXmlWriter.toString());
        }
...
private void write2Writer(String output) throws IOException {
    try {
        myWriter.write(output);
    } catch (ExecutionException | InterruptedException ex) {
        ex.printStackTrace();
    }
}

Answer 1

我找不到任何提示来使用什么作为位置值
asyncOutput.write(ByteBuffer, Long)

这是你想要定位的位置。我不明白这有什么神秘的。

Answer 2

AsynchronousFileChannel 没有全局位置，这是故意的。相反，此通道为需要同时访问文件不同部分的应用程序提供异步 API。

Answer 3

从链接中提取的解决方案：

Future<Integer> future = asyncOutput.write(string2ByteBuffer(output), this.position);
this.position += future.get();

来源：http://cr.openjdk.java.net/~alanb/6830721/webrev.00/test/java/nio/channels/AsynchronousFileChannel/Basic.java.html