简单的回答是: 你可以用以下两种方法之一在内部停止线程:

run方法命中返回子例程。 运行方法完成，并隐式返回。

你也可以从外部停止线程:

电话系统。退出(这会终止整个进程) 调用线程对象的interrupt()方法* 看看线程是否有一个听起来可行的方法(如kill()或stop())

*:期望是这应该停止一个线程。然而，当这种情况发生时，线程实际做什么完全取决于开发人员在创建线程实现时编写的内容。

你在run方法实现中看到的一个常见模式是while(boolean){}，其中布尔值通常是名为isRunning的东西，它是其线程类的成员变量，它是volatile的，通常由其他线程通过sort setter方法访问，例如kill() {isRunnable=false;}。这些子例程很好，因为它们允许线程在终止之前释放它所持有的任何资源。

在IndexProcessor类中，您需要一种方法来设置一个标志，该标志通知线程它将需要终止，类似于您在类作用域中使用的变量run。

当您希望停止线程时，您可以设置这个标志并在线程上调用join()并等待它完成。

通过使用volatile变量或使用getter和setter方法来确保该标志是线程安全的，这些方法与用作标志的变量同步。

public class IndexProcessor implements Runnable {

    private static final Logger LOGGER = LoggerFactory.getLogger(IndexProcessor.class);
    private volatile boolean running = true;

    public void terminate() {
        running = false;
    }

    @Override
    public void run() {
        while (running) {
            try {
                LOGGER.debug("Sleeping...");
                Thread.sleep((long) 15000);

                LOGGER.debug("Processing");
            } catch (InterruptedException e) {
                LOGGER.error("Exception", e);
                running = false;
            }
        }

    }
}

然后在SearchEngineContextListener中:

public class SearchEngineContextListener implements ServletContextListener {

    private static final Logger LOGGER = LoggerFactory.getLogger(SearchEngineContextListener.class);

    private Thread thread = null;
    private IndexProcessor runnable = null;

    @Override
    public void contextInitialized(ServletContextEvent event) {
        runnable = new IndexProcessor();
        thread = new Thread(runnable);
        LOGGER.debug("Starting thread: " + thread);
        thread.start();
        LOGGER.debug("Background process successfully started.");
    }

    @Override
    public void contextDestroyed(ServletContextEvent event) {
        LOGGER.debug("Stopping thread: " + thread);
        if (thread != null) {
            runnable.terminate();
            thread.join();
            LOGGER.debug("Thread successfully stopped.");
        }
    }
}

您应该始终通过检查run()循环中的标志(如果有的话)来结束线程。

你的线程应该是这样的:

public class IndexProcessor implements Runnable {

    private static final Logger LOGGER = LoggerFactory.getLogger(IndexProcessor.class);
    private volatile boolean execute;

    @Override
    public void run() {
        this.execute = true;
        while (this.execute) {
            try {
                LOGGER.debug("Sleeping...");
                Thread.sleep((long) 15000);

                LOGGER.debug("Processing");
            } catch (InterruptedException e) {
                LOGGER.error("Exception", e);
                this.execute = false;
            }
        }
    }

    public void stopExecuting() {
        this.execute = false;
    }
}

然后你可以通过调用thread. stopexecution()结束线程。这样线程就干净地结束了，但这需要15秒(因为你在睡觉)。 如果确实非常紧急，您仍然可以调用thread.interrupt() -但首选方法应该始终是检查标志。

为了避免等待15秒，你可以像这样分割睡眠:

        ...
        try {
            LOGGER.debug("Sleeping...");
            for (int i = 0; (i < 150) && this.execute; i++) {
                Thread.sleep((long) 100);
            }

            LOGGER.debug("Processing");
        } catch (InterruptedException e) {
        ...

一些补充信息。 Java文档中都建议使用标志和中断。

https://docs.oracle.com/javase/8/docs/technotes/guides/concurrency/threadPrimitiveDeprecation.html

private volatile Thread blinker;

public void stop() {
    blinker = null;
}

public void run() {
    Thread thisThread = Thread.currentThread();
    while (blinker == thisThread) {
        try {
            Thread.sleep(interval);
        } catch (InterruptedException e){
        }
        repaint();
    }
}

对于需要长时间等待的线程(例如，等待输入)，使用thread .interrupt

public void stop() {
     Thread moribund = waiter;
      waiter = null;
      moribund.interrupt();
 }

通常，线程在被中断时被终止。那么，为什么不使用本机布尔值呢?尝试isInterrupted ():

Thread t = new Thread(new Runnable(){
        @Override
        public void run() {
            while(!Thread.currentThread().isInterrupted()){
                // do stuff         
            }   
        }});
    t.start();

    // Sleep a second, and then interrupt
    try {
        Thread.sleep(1000);
    } catch (InterruptedException e) {}
    t.interrupt();

我如何杀死一个线程?不使用stop();

Brian Goetz在他的书中建议使用Thread.currentThread(). isinterrupted()标志和interrupt()方法来取消。

阻塞库方法(如sleep()和wait())尝试检测线程何时被中断并提前返回。它们通过清除中断状态并抛出InterruptedException来响应中断，这表明阻塞操作由于中断而提前完成。

JVM不保证阻塞方法检测中断的速度有多快，但在实践中，检测中断的速度相当快。

class PrimeProducer extends Thread {
    private final BlockingQueue<BigInteger> queue;

    PrimeProducer(BlockingQueue<BigInteger> queue) {
        this.queue = queue;
    }

    public void run() {
        try {
            BigInteger p = BigInteger.ONE;
            while (!Thread.currentThread().isInterrupted()) {
                queue.put(p = p.nextProbablePrime()); // blocking operation
            }
        } catch (InterruptedException consumed) {
            // allow thread to exit
        }
        // any code here will still be executed
    }

    public void cancel() {
        interrupt();
    }
}

如果您将任何代码放在catch块之后，当我们吞咽InterruptedException以优雅地退出run()时，它仍然会被执行。

简单介绍一下interrupt()的工作原理。

如果在非阻塞的线程上调用interrupt，则interrupt()不会在run()内部引起InterruptedException，而只是将isInterrupted标志更改为true，线程将继续工作，直到到达thread . currentthread ().isInterrupted()检查并退出run()。

如果在阻塞的线程上调用interrupt (sleep()或wait()被调用，在我们的例子中，它是put()可能阻塞线程)，那么isInterrupted将被设置为false，并且在put()中抛出InterruptedException。