如何消费完后终止线程 java代码

在Java中，线程的终止通常是通过设置一个标志来实现的，线程在工作时会不断地检查这个标志，如果标志被设置为true，则线程终止。下面是一个示例代码，演示如何使用标志来终止线程：

class MyThread extends Thread {
    private volatile boolean isRunning = true;

    @Override
    public void run() {
        while (isRunning) {
            // 线程执行的代码
            // 如果任务完成，可以设置 isRunning = false 来终止线程
        }
    }

    public void shutdown() {
        isRunning = false;
    }
}

// 在主线程中启动子线程
MyThread myThread = new MyThread();
myThread.start();

// 当任务完成后，调用 shutdown() 方法终止线程
myThread.shutdown();

在上面的代码中，`MyThread` 类继承了 `Thread` 类，并定义了一个 `volatile` 类型的布尔变量 `isRunning`，用于标识线程是否应该继续运行。在 `run()` 方法中，线程会不断地检查 `isRunning` 变量，如果变量值为 `false`，则线程会终止。

在主线程中，我们可以通过调用 `shutdown()` 方法来设置 `isRunning` 变量为 `false`，从而终止线程的运行。