Java停止从类中运行的所有线程

Question

我需要做的是能够停止从一个实现runnable的线程类运行的所有线程。这就是我的意思:这里是我的“线程”类的开始:

public class HTTP extends Thread
{   
    int threadNumber;
    String host;
    int port;
    int timeLeft;
    private BufferedReader LocalBufferedReader;

    public HTTP(int threadNumber, String host, int port, int timeLeft)
    {
        this.threadNumber = threadNumber;
        this.host= host;
        this.port = port;
        this.timeLeft = (timeLeft * 1000);
    }

  public void run()
  {

这就是我如何创建多个线程来执行此操作：

 for (int n = 1; n <= m; n++) {
      new HTTP(n + 1, str, j, k).start();
    }

m是要创建的线程数。这可能是从50到1000的任何地方。现在我需要做的是突然立刻停止所有的动作。我该怎么做呢？

Answer 1

首先，启动1000个线程实际上是没有意义的，因为很少有线程会被调度为实际并发运行。

其次，你不能“停止”线程。你所能做的就是通过合作代码很好地要求他们停止。

执行所需操作的最简单方法是关闭 JVM。

Answer 2

在Java中停止线程是一个通过中断实现的协作过程。您可以存储线程并逐个中断它们：

List<Thread> threads = new ArrayList<> ();

for (int n = 1; n <= m; n++) {
  Thread t = new HTTP(n + 1, str, j, k);
  threads.add(t);
  t.start();
}

//later on

for (Thread t : threads) {
    t.interrupt();
}

然而，有几件事值得注意：

< li >只有当您的< code>run方法通过停止正在执行的操作来对中断做出反应时，这才会起作用 < li >使用线程池可以更容易地完成同样的事情，例如，使用由Executors类提供的各种工厂方法返回的ExecutorService之一。他们确实会为你处理线程的生命周期。

Answer 3

首先存储所有线程：

ArrayList<Thread> threads = new ArrayList<Thread>();
for (int n = 1; n <= m; n++) {
    Thread t = new HTTP(n + 1, str, j, k);
    threads.add(t);
    t.start();
 }

现在，对于stop方法，只需循环所有线程并对其调用中断：

for(Thread thread : threads)
{
    thread.interrupt();
}

确保在HTTP线程中检查isIntruppted（）。所以你会这样做：

public class InterruptTest {

    static class TThread extends Thread {
        public void run() {
            while(!isInterrupted()) {
                System.out.println("Do Work!!!");
                try {
                    sleep(1000);
                } catch (InterruptedException e) {
                    return;
                }
            }
        }
    }

    public static void main(String[] args) throws InterruptedException {
        Thread t = new TThread();
        t.start();

        Thread.sleep(4000);
        System.out.println("Sending interrupt!!");
        t.interrupt();
        Thread.sleep(4000);
    }

}