java线程启动暂停停止的简单示例

  今天为测试之前写的socket处理程序，就动手写了个测试页面，用于控制线程运行，暂停和停止，不多说了，上代码先。

import java.io.IOException;
import java.util.Date;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.apache.log4j.Logger;

/**
 * Servlet implementation class PressureServletTest
 */
public class PressureServletTest extends HttpServlet {
	private static final long serialVersionUID = 1L;
   
	private int threadNumber = 10;
	private volatile int timeInterval = 25;
	private volatile boolean run = false;
	private volatile boolean cancelled = false;
	private ThreadGroup group = new ThreadGroup("压力测试线程组");
   
    public PressureServletTest() {
        super();
        
        int i = 0; 
        while(i < threadNumber){
        	new TestThread(group, "压力测试线程_" + i++).start();
        }
    }

	protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		doPost(request, response);
	}

	/**
	 * @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse response)
	 */
	protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		String interval = request.getParameter("interval");
		String command = request.getParameter("command");
		if(request.getParameter("cancelled") != null){
			cancelled = true;
			group.interrupt();
		}else{
			if(interval != null){
				timeInterval = Integer.parseInt(interval);
			}
			
			if("S".equals(command)){
				if(run){
					run = false;
					group.interrupt();
				}
			}else if("R".equals(command)){
				if(!run){
					run = true;
					group.interrupt();
				}
			}
		}
		request.setAttribute("status", cancelled ? "停止" : run ? "运行" : "暂停");
		request.setAttribute("num", threadNumber);
		request.getRequestDispatcher("/admin_artifact_Pressuretest.jsp").forward(request, response);
	}
	
	private class TestThread extends Thread{
		
		private Logger log = Logger.getLogger(TestThread.class);
		
		private String login_detect_issuer = UssdConfigure.getInstance().getProperty(ConfigureField.LOGIN_ISSUER);
		
		private int maxWaitTime = UssdConfigure.getInstance().getIntProperty(ConfigureField.INT_MAX_FUTURE_TIMEOUT);

		@Override
		public void interrupt() {
			super.interrupt();
		}
		
		

		public TestThread(ThreadGroup group, String name) {
			super(group, name);
		}



		@Override
		public void run() {
			while(!cancelled){
				
				if(!run){
					try {
						synchronized (this) {
							this.wait();
						}
					} catch (InterruptedException e) {
						log.info("准备执行....");
					}
					continue;
				}
				
				//测试查询
				String id = RxMD5.getInstance().getString();//本次请求的查询Id
				String artifact = RxMD5.getInstance().getString();
				SoapSamlRequest samlrequest = new SoapSamlRequest(id, new Date(), login_detect_issuer);
				samlrequest.setArtifact(artifact);
				
				FutureData future = QueryIdentificationThread.getInstance().request(samlrequest);
				SoapSamlResponse userInfo = future.getResponse(maxWaitTime);
				
				if(userInfo == null){
					log.info("id:" + id +", 请求获取超时或出错！");
				}else{
					log.info("id:" + id +", 查询获取结果:" + userInfo.getStatusCode());
				}
				
				try {
					Thread.sleep(timeInterval);
				} catch (InterruptedException e) {
					log.info("请求发生暂停间隔中断....");
				}
				
				
			}
		}
		
	}

}

控制页面效果，这个没啥的，根据servlet的参数给几个按钮就行了。