如何通过另一个Servlet修改布尔值以终止循环？

核心问题是Servlet中创建的LoopClass实例和运行for循环的实例不是同一个对象，导致你修改的是新实例的布尔值，循环所在的实例完全没收到变化，所以toInterrupt[0]始终为false。此外还存在多线程可见性问题，需要保证布尔值的修改能被循环线程及时感知。

解决步骤 #

1. 共享LoopClass实例 #

不能在Servlet中每次请求都新建LoopClass对象，必须让循环线程和Servlet操作同一个实例。常用的共享方式：

• 存入ServletContext（全局上下文，适合整个应用唯一的循环）
• 存入HttpSession（适合每个用户独立的循环）
• 使用单例模式（注意线程安全）

2. 保证多线程可见性 #

多线程环境下，普通布尔值的修改可能无法被其他线程及时看到，推荐两种方式：

• 用volatile修饰数组（或布尔变量）
• 使用AtomicBoolean（java.util.concurrent.atomic包下，线程安全且无需额外同步）

修改后的代码示例 #

方式一：使用volatile数组

public class LoopClass {
    // 初始化数组时指定长度，原代码此处有语法错误
    private volatile boolean[] toInterrupt = new boolean[1];

    public boolean getValue() {
        return toInterrupt[0];
    }

    public void setValue(boolean newValue) {
        toInterrupt[0] = newValue;
    }
}

方式二：使用AtomicBoolean（更推荐）

import java.util.concurrent.atomic.AtomicBoolean;

public class LoopClass {
    private AtomicBoolean toInterrupt = new AtomicBoolean(false);

    public boolean getValue() {
        return toInterrupt.get();
    }

    public void setValue(boolean newValue) {
        toInterrupt.set(newValue);
    }
}

共享实例并启动循环（用ServletContextListener）

import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;

public class LoopInitListener implements ServletContextListener {
    @Override
    public void contextInitialized(ServletContextEvent sce) {
        LoopClass loopInstance = new LoopClass();
        // 将实例存入全局上下文
        sce.getServletContext().setAttribute("loopInstance", loopInstance);

        // 启动循环线程
        new Thread(() -> {
            // 模拟你的for循环逻辑
            for (int i = 0; ; i++) {
                if (loopInstance.getValue()) {
                    System.out.println("循环已中断");
                    break;
                }
                // 循环执行的业务逻辑
                try {
                    Thread.sleep(500);
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                    break;
                }
            }
        }).start();
    }
}

修改后的Servlet代码

import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;

public class InterruptServlet extends HttpServlet { // 修正原代码拼写错误extends
    @Override
    protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws IOException {
        // 从全局上下文获取共享的LoopClass实例
        LoopClass loopInstance = (LoopClass) getServletContext().getAttribute("loopInstance");
        
        if (loopInstance != null) {
            loopInstance.setValue(true);
            resp.getWriter().write("循环中断指令已发送");
        } else {
            resp.getWriter().write("未找到运行中的循环实例");
        }
    }
}

原代码中的语法错误修正 #

• LoopClass中数组初始化：new boolean[]; → new boolean[1];
• Servlet类继承：exetnds → extends
• Servlet变量声明：LoopClass = lp = new LoopClass(); → LoopClass lp = new LoopClass();
• 循环中的break：break: → break;

内容的提问来源于stack exchange，提问作者Stephan