【问题标题】:Why doesn't my Java program write String into file?为什么我的 Java 程序不将字符串写入文件?
【发布时间】:2016-01-28 19:13:26
【问题描述】:

我有两个线程,每个线程都应该将其名称和递增的数字写入文件 - 但它不起作用。

如果我使用System.out.println() 方法,线程工作正常,只有写入文件失败。知道为什么吗?

这就是我的线程的样子:

package ThreadTest;

import java.io.*;

public class Thread1 implements Runnable {

public void run() {
    int x = 0;
    while (true) {

        try {

            BufferedWriter p1 = new BufferedWriter(new FileWriter("C:\\Users\\User\\Desktop\\a1.txt"));
            x++;
            p1.write("Thread11: " + x);
            Thread.sleep(500);
            p1.close();
        } catch (Exception e) {
            System.out.println(e.getMessage());
        }

    }
  }

}

主类如下所示:

package ThreadTest;

public class ThreadTestTest {

    public static void main(String args[]) {

        try {
            Thread1 t11 = new Thread1();
            Thread t1 = new Thread(t11);

            Thread2 t22 = new Thread2();
            Thread t2 = new Thread(t22);

            t2.start();
            t1.start();

            t1. join();
             t2. join();


        } catch (Exception e) {
            e.getMessage();
        }

    }

}

【问题讨论】:

  • 你遇到了什么错误?
  • 而且您不需要将t11 和t22 作为参数传递给另一个线程对象。实例本身就是线程。

标签: java multithreading file


【解决方案1】:

关闭文件后,您立即再次打开它,从而将其截断为零长度。

【讨论】:

【解决方案2】:

正如亨利已经指出的那样,您基本上需要让您的 BufferedWriter 在线程之间共享,这样您就不会不断地再次覆盖文件。

以下会做:

public class ThreadTest {
    public static void main(String[] args) {
        class ThreadSafeBufferedWriter extends BufferedWriter {
            public ThreadSafeBufferedWriter(Writer out) {
                super(out);     
            }

            @Override
            public synchronized void write(String str) throws IOException {
                super.write(str);
            }
        }

        try (BufferedWriter p1 = new ThreadSafeBufferedWriter(new FileWriter("/tmp/out.txt"))) {            
            Thread t1 = new Thread(new Payload("Thread1", p1));
            Thread t2 = new Thread(new Payload("Thread2", p1));         
            t2.start();
            t1.start();                
            t2.join();
            t1.join();                
        }
        catch (Exception e) {
            // do something smart
        }
    }
}

实际的有效载荷来自一个 Runnable,它位于此处:

class Payload implements Runnable {
    private String name;
    private Writer p1;

    public Payload(String _name, Writer _p1) {
        this.name = _name;
        this.p1 = _p1;
    }

    @Override
    public void run() {
        int x = 0;
        while (x < 10) { // you have to make sure these threads actually die at some point
            try {       
                x++;
                this.p1.write(this.name + ": " + x + "\n");
                Thread.sleep(500);      
            } catch (Exception e) {
                // do something smart
            }
        }
    }
}

【讨论】:

    【解决方案3】:

    谢谢大家:)!

    我刚刚在文件位置添加了一个 true:

    PrintWriter p2 = new PrintWriter(new FileWriter("C:\\Users\\User\\Desktop\\a1.txt",true));
    

    现在 java 追加文本而不是覆盖旧文本。

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 2012-02-01
      • 2021-12-01
      • 2015-07-16
      • 2016-05-27
      • 1970-01-01
      • 2014-01-04
      • 2021-03-11
      相关资源
      最近更新 更多