Приложение, парсит директорию, находит нужные файлы и добавляет их названия в массив. Далее надо организовать их поочередную обработку, решение с выставлением таймаута перед запуском обработки второго файла не годится, надо именно чтобы предыдущий файл обработался, далее запустилась обработка следующего файла из массива. p.s. в коде небольшая каша, я только учусь.
public void exportProducer(ArrayList<String> findedFiles) {
if (findedFiles.size() != 0) {
for (String fileName : findedFiles) {
queue.add(() -> {
//export
progressBar1.setValue(0);
progressBar1.setString("0%");
String selectedFile4Auto = config.getPathForImport() + "/" + fileName;
setRowCount = rowCount.getRowCount(selectedFile4Auto);
model.addElement("Opening: " + fileName + "." + newline);
textArea1.setModel(model);
inputAllCorrectNums = new FindAllCorrectNumbers();
String pathForExport = config.getPathForExport() + "/" + fileName;
inputAllCorrectNums.getAllCorrectNums((selectedFile4Auto), setRowCount);
inputAllCorrectNums.getPropertyChangeSupport().addPropertyChangeListener("state", (evt) -> {
if (evt.getNewValue().equals(SwingWorker.StateValue.DONE)) {
try {
importedData = inputAllCorrectNums.get();
System.out.println("Export to File");
File selectedFile = new File(config.getPathForExport() + "/" + fileName);
exportToFile.exportFile(importedData, selectedFile);
model.addElement("Exporting: " + fileName + "." + newline);
textArea1.setModel(model);
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
inputAllCorrectNums.cancel(true);
}
});
doWorkForCorrectNums();
});
}
}
}
public void autoExport() {
Thread queueTread = new Thread(() -> {
while (true) {
try {
queue.take().run();
System.out.println("add queue");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
});
queueTread.start();
}
Решил вопрос следующим образом. Помог Паттерн Observer на Java - Наблюдатель http://www.javenue.info/post/76 -Убрал Очередь. -Убрал цикл forEach. -Добавил notifyListeners в область где SwingWorker отвечает что завершил работу, после чего счетчиком проверятся содержимое массива, если array.size() < счетчика, то exportProducer выполняется еще раз и так до того как счетчик не будет равен длине массива.
for (String fileName : findedFiles)
по очередиfor (String fileName : findedFiles)
Если вам нужно выполнять параллельно всё, то да, тогда можно очереди использовать. Но и в таком случае, очередь нужна лишь, если вы должны обращаться к 1 "узкому" участку в коде. Например, если вы можете многопоточно выполнить весь циклfor
но лишь в 1 файл вам нужно записывать результат. Тогда, чтобы все потоки, которые сделали обработку ваших файлов, записали результат в 1 файл и нужна очередь. ПОнятно? )))