public class Test extends HttpServlet {
private static final long serialVersionUID = 1L;
protected void doGet(final HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
ScheduledExecutorService ses = Executors.newSingleThreadScheduledExecutor();
T t = new T(req);
ses.scheduleAtFixedRate(t, 0, 5000, TimeUnit.MILLISECONDS);
}
}
public class T implements Runnable {
public HttpServletRequest req;
public T(HttpServletRequest req){
this.req = req;
System.out.println(req.getSession()+"---------------");
}
public void run() {
System.out.println(req.getSession()+"---------------");
try {
Connection conn = JdbcUtil.open();
conn.setAutoCommit(false);
} catch (SQLException e) {
e.printStackTrace();
}
System.out.println(req.getSession()+"==============");
}
}