Как остановить, приостановить, отменить поток в java

Question

Я разрабатываю приложение в java, которое запускает некоторые потоки, которые выполняют некоторые задания, и обновляет JTable с помощью JProgressBar. я JPopupMenu развивать на JTable, который имеет некоторые JMenuItem:

• Пауза
• Stop
• Отменить
• RESUME

Так я хочу, чтобы быть в состоянии сделать это.

Когда пользователь добавить новый поток в JTable я сохранить поток в ArrayList<Thread>, так что я должен реализовать

stop.addActionListener(new ActionListener() { 
      @Override 
      public void actionPerformed(ActionEvent ae) { 

      } 
     }); 

и другой ..

так я стараюсь, с гипотезой, что у меня есть индекс текущего потока:

Thread t = working.get(selectedThread); //where working is my `ArrayList<Thread>` 
t.interrupt(); 

но ничего .. это продолжать работать ... так я стараюсь:

try { 
         working.get(actualRow).wait(); 
        } catch (InterruptedException ex) { 
         Logger.getLogger(PannelloRicerca.class.getName()).log(Level.SEVERE, null, ex); 
        } 

, но поймите меня IllegalStateMonitorException на wait(), поэтому я не знаю, как это сделать .. может кто-то мне помочь?

Answer 1

Thread.interrupt() вызова только устанавливает битые прерывания на Thread и это вызывает какие-либо wait или sleep звонков бросить InterruptedException. Он не отменяет выполнение потока, как многие ожидают.

Вы можете проверить бит прерывания в потоке, как это:

while (!Thread.currentThread().isInterrupted()) { 
    ... 
} 

Типичный способ для людей, чтобы остановить поток должен иметь AtomicBoolean (или volatile boolean) и сделать что-то вроде:

AtomicBoolean running = new AtomicBoolean(true); 
while (running.set()) { 
    ... 
} 

... 
// then in the other thread (like the main thread) you stop the thread by: 
runner.set(false); 

Вы получаете IllegalStateMonitorException, потому что вы звоните wait, не находясь внутри блока для объекта, которого вы ждете. Вам нужно сделать что-то вроде:

Thread t = working.get(actualRow); 
synchronized (t) { 
    t.wait(); 
} 

Хотя я не уверен, что это то, что вы хотите. Может быть, вы хотите присоединиться к теме, которая ждет ее завершения?

working.get(actualRow).join(); 

Answer 2

IllegalStateMonitorException потому, что поток может ждать только в объекте он это принадлежит "(я не помню, если это правильный термин) его.

Сначала вам необходимо выполнить синхронизацию по одному и тому же объекту, чтобы гарантировать, что на этом объекте уже никто не ждет.

synchronize (working.get(actualRow)) { 
    working.get(actualRow).wait(); 
}