用异步线程来实现点击量

package com.meyacom.common.web.thread;

import com.meyacom.common.integration.dao.DAO;
import com.meyacom.common.web.util.Logger;

/**
 * @作者:朱湘鄂

 * @日期:20110325
 * @包:com.meyacom.jiangly.thread
 * @类:com.meyacom.jiangly.thread.AsyncThread
 * @说明:该类是多线程修改点击率的基类，调用此类实现修改点击率。
 */
public class AsyncThread implements Runnable {

 private DAO dao; // 注入dao
 private String sql; // 动态sql语句

 
 public String getSql() {
  return sql;
 }
 public void setSql(String sql) {
  this.sql = sql;
 }

 /**
  * @功能: 重写Thread接品的Run()方法，实现流程：
  *
  * @1. 调用dao的update方法
  *
  * @2. 修改点击率
  *
  * @throws Exception
  *             抛出数据访问异常
  */
 @SuppressWarnings("finally")
 public void run() {
  try {
   Logger.audit("进入->:修改点击率的类");
   Logger.audit("动态的sql语句->:" + sql);
   dao.update("dynamic.system.sql", sql);
  } catch (Exception e) {
   Logger.error("访问数据异常，修改点击率信息异常！" + e);
  } finally {
   Logger.audit("退出->:修改点击率的类");
   return;
  }
 }

 public DAO getDao() {
  return dao;
 }

 public void setDao(DAO dao) {
  this.dao = dao;
 }
}

 

package com.meyacom.common.web.thread;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

import com.meyacom.common.web.util.Logger;

/**
 * 作者:朱湘鄂
 *
 * @日期:20110328
 * @包:com.meyacom.jiangly.thread
 * @类:com.meyacom.jiangly.thread.AsyncThread
 * @说明:该类是线程池服务类
 */
public class ThreadPoolService {

 public static final int DEFAULT_POOL_SIZE = 5; // 默认线程池大小

 public static final long DEFAULT_TASK_TIMEOUT = 1000;// 默认一个任务的超时时间，单位为毫秒

 private int poolSize = DEFAULT_POOL_SIZE;

 private ExecutorService executorService;// 线程服务serivce

 private AsyncThread asyncThread; // 注入线程实例

 public AsyncThread getAsyncThread() {
  return asyncThread;
 }

 public void setAsyncThread(AsyncThread asyncThread) {
  this.asyncThread = asyncThread;
 }

 /**
  * 根据给定大小创建线程池
  */
 public ThreadPoolService(int poolSize) {
  setPoolSize(poolSize);
 }

 public ThreadPoolService() {
  setPoolSize(DEFAULT_POOL_SIZE);
 }

 /**
  * @功能: 启动线程池中的线程来执行任方法，实现流程：
  *
  * @param sql
  *            传入动态的sql语句
  *
  * @throws Exception
  *             线程执行异常
  */
 public void execute(String sql) {
  try {
   asyncThread.setSql(sql);
   executorService.execute(asyncThread);
  } catch (Exception e) {
   Logger.error("线程执行异常！" + e);
  }
 }

 /**
  * @功能: 关闭当前ExecutorService方法，实现流程：
  *
  * @param timeout
  *            以毫秒为单位的超时时间
  *
  * @throws InterruptedException
  *             抛出数据访问异常
  */
 public void destoryExecutorService(long timeout) {
  if (executorService != null && !executorService.isShutdown()) {
   try {
    executorService
      .awaitTermination(timeout, TimeUnit.MILLISECONDS);
   } catch (InterruptedException e) {
    Logger.error("关闭线程池异常！" + e);
   }
   executorService.shutdown();
  }
 }

 /**
  * @功能: 创建新的ExecutorService方法，实现流程：
  *
  *      关闭当前ExecutorService， 随后根据poolSize创建新的ExecutorService
  */
 public void createExecutorService() {
  destoryExecutorService(1000);
  executorService = Executors.newFixedThreadPool(poolSize);
 }

 /**
  * 调整线程池大小
  */
 public void setPoolSize(int poolSize) {
  this.poolSize = poolSize;
  createExecutorService();
 }

}