線程池代碼

          ThreadPoolManager

          package com.threadpool.test;
          import java.util.LinkedList;
          import java.util.Queue;
          import java.util.concurrent.ArrayBlockingQueue;
          import java.util.concurrent.Executors;
          import java.util.concurrent.RejectedExecutionException;
          import java.util.concurrent.RejectedExecutionHandler;
          import java.util.concurrent.ScheduledExecutorService;
          import java.util.concurrent.ScheduledFuture;
          import java.util.concurrent.ThreadPoolExecutor;
          import java.util.concurrent.TimeUnit;

          import org.omg.CORBA.TIMEOUT;

          import com.nio.test.ReadFileThread;

          public class ThreadPoolManager {

              private static ThreadPoolManager tpm = new ThreadPoolManager();

              // 線程池最小線程數
              private final static int MIN_SIZE = 4;
              // 線程池最大線程數
              private final static int MAX_SIZE = 10;
              // 線程池維護線程允許的空閑限制
              private final static int KEEP_ACTIVE_TIME = 0;
              // 線程池用的緩沖隊列大小
              private final static int WORK_QUEUE_SIZE = 10;
              // 消息緩沖隊列
              Queue queue = new LinkedList();
              
              final Runnable accessBuffeThread = new Runnable()
              {

                  public void run() {
                      
                      if( hasMoreAcquire() ){
                          
                          String msg = ( String ) queue.poll();
                          Runnable task = new AccessDBThread( msg );
                          threadpool.execute( task );
                      }
                  }
                  
              };
              // 無法由 ThreadPoolExecutor 執行的任務的處理程序
              final RejectedExecutionHandler handler = new RejectedExecutionHandler()
              {

                  public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
                      // TODO Auto-generated method stub
                      System.out.println(((AccessDBThread )r).getMsg()+"消息放入隊列中重新等待執行");
                      queue.offer((( AccessDBThread ) r ).getMsg() );
                  }
                  
              };
              
              final ThreadPoolExecutor threadpool = new ThreadPoolExecutor(MIN_SIZE, MAX_SIZE, KEEP_ACTIVE_TIME, TimeUnit.SECONDS, new ArrayBlockingQueue(WORK_QUEUE_SIZE),this.handler);
              
              // 調度線程池

              final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool( 1 );

              final ScheduledFuture taskHandler = scheduler.scheduleAtFixedRate(accessBuffeThread, 0, 1, TimeUnit.SECONDS);
              
              public static ThreadPoolManager newinstance()
              {
                  return tpm;
              }
              
              private ThreadPoolManager (){}
              
              
              private boolean hasMoreAcquire()
              {
                  return !queue.isEmpty();
              }
              
              public void addLogMsg(String msg)
              {
               Runnable task = new AccessDBThread(msg);
               threadpool.execute(task);
              }
          }
          AccessDBThread
          package com.threadpool.test;

          public class AccessDBThread implements Runnable{

              private String msg;
              public String getMsg() {
                  return msg;
              }
              public void setMsg(String msg) {
                  this.msg = msg;
              }
              
              public AccessDBThread(){
                  super();
              }
              
              public AccessDBThread(String msg)
              {
                  this.msg=msg;
              }
              public void run() {
                  // TODO Auto-generated method stub
                  System.out.println("Added the message: "+msg+" into the Database");
              }

              
          }

          測試類:
          package com.threadpool.test;


          public class TestDriver {

              ThreadPoolManager tpm = ThreadPoolManager.newinstance();
              
              public void addMsg(String msg)
              {
                  tpm.addLogMsg(msg);
              }
              public static void main(String[] args) {
                  for(int i=0;i<100;i++)
                  {
                      new TestDriver().addMsg(Integer.toString(i));
                  }
              }
          }





          李陽

          posted on 2011-09-02 15:20 crazy-李陽 閱讀(422) 評論(0)  編輯  收藏


          只有注冊用戶登錄后才能發表評論。


          網站導航:
           
          <2011年9月>
          28293031123
          45678910
          11121314151617
          18192021222324
          2526272829301
          2345678

          導航

          統計

          常用鏈接

          留言簿

          隨筆檔案

          搜索

          最新評論

          閱讀排行榜

          評論排行榜

          主站蜘蛛池模板: 中西区| 象山县| 安西县| 攀枝花市| 嘉义市| 金华市| 西林县| 吴江市| 千阳县| 玉门市| 房山区| 新干县| 新昌县| 马鞍山市| 洛阳市| 余姚市| 巨野县| 进贤县| 新昌县| 友谊县| 朔州市| 高清| 绥江县| 稻城县| 和林格尔县| 鄱阳县| 出国| 遵义县| 嘉定区| 布尔津县| 马公市| 滨海县| 双流县| 襄汾县| 望城县| 长武县| 隆林| 武川县| 巴林左旗| 太仓市| 上饶市|