Исполнители Java: как я могу остановить отправленные задачи?

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

• Используйте cancel (true) , чтобы прерывание было отправлено задаче.
• Handle 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 , потому что итераторы, которые вы получаете из вектора , не являются потокобезопасными и, следовательно, должны быть синхронизированы. В расширенном цикле 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);
    }
}