1

我希望能够从 Web 应用程序启动/暂停/退出后台进程。我希望该过程无限期地运行。

用户将访问网页。按下一个按钮来启动线程,它会一直运行,直到用户告诉它停止。

我正在尝试确定执行此操作的最佳工具。我看过像 Quartz 这样的东西,但我还没有看到任何关于像 Quartz 这样的东西是否适合无限线程的讨论。

我的第一个想法是做这样的事情。

public class Background implements Runnable{
    private running = true;

    run(){
         while(running){
              //processing 
        }
    }

    stop(){
        running = false;
    }
}

//Then to start
Background background = new Background();
new Thread(background).start();
getServletContext().setAttribute("background", background);

//Then to stop
background = getServletContext().getAttribute("background");
background.stop();

我要测试一下。但我很好奇是否有更好的方法来实现这一点。

4

1 回答 1

1

首先,所有Object放入 Context 的 s 都必须实现Serializable.

我不建议将Background对象放入上下文中,而是创建一个BackgroundController具有private boolean running = true;属性的类。getter 和 setter 应该是synchronised,以防止后台线程和 web 请求线程发生冲突。同样,private boolean stopped = false;应该将它们放在同一个类中。

我还进行了一些其他更改,您必须将循环核心分解为小单元(如 1 次迭代),以便可以在活动中间的某个位置停止进程。

代码如下所示:

public class BackgroundController implements Serializable {
    private boolean running = true;
    private boolean stopped = false;
    public synchronized boolean isRunning() { 
        return running; 
    }
    public synchronized void setRunning(boolean running) { 
        this.running = running; 
    }
    public synchronized boolean isStopped() { 
        return stopped; 
    }
    public synchronized void stop() { 
        this.stopped = true; 
    }
}
public class Background implements Runnable {
    private BackgroundController control;
    public Background(BackgroundController control) {
        this.control = control;
    }

    run(){
         while(!isStopped()){
              if (control.isRunning()) {
                   // do 1 step of processing, call control.stop() if finished
              } else {
                   sleep(100); 
              }
        }
    }

}

//Then to start
BackgroundController control = new BackgroundController();
Background background = new Background(control);
new Thread(background).start();
getServletContext().setAttribute("backgroundcontrol", control);

//Then to pause
control = getServletContext().getAttribute("backgroundcontrol");
control.setRunning(false);

//Then to restart
control = getServletContext().getAttribute("backgroundcontrol");
control.setRunning(true);

//Then to stop
control = getServletContext().getAttribute("backgroundcontrol");
control.stop();
于 2013-02-03T00:16:59.313 回答