java动态控制线程的启动和停止
2016-02-23 18:08
337 查看
最近项目有这样的需求:原来系统有个计算的功能,但该功能执行时间会很长(大概需要几个小时才能完成),如果执行过程中出现了错误的话,也只能默默的等待错误执行完成才行,无法做到动态的对该功能进行停止。
我了解到项目需求后,写了如下的小例子:
package com.iamzken.test;
import java.io.IOException;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
public class Test extends HttpServlet {
//该线程代表执行任务的线程
private volatile Thread t ;
@Override
protected void doGet(HttpServletRequest req, HttpServletResponse resp)
throws ServletException, IOException {
doPost(req, resp);
}
@Override
protected void doPost(final HttpServletRequest req, final HttpServletResponse resp)
throws ServletException, IOException {
//开关参数switch,值为on代表要启动线程t执行相应的任务,值为off代表要停止正在执行任务的线程t
String s = req.getParameter("switch");
if("off".equals(s)){
t.stop();
}else if("on".equals(s)){
t = new Thread(new Runnable() {
//run的方法体代表要执行的任务
@Override
public void run() {
req.setAttribute("name", req.getParameter("flag"));
int i = 0;
while(i < 10000000){
System.out.println(++i);
}
}
});
//启动线程
t.start();
}
try {
//代表线程t执行完之后主线程才能继续
t.join();
System.out.println(req);
req.getRequestDispatcher("/my001.jsp").forward(req, resp);
} catch (Exception e) {
e.printStackTrace();
}
}
}
以上是主要的servlet代码:
访问路径为:http://localhost:8080/web001/test.do?flag=xxyyzz&switch=off
其中switch开关参数取值有两种:on和off,on表示执行线程对应的任务,off表示中断线程正在执行的任务。
最后附上完整的项目源码。
web001.rar
我了解到项目需求后,写了如下的小例子:
package com.iamzken.test;
import java.io.IOException;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
public class Test extends HttpServlet {
//该线程代表执行任务的线程
private volatile Thread t ;
@Override
protected void doGet(HttpServletRequest req, HttpServletResponse resp)
throws ServletException, IOException {
doPost(req, resp);
}
@Override
protected void doPost(final HttpServletRequest req, final HttpServletResponse resp)
throws ServletException, IOException {
//开关参数switch,值为on代表要启动线程t执行相应的任务,值为off代表要停止正在执行任务的线程t
String s = req.getParameter("switch");
if("off".equals(s)){
t.stop();
}else if("on".equals(s)){
t = new Thread(new Runnable() {
//run的方法体代表要执行的任务
@Override
public void run() {
req.setAttribute("name", req.getParameter("flag"));
int i = 0;
while(i < 10000000){
System.out.println(++i);
}
}
});
//启动线程
t.start();
}
try {
//代表线程t执行完之后主线程才能继续
t.join();
System.out.println(req);
req.getRequestDispatcher("/my001.jsp").forward(req, resp);
} catch (Exception e) {
e.printStackTrace();
}
}
}
以上是主要的servlet代码:
访问路径为:http://localhost:8080/web001/test.do?flag=xxyyzz&switch=off
其中switch开关参数取值有两种:on和off,on表示执行线程对应的任务,off表示中断线程正在执行的任务。
最后附上完整的项目源码。
web001.rar
相关文章推荐
- 基于Spring + Spring MVC + Mybatis + shiro 高性能web构建
- java序列化和json序列化效率对比
- java 嵌套遍历文件夹里面的文件和文件夹
- SpringMVC传值
- Promise模式简介(Future) --- Java实现异步
- Java线程
- Java定时执行任务
- java学习笔记-代码块
- Java中 Map、Set、List
- maven 常用命令 mvn 发布可执行jar包
- Java Reflection(十二):动态类加载与重载
- java基本语法
- Java解析JSON
- Java Reflection(十一):动态代理
- Java 回顾笔记6(晚上)
- Java Reflection(十):数组
- Eclipse开启内存监视窗口
- Java并发同步工具类之CountDownLatch
- Java Reflection(九):泛型
- Java Reflection(八):注解