12

我正在尝试通过 Java 中的多个线程将一些内容写入文件。每个线程读取不同的输入文件，进行一些计算并将一些（不同的）内容写入公共输出文件。问题是最后，输出文件只包含最后一个终止线程写入的内容，而不包含其他线程的内容。线程的相关代码 - 

public void run()
{
    try
    {
        File file = new File("/home/output.txt");
        if (!file.exists()) 
        {
             file.createNewFile();
        }
        FileWriter fw = new FileWriter(file.getAbsoluteFile());
        BufferedWriter bw = new BufferedWriter(fw);

        BufferedReader br = new BufferedReader(new FileReader(inputfile)); // each thread reads a different input file
        String line="";

        while((line=br.readLine())!=null)
        {
            String id = line.trim();               // fetch id

            StringBuffer sb = processId(userId);   // process id

            synchronized(this){
            bw.write(sb.toString() + "\n");        // write to file
            }
        }
        bw.close();
    }
    catch (IOException e)
    {
        e.printStackTrace();
    }
}

如何让所有线程将其内容写入公共文件？

4

5 回答 5

22

FileWriter使用使用附加模式的构造函数

FileWriter fw = new FileWriter(file.getAbsoluteFile(), true);
于 2013-10-06T10:36:02.653 回答
9

有一个文件写入器线程，它不断从阻塞队列中读取并写入文件。所有其他 20 个线程只会将数据放入阻塞队列。这将防止 20 个编写器线程之间的争用。

于 2014-03-04T08:24:10.473 回答
4

与您的代码相关的几点：

1.您创建的FileWriter方式不正确。如果要将数据附加到文件，请使用包含附加boolean参数 ( Make it true) 的构造函数：

public FileWriter(File file,boolean append) throws IOException

例如 ：

FileWriter fw = new FileWriter(file.getAbsoluteFile(),true);

2.你说的是多个线程将共享一个公共文件，但我在你的代码中看不到任何同步块。使用同步来确保一次只有一个线程可以访问共享资源。

于 2013-10-06T11:22:11.977 回答
2

FileWriter fw = new FileWriter(file.getAbsoluteFile(),true);

应该使用指示附加模式。

于 2013-10-06T10:38:44.417 回答
-4

我是新手。所以我可能错了！但是您的代码可能会或可能不会起作用。那是 Runnable 还是线程的运行？请注意：

MyClass implements Runnable {

 public void run() {
 ....synchronized(this)..
 }

}

Thread t1 = new Thread(new MyClass());
Thread t2 = new Thread(new MyClass());

我们中的许多人都这样做（我做到了，做到了:)，是的！每个线程都将获得对不同 obj 的锁定，并且您最终可能会得到意想不到的结果，除非操作系统使用某种机制来同步写入同一个文件（我不知道）。如果是这样，那么您的同步是无用的（在我的示例中无论如何都无用），如果不是，那么您很漂亮....另外请注意，可能有另一个使用此 output.txt 的进程，我们没有想法...复杂的东西，至少对我来说

我的观点是，如果您有一个SHARES、MUTABLE、STATE类的实例，则同步很有用。（让我们暂时忘记同步和静态）

MyClass 有状态吗？不，它是共享的吗？不，在我的例子中不是。它会起作用吗？不是这样的。大概是这样的？

MyClass mc = new MyClass()
Thread t1 = new Thread(mc);
Thread t2 = new Thread(mc);

PS：我忘记在每个线程上调用 start 。

于 2014-01-24T18:20:16.403 回答