Как я могу закончить замкнутый подпоток в Java?

Question

Мне нужно выполнить некоторую очистку, когда я собираюсь закончить цикл. Например, сохранение буфера, чтобы я мог продолжить позже.

PseudoCode: 
private class CalculatePI(Byte[] resume) implements Runnable{ 
    public void Run(){ 
     while(true){ 
      resume=resumeCalculating(resume); 
     } 
    } 
} 
Thread calculator= new Thread(new CalculatePI(Byte[] resume)); 
Thread.sleep(200); 
//And now I want to kill calculator 

Так что лучший способ реализовать это?

1. Используйте флаг: Но проблема в том, что если resumeCalculating() принимает (EDIT: долгое время) навсегда до конца?
2. Включить исключение в калькулятор, как?
3. Могу ли я использовать прослушиватели событий или что-то еще? Я думал, что они использовались для графических интерфейсов
4. Просто остановите его? И Class Thread включает какой-то деконструктор, который будет вызываться, когда поток прекращается, и я мог бы обработать там?

EDIT Владелец:

Я знаю, что я могу использовать флаг. Но подумайте:

public void Run(){ 
     while(true){ 
      resume=calculate_stepone(resume); //takes one minute 
      resume=calculate_steptwo(resume); //takes two minutes 
      resume=calculate_stepthree(resume); //takes three minutes 
      resume=calculate_steplast(resume); //takes four minutes 
     } 
    } 

ставит if(flag) saveResultsAndExit(); между каждой линией практической или красивая? Я просто хочу отбросить полученные результаты и сохранить предыдущие результаты.

Answer 1

Правильный способ, чтобы остановить поток является interrupt это.

Если задача, выполняемая в потоке, выполняет IO или использует sleep, тогда она получит сигнал (InterruptedException в этой точке); иначе задача должна регулярно опроса, чтобы узнать, есть ли ее interrupted.

Позволяет адаптировать psuedocode оригинального автора:

private class CalculatePI(Byte[] resume) implements Runnable{ 
    public void Run(){ 
     while(!Thread.interrupted()) { //### 
      resume=resumeCalculating(resume); 
     } 
    } 
} 
Thread calculator= new Thread(new CalculatePI(Byte[] resume)); 
calculator.run(); //### 
//... 
//And now I want to kill calculator 
calculator.interrupt(); //### sends the signal 
//... 
calculator.join(); //### actually waits for it to finish 

Answer 2

Ответ на 1: Вы можете обработать флаг прерывания в resumeCalculating().

Answer 3

Возможно, лучше всего использовать флаг, подождать некоторое время, пока поток не завершится, и если он не (resumeCalculating не вернулся), уничтожьте поток вручную. Вероятно, лучше не включать слишком много логики на основе потоков в resumeCalculating, это действительно зависит от того, как она реализована в отношении того, насколько легко прервать ее на полпути.

Answer 4

Создайте свою программу, чтобы resumeCalculating не выполнял навсегда, чтобы продолжить. Кроме того, синхронизируйте доступ к вашему флагову.