ScheduledExecutorService 不显示变量的变化

Question

我一直在尝试在我的 java servlet 中执行延迟 1 秒的代码。如果跟踪打开或关闭，我需要检查条件。如果它关闭，那么它会转到 else 并关闭调度程序。代码如下。

protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
    // TODO Auto-generated method stub

    Map m=request.getParameterMap();
    Set s = m.entrySet();
    Iterator it = s.iterator();
    int index=0;

        while(it.hasNext()){

            Map.Entry<String,String[]> entry = (Map.Entry<String,String[]>)it.next();

            String key             = entry.getKey();
            String[] value         = entry.getValue();

            System.out.println("Value is "+value[0].toString());
                     switch(key)
                     {
                     case "RegId": 
                         RegId=value[0].toString();
                         break;
                     case "isTrackingRequested": 
                         isTrackingRequested=Boolean.valueOf(value[0]);
                         break;     
         }
     }
    boolean isTrackingRequestednew=isTrackingRequested;
    ScheduledExecutorService ses = Executors.newSingleThreadScheduledExecutor();

        ses.scheduleAtFixedRate(new Runnable() {
            @Override 
            public void run() { 

                // code to run 
                if(isTrackingRequestednew){
                    try {
                        System.out.println("===========================================================================");
                        System.out.println("new track status is "+isTrackingRequestednew);
                        System.out.println("===========================================================================");

                        }catch(Exception e)
                        {   

                        } 
                     }
                else
                {
                    ses.shutdown();

                }
            } 
        }, 0, 1, TimeUnit.SECONDS);
}

现在为了停止跟踪，我的应用程序将 isTrackingRequestednew 发送为“false”，现在这个值根本没有改变。我不知道为什么会这样。请帮帮我。

Answer 1

此代码无法编译，您无法访问内部类中的本地（非最终）变量。
每次发布请求时，您都会创建新的 ExecutorService，而不是每个会话或跟踪实体创建一次。我不知道这个线程的目的是什么，所以我会保存你奇怪的代码风格

private static class TrackingInfo {
    final private AtomicBoolean status;
    final private ScheduledExecutorService ses;

    TrackingInfo(boolean flagStatus) {
        this.status = new AtomicBoolean(flagStatus);
        this.ses = Executors.newSingleThreadScheduledExecutor();
        ses.scheduleAtFixedRate(new Runnable() {
            @Override
            public void run() {

                // code to run
                if (status.get()) {
                    try {
                        System.out.println("===========================================================================");
                        System.out.println("new track status is " + status.get());
                        System.out.println("===========================================================================");

                    } catch (Exception e) {

                }
                } else {
                    ses.shutdown();
                }
            }
        }, 0, 1, TimeUnit.SECONDS);
    }

    public void setStatus(boolean status) {
        this.status.set(status);
    }
}

使用request.getSession().getAttribute(...) / setAttribute() 将这个TrackingInfo 和worker 保存在其中，并通过TrackingInfo.setStatus(newStatus) 实例将标志更改传递给worker，或者您可以在控制器类中有一些Map 变量（不是方法局部变量）并存储跟踪ID 和TrackingInfo 与之关联。
恕我直言，如果您真正终止跟踪线程就像在发布的代码中一样简单

else {
    ses.shutdown();
}

你根本不需要TrackingInfo。只需存储（如上所述在会话或缓存中）对调度程序的引用，然后在您的 doPost 方法中收到带有 false 值的 isTrackingRequestednew，获取此调度程序并像这样关闭它

if (!isTrackingRequestednew) {
    ScheduledExecutorService scheduler = (ScheduledExecutorService) request.getSession().getAttribute("trackingScheduler");
    if (scheduler != null) {
        scheduler.shutdown();
    }
}

而不是"trackingScheduler"，您可以使用一些跟踪ID 作为标识符，并在每个请求中发送它。
请注意，您还必须清理由于某些网络错误或其他原因而未正确关闭的旧调度程序。