java - 如何使用 ExecutorService 重新启动之前在 Swing 应用程序中终止的线程

Question

我正在创建一个 Swing 应用程序。它包含一个JFrame，在JFrame内部，我添加了一个JButton来启动和停止一些任务。我使用相同的 JButton 来启动和停止由 ExecutorService 执行的线程任务。

单击“开始”按钮时，将执行线程，并且按钮标签将更改为“停止”，而单击“停止”按钮将停止所有线程(我已使用 ExecutorService shutdownNow() 方法完成此操作)和按钮标签将再次更改为开始，但应用程序不会关闭。 现在，如果我再次单击“开始”按钮，应用程序就会挂起，线程不会从头开始重新启动。

import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JPanel;

public class MultipleThreads {
    public static ExecutorService executor = Executors.newFixedThreadPool(4);

    public static void main(String[] args) {
        JFrame frame = new JFrame("Stop Thread");
        frame.setSize(200,200);
        frame.setLocationRelativeTo(null);
        frame.setLayout(null);
        JPanel panel = new JPanel();
        panel.setBounds(5,5,150,150);
        panel.setLayout(null);
        JButton btn = new JButton("Start");
        btn.setBounds(10,10,80,25);

        btn.addActionListener(new ActionListener() {
            @Override
            public void actionPerformed(ActionEvent ae) {
                if (btn.getText().equals("Start")) {
                    btn.setText("Stop");
                    MultipleThreads2 runThreads = new MultipleThreads2();
                    runThreads.runThreadMethod();
                } else if (btn.getText().equals("Stop")) {
                    try {
                        if (!executor.awaitTermination(800, TimeUnit.MILLISECONDS)) {
                            executor.shutdownNow();
                        } 
                    } catch (InterruptedException e) {
                        executor.shutdownNow();
                    }

                    btn.setText("Start");
                }
            }
        });
        panel.add(btn);
        frame.add(panel);
        frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
        frame.setVisible(true);
    }
}

class MultipleThreads2 {
    public volatile boolean flag = true;

    public void stopRunning() {
        flag = false;
    }

    public MultipleThreads2() {
        while (flag) {
            try {
                MultipleThreads.executor.submit(t1);
                MultipleThreads.executor.submit(t2);
                flag = false;
                System.out.println(t1.isAlive());
            } catch (Exception e) {

            }
        }
    }

    public void runThreadMethod() {
        flag = true;
        while (flag) {
            try {
                MultipleThreads.executor.submit(t3);
                MultipleThreads.executor.submit(t4);
                    flag = false;
            } catch (Exception e) {

            }
        }
    }

    Thread t1 = new Thread(new Runnable() {
        @Override
        public void run() {
            try {
                for (int i = 0; i < 10; i++) {
                    System.out.println("From t1 Thread");
                    Thread.sleep(1000);
                }
            } catch (Exception e) {

            }
        }
    });

    Thread t2 = new Thread(new Runnable() {
        @Override
        public void run() {
            try {
                for (int i = 0; i < 10; i++) {
                    System.out.println("From t2 Thread");
                    Thread.sleep(500);
                }
            } catch (Exception e) {

            }
        }
    });

    Thread t3 = new Thread(new Runnable() {
        @Override
        public void run() {
            try {
                for (int i = 0; i < 10; i++) {
                    System.out.println("From t3 Thread");
                    Thread.sleep(500);
                }
            } catch (Exception e) {

            }
        }
    });

    Thread t4 = new Thread(new Runnable() {
        @Override
        public void run() {
            try {
                for (int i = 0; i < 10; i++) {
                    System.out.println("From t4 Thread");
                    Thread.sleep(500);
                }
            } catch (Exception e) {

            }
        }
    });
}

预期:第二次单击“开始”按钮时应从头开始重新启动所有线程。

Answer 1

这里:

public static ExecutorService executor = Executors.newFixedThreadPool(4);

您将创建该线程池一次。稍后，您会打电话

executor.shutdownNow();

换句话说:你正在启动你的车，在某个时刻，你停下车，下车，然后点燃它。然后你问自己:“好吧，我怎样才能用那辆车开车回家？”。好吧，你不能。你刚刚把它点燃了。

同样的事情:当您关闭服务时，它就会消失。

长话短说，一个简单(不一定理想)的解决方案是:

public static ExecutorService executor = null;

及以后:

if (executor == null) 
  executor = Executors.newFixedThreadPool(4);

和

executor.shutdownNow();
executor = null;

换句话说:你开着你的车开车，你把它放火了，然后你买了一辆新车，再开车，然后再把它放火。

当然，设置为 null 并检查它的方法可能会导致各种问题。这样做会更好一点:

  executor.shutdownNow();
  executor = Executors.newFixedThreadPool(4);

含义:您只需在“最后一个”被告知关闭后立即创建一个新实例，而不是将执行器保留为空。因此，从理论上讲，每当执行器用于提交任务或关闭时，您都在与当前“有效”的实例进行通信。