使用ExecutorService命令写入同一文件

Question

我正在尝试实例化ExecutorService中需要按顺序写入文件的任务，所以如果存在33个任务，它们需要按顺序编写。。。

我曾尝试使用LinkedBlockingQueue和ReentrantLock来保证顺序，但据我所知，在公平模式下，它会解锁到ExecutorService创建的x个线程中最年轻的一个。

private final static Integer cores =      Runtime.getRuntime().availableProcessors();
private final ReentrantLock lock = new ReentrantLock(false);
private final ExecutorService taskExecutor;

在构造函数中

taskExecutor = new ThreadPoolExecutor
        (cores, cores, 1, TimeUnit.MINUTES, new LinkedBlockingQueue());

所以我处理一个输入文件对等任务的配额

if(s.isConverting()){
   if(fileLineNumber%quote > 0) tasks = (fileLineNumber/quote)+1;
   else tasks = (fileLineNumber/quote);
   for(int i = 0 ; i<tasks || i<1 ; i++){
      taskExecutor.execute(new ConversorProcessor(lock,this,i));
   }
}

做的任务

public void run() {
    getFileQuote();
    resetAccumulators();
    process();
    writeResult();
}

我的问题就在这里：

private void writeResult() {
    lock.lock();
    try {
        BufferedWriter bw = new BufferedWriter(new FileWriter("/tmp/conversion.txt",true));
        Integer index = -1;
        if(i == 0){
            bw.write("ano dia tmin tmax tmed umid vento_vel rad precn");
        }
        while(index++ < getResult().size()-1){
            bw.write(getResult().get(index) + "n");
        }
        if(i == controller.getTasksNumber()){ 
            bw.write(getResult().get(getResult().size()-1));
        }
        else{ 
            bw.write(getResult().get(getResult().size()-1) + "n");
        }
        bw.close();
    } catch (IOException ex) {
        Logger.getLogger(ConversorProcessor.class.getName()).log(Level.SEVERE, null, ex);
    } finally { 
        lock.unlock(); 
    }
}

Answer 1

在我看来，除了将输出写入文件之外，所有事情都需要同时进行，并且必须按照对象创建顺序进行。

我会从线程代码中取出写入文件的代码writeResult()方法，而是创建Futures，返回由process()方法创建的String，并将Futures加载到ArrayList<Future<String>>中。然后，您可以在每个Future上调用get()的for循环中迭代ArrayList，并使用BufferedWriter或PrintWriter将结果写入文本文件。