停止/取消 SwingWorker 线程？

Question

我试图找出如何在按下按钮时停止 SwingWorker 线程的运行。我一直在环顾四周，但在解决如何做到这一点时遇到了一些麻烦。目前，这就是我所拥有的：

new MySwingWorkerClass(args).execute();

然后我正在创建一个按钮，我想用它来停止线程：

button = new JButton("Stop");
button.addActionListener(new ActionListener() {
        public void actionPerformed(ActionEvent e) 
        {
        // Stop the swing worker thread
        }
});

我已经环顾四周寻找答案，到目前为止我已经设法找到了取消方法。但我不明白如何用它来阻止我的摇摆工人。我尝试了以下方法，但没有成功：

SwingWorker.cancel(true);

Answer 1

您需要保留对您的 SwingWorker 的引用，然后使用该引用来取消工作线程。

MySwingWorker myWorker = new MySwingWorkerClass(args).execute();

button.addActionListener(new ActionListener() {
    public void actionPerformed(ActionEvent e) 
    {
        // Stop the swing worker thread
        myWorker.cancel(true);
    }
});

这是一个完整的示例：

public class WorkerDemo extends JFrame {
    private boolean isStarted = false;
    private JLabel counterLabel = new JLabel("Not started");
    private Worker worker = new Worker();
    private JButton startButton = new JButton(new AbstractAction("Start") {

        @Override
        public void actionPerformed(ActionEvent arg0) {
            if(!isStarted) { 
                worker.execute();
                isStarted = false;
            }
        }

    });
    private JButton stopButton = new JButton(new AbstractAction("Stop") {

        @Override
        public void actionPerformed(ActionEvent arg0) {
            worker.cancel(true);
        }

    });

    public WorkerDemo() {

        add(startButton, BorderLayout.WEST);
        add(counterLabel, BorderLayout.CENTER);
        add(stopButton, BorderLayout.EAST);
        pack();
        setDefaultCloseOperation(EXIT_ON_CLOSE);
        setVisible(true);
    }

    class Worker extends SwingWorker<Void, Integer> {

        int counter = 0;

        @Override
        protected Void doInBackground() throws Exception {
            while(true) {
                counter++;
                publish(counter);
                Thread.sleep(60);
            }
        }

        @Override
        protected void process(List<Integer> chunk) {

            // get last result
            Integer counterChunk = chunk.get(chunk.size()-1);

            counterLabel.setText(counterChunk.toString());
        }

    }

    public static void main(String[] args) {
        SwingUtilities.invokeLater(new Runnable() {

            @Override
            public void run() {
                new WorkerDemo();
            }

        });
    }

}

Answer 2

您需要定期检查其已取消标志（即 isCancelled())。 SwingWorker 离开如何处理中断由你决定。

有关详细信息，请参阅取消后台任务。

Answer 3

您可以尝试覆盖done()方法并将其放入try catch中并捕获java.util.concurrent.CancellationException。类似的东西

。
。
。

@Overide
done() {
   try {
     get();
   } catch (CancellationException e) {
       // Do your task after cancellation
   }
}

。
。
。

Answer 4

我认为每次停止后都必须重新启动计数器。

对于 startButton，您必须重新启动工作程序，如

private JButton startButton = new JButton(new AbstractAction("Start") {

        @Override
        public void actionPerformed(ActionEvent arg0) {
            if(!isStarted) { 
                worker = new Worker();     // New line
                worker.execute();
                isStarted = false;
            }
        }
    });

使用

worker.setStopFlag(); // in stopButton actionPerformed block.

要停止您可以在 Worker 类中
私有布尔stopFlag = false;

添加

if( stopFlag)
break;

并在 Thread.sleep(60); 之后
最后将 stopFlag 的 setter 放在 Worker 类的末尾，顺便说

void setStopFlag(){
    stopFlag = true;
}

一下，如果你想要异常退出，你可以使用 cancel(true) 。