Java多线程文件保存

Question

我有一个创建多个无限线程的应用程序。每个线程读取一些信息，我使用线程池创建了一些任务（这很好）。

我添加了处理数组的附加函数，当它完成时，它将那些ArrayLists 发送到将这些列表保存为文件的新线程。我已经以 3 种方式实现了保存，只有一种成功。我想知道为什么其他两种方式没有。

1. 我创建了一个线程（通过new Thread(Runnable)）并为其提供了文件的数组和名称。在线程构造函数中，我创建了PrintWriter 并保存了文件。它运行没有任何问题。 （我有 1-10 个文件保存线程并行运行）。

2. 如果我将保存代码 outputStream.println(aLog); 放在 Run 方法中，它永远不会到达它并且在构造函数完成线程退出后。

3. 我将创建的可运行文件（文件保存）放在线程池中（保存代码在 run() 方法中）。当我只发送 1 个任务（要保存 1 个文件）时，一切都很好。超过 1 个任务被添加到池中（非常快），创建了异常（在调试时我可以看到所有需要的信息都可用）并且一些文件没有保存。

可以解释不同的行为吗？ 谢谢

请看下面的代码。 （从作为无限线程类的一部分的函数开始，它也将一些任务放入池中），在无限线程中创建的池： ExecutorService iPool = Executors.newCachedThreadPool();

private void logRate(double r1,int ind){
 historicalData.clear();
    for (int i = 499; i>0; i--){
      // some Code

     Data.add(0,array1[ind][i][0] + "," + array1[ind][i][1] + "," + 
                          array1[ind][i][2] + "," + array1[ind][i][3] + "," +
                          array2[ind][i] + "\n" );
     }
      // first item
      array1[ind][0][0] = r1; 
      array1[ind][0][1] = array1[ind][0][0] ;
      array1[ind][0][2] = array1[ind][0][0] ;
      array2[ind][0] = new SimpleDateFormat("HH:mm:ss yyyy_MM_dd").format(today); 

      Data.add(0,r1+","+r1+","+r1+","+r1+ "," + array2[ind][0] + '\n') ;

      // save the log send it to the pool (this is case 3)
      //iPool.submit(new FeedLogger(fName,Integer.toString(ind),Data));
      // Case 1 and 2 
      Thread fl = new Thread(new FeedLogger(fName,Integer.toString(ind),Data)) ;
    }

这里是 FeedLogger 类：

public class FeedLogger implements Runnable{
private List<String> fLog = new ArrayList<>() ;
PrintWriter outputStream = null;
String asName,asPathName;

public FeedLogger(String aName,String ind, List<String> fLog) {
this.fLog = fLog;
this.asName = aName;

try {
    asPathName = System.getProperty("user.dir") + "\\AsLogs\\"  + asName + "\\Feed" + ind 
                                    + ".log" ;

     outputStream = new PrintWriter(new FileWriter(asPathName));
     outputStream.println(fLog); Case 1 all is fine
     outputStream.flush(); // Case 1 all is fine
     outputStream.close(); Case 1 all is fine

}
catch (Exception ex) {
    JavaFXApplication2.logger.log(Level.SEVERE, null,asName + ex.getMessage());
 }
}

@Override
public void run()
{
 try{
    outputStream.println(fLog); // Cas2 --> not reaching this code, Case3 (as task) create 
                                                     exception when we have multiple tasks
    outputStream.flush();
    } 
  catch (Exception e) {
      System.out.println("err in file save e=" + e.getMessage() + asPathName + " feed size=" +  
                          fLog.size()); 
      JavaFXApplication2.logger.log(Level.ALL, null,asName + e.getMessage());
  } 

    finally {if (outputStream != null) {outputStream.close();}}
    }
  } 

Answer 1

您需要在 Thread 实例上调用 start() 以使其实际执行某些操作。