Поток для обработки нескольких остальных вызовов

Я пытаюсь обработать около 1000 файлов, используя следующий код:

ExecutorService executor = Executors.newFixedThreadPool(threadPoolSize);
Runnable worker = null;
for (File file : files) {
    if (file.isFile()) {
        worker = new FileProcessThread(file, connectionVo);
        executor.execute(worker);
        file.deleteOnExit();
    }
}
while (!executor.isTerminated()) {
    System.out.println("Still running");
}
executor.shutdown();
System.out.println("Finished all threads");

Этот код создает несколько потоков. Каждый поток имеет несколько вызовов rest внутри. Эти остальные API предназначены для обработки входного файла. Каждый поток также регистрирует каждое событие транзакции, которое происходит во время обработки. Но результат выполнения этих потоков несовместим.

1. Для нескольких потоков он работает отлично. Выбирает файл. Регистрирует правильные
   транзакции и перемещает обработанный файл в нужный каталог.
2. Но для некоторых потоков он показывает некоторое непредсказуемое поведение, например, регистрирует событие обработки файла одного потока в другом.

Шаги в каждом потоке:

1. Создать транзакцию - оставшийся вызов
2. Регистрировать событие в транзакции для запуска процесса — остаточный вызов
3. Передает файл другому модулю для преобразования файла - остаточный вызов, который внутренне
   создает еще один поток, который синхронизируется
4. После обработки файл перемещается в другой - в тот же каталог кода.

Мне нужна стабильная производительность этих потоков. Любая помощь будет оценена.

Код внутри запуска:

 long transactionID = 0l;
    long connectionId = connectionVo.getConnectionId();
    try {
        transactionID = beginTransaction.getTransactionId();
        FileInputStream processedFileData;
        processedFileData = new FileInputStream(file);

        Response response = Service.postMessage(stream2file,              
        connectionId, 0, transactionID);

        if (response.getStatus() != 200) {
              writToDirectory(stream2file, userError, file.getName(), transactionID);
            }

        } else {
            String userArchive = getUserArchive();
            if (checkDirectory(userArchive, transactionID)) {
                writToDirectory(stream2file, userArchive, file.getName(), transactionID);
            }

        }
        file.delete();

    } catch (FileNotFoundException e) {
    }