Java Executors: как остановить отправленные задачи?

Тот факт, что вы вызываете cancel() на Future, не означает, что задача остановится автоматически. Вы должны поработать с задачей, чтобы убедиться, что она остановится:

• Используйте cancel(true), чтобы прерывание было отправлено задаче.
• Ручка InterruptedException. Если функция в вашей задаче выдает InterruptedException, убедитесь, что вы корректно завершили работу как можно скорее после перехвата исключения.
• Периодически проверяйте Thread.currentThread().isInterrupted(), выполняет ли задача непрерывные вычисления.

Например:

class LongTask implements Callable<Double> {
    public Double call() {
        
         // Sleep for a while; handle InterruptedException appropriately
         try {
             Thread.sleep(10000);
         } catch (InterruptedException ex) {
             System.out.println("Exiting gracefully!");
             return null;
         }


         // Compute for a while; check Thread.isInterrupted() periodically
         double sum = 0.0;
         for (long i = 0; i < 10000000; i++) {
             sum += 10.0
             if (Thread.currentThread().isInterrupted()) {
                 System.out.println("Exiting gracefully");
                 return null;
             }
         }

         return sum;
    } 
}

Кроме того, как упоминалось в других сообщениях: ConcurrentModificationException может быть выброшено, даже если используется потокобезопасный класс Vector, потому что итераторы, которые вы получаете из Vector, не являются потокобезопасными и, следовательно, должны быть синхронизированы. В расширенном цикле for используются итераторы, поэтому будьте осторожны:

final Vector<Double> vector = new Vector<Double>();
vector.add(1.0);
vector.add(2.0);

// Not thread safe!  If another thread modifies "vector" during the loop, then
// a ConcurrentModificationException will be thrown.
for (Double num : vector) {
    System.out.println(num);
}

// You can try this as a quick fix, but it might not be what you want:
synchronized (vector) {    // "vector" must be final
    for (Double num : vector) {
        System.out.println(num);
    }
}

ConcurrentModificationException поступает из вашего обращения к tasks.clear(), в то время как ваши Exceutors повторяют ваш tasks Vector. Что вы можете попробовать сделать, так это вызвать _ 5_ на ExecutorService

Наиболее распространенный случай для ConcurrentModificationException - это когда vector изменяется одновременно с итерацией. Часто это делается в одном потоке. Вам нужно удерживать блокировку Vector на протяжении всей итерации (и осторожно, чтобы не зайти в тупик).

fut.get () - это блокирующий вызов, даже по истечении тайм-аута вы будете блокироваться до тех пор, пока задача не будет выполнена. Если вы хотите остановиться как можно ближе к 5-минутной отметке, вам нужно проверить флаг прерывания, я просто рекомендую вам сделать это с помощью метода Thread.isInterrupted (), который сохраняет состояние прерывания. Если вы хотите просто немедленно остановиться и вам не нужно очищать какое-либо состояние, создайте исключение, которое будет перехвачено Future и указано вам как ExecutionException.

fut.cancel (true) ничего не делает, поскольку метод invokeAll () уже сделал это за вас.

Если вы не используете коллекцию "tasks" где-то еще, вам, вероятно, не нужно вызывать для нее clear (). Это не будет источником вашей проблемы, поскольку метод invokeAll () выполняется со списком к тому моменту, когда вы вызываете clear (). Но, если вам нужно начать формирование списка новых задач для выполнения, я предлагаю вам сформировать новый Список задач, а не использовать старый Список новых задач.

К сожалению, у меня нет ответа на вашу проблему. Я не вижу здесь достаточно информации, чтобы диагностировать это. Ничто в предоставленном вами фрагменте кода не указывает на неправильное (только ненужное) использование библиотечных классов / методов. Возможно, если вы включили полную трассировку стека, а не ошибку одной строки.

Поместите fut.cancel(true); в блок finally