java - 多线程只写一个输出流并且数据丢失

Question

我运行五个线程来生成随机字符串数据，然后仅写入一个输出流。程序完成后，一些数据丢失了。

我简化了我的代码。

new Thread(() -> {
  stream.write(RANDOM_STRING + "\n)
).start();

class Stream {
  String buffer = "";

  Stream() {
    new Thread(() -> {
      BufferedOutputStream bs
       = new BufferedOutputStream(new FileOutputStream("PATH");
      bs.wrtie(buffer.getBytes());  // point 1
      buffer = ""                   // point 2
      bs.close();
    }).start();
  }
  public void write(String input) {
    buffer += input;
  }
}

我认为数据丢失的原因在第1点和第2点之间。我认为如果我使用索引数据结构来检查消耗了哪些数据，就可以解决。但有没有更好的方法来解决这个问题呢？请帮我。谢谢。

Answer 1

尝试使用ConcurrentLinkedQueue<String>对于 buffer ，使用方法 offer和poll而不是+=和= ""关于字符串引用。