亚洲一区二区三区久久,国产二区一区,日韩精品免费一区二区夜夜嗨

java

線程池代碼

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();

   // 線程池最小線程數(shù)
   private final static int MIN_SIZE = 4;
    // 線程池最大線程數(shù)
   private final static int MAX_SIZE = 10;
    // 線程池維護(hù)線程允許的空閑限制
   private final static int KEEP_ACTIVE_TIME = 0;
    // 線程池用的緩沖隊(duì)列大小
   private final static int WORK_QUEUE_SIZE = 10;
   // 消息緩沖隊(duì)列
   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 執(zhí)行的任務(wù)的處理程序
   final RejectedExecutionHandler handler = new RejectedExecutionHandler()
   {

       public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
           // TODO Auto-generated method stub
           System.out.println(((AccessDBThread )r).getMsg()+"消息放入隊(duì)列中重新等待執(zhí)行");
           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);

   // 調(diào)度線程池

   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");
   }


}

測(cè)試類：
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) 評(píng)論(0) 編輯收藏

新用戶注冊(cè) 刷新評(píng)論列表


只有注冊(cè)用戶登錄后才能發(fā)表評(píng)論。




網(wǎng)站導(dǎo)航: 博客園 IT新聞 Chat2DB C++博客博問管理

<

2011年9月

>

日

一

二

三

四

五

六

28

29

30

31

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

1

2

3

4

5

6

7

8

導(dǎo)航

統(tǒng)計(jì)

隨筆 - 3
文章 - 0
評(píng)論 - 0
引用 - 0

常用鏈接

留言簿

隨筆檔案

2011年9月 (3)

線程池代碼

導(dǎo)航

統(tǒng)計(jì)

常用鏈接

留言簿

隨筆檔案

搜索

最新評(píng)論

閱讀排行榜

評(píng)論排行榜