国产午夜亚洲精品,看亚洲a级一级毛片,久久久久亚洲精品天堂

[置頂]線程池代碼

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

   };
   // 無(wú)法由 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è)試類(lèi)：
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 @ 2011-09-02 15:20 crazy-李陽(yáng) 閱讀(422) | 評(píng)論 (0) | 編輯收藏

ibatis分頁(yè)<一>

package com.lxy.dialect;

public abstract interface Dialect {

public boolean supportLimit();

public String getLimitString(String sql,boolean hasoffset);

public String getLimitString(String sql,int offset,int limit);

}

package com.lxy.dialect;

public class MyDialect implements Dialect {

protected static final String SQL_END_DELIMITER = ";";

public String getLimitString(String sql, boolean hasoffset) {

return new StringBuffer(sql.length() + 20).append(trim(sql)).append(

hasoffset ? "limit ?,?" : "limit ?").append(SQL_END_DELIMITER)

.toString();

}

public String getLimitString(String sql, int offset, int limit) {

sql = trim(sql);

StringBuffer sb = new StringBuffer(sql.length() + 20);

sb.append(sql);

if (offset > 0) {

sb.append("limit").append(offset).append(',').append(limit).append(

";");

} else {

sb.append("limit").append(limit).append(";");

}

return sb.toString();

}

public boolean supportLimit() {

return true;

}

private String trim(String sql) {

sql = sql.trim();

if (sql.endsWith(";")) {

sql = sql.substring(0, sql.length() - 1 - ";".length());

}

return sql;

}

posted @ 2011-09-14 19:11 crazy-李陽(yáng) 閱讀(215) | 評(píng)論 (0) | 編輯收藏

線程池代碼

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

   };
   // 無(wú)法由 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è)試類(lèi)：
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 @ 2011-09-02 15:20 crazy-李陽(yáng) 閱讀(422) | 評(píng)論 (0) | 編輯收藏

線程池

為什么要用線程池？

諸如 Web 服務(wù)器、數(shù)據(jù)庫(kù)服務(wù)器、文件服務(wù)器或郵件服務(wù)器之類(lèi)的許多服務(wù)器應(yīng)用程序都面向處理來(lái)自某些遠(yuǎn)程來(lái)源的大量短小的任務(wù)。請(qǐng)求以某種方式到達(dá)服務(wù)器，這種方式可能是通過(guò)網(wǎng)絡(luò)協(xié)議（例如 HTTP、FTP 或 POP）、通過(guò) JMS 隊(duì)列或者可能通過(guò)輪詢數(shù)據(jù)庫(kù)。不管請(qǐng)求如何到達(dá)，服務(wù)器應(yīng)用程序中經(jīng)常出現(xiàn)的情況是：?jiǎn)蝹€(gè)任務(wù)處理的時(shí)間很短而請(qǐng)求的數(shù)目卻是巨大的。

構(gòu)建服務(wù)器應(yīng)用程序的一個(gè)過(guò)于簡(jiǎn)單的模型應(yīng)該是：每當(dāng)一個(gè)請(qǐng)求到達(dá)就創(chuàng)建一個(gè)新線程，然后在新線程中為請(qǐng)求服務(wù)。實(shí)際上，對(duì)于原型開(kāi)發(fā)這種方法工作得很好，但如果試圖部署以這種方式運(yùn)行的服務(wù)器應(yīng)用程序，那么這種方法的嚴(yán)重不足就很明顯。每個(gè)請(qǐng)求對(duì)應(yīng)一個(gè)線程（thread-per-request）方法的不足之一是：為每個(gè)請(qǐng)求創(chuàng)建一個(gè)新線程的開(kāi)銷(xiāo)很大；為每個(gè)請(qǐng)求創(chuàng)建新線程的服務(wù)器在創(chuàng)建和銷(xiāo)毀線程上花費(fèi)的時(shí)間和消耗的系統(tǒng)資源要比花在處理實(shí)際的用戶請(qǐng)求的時(shí)間和資源更多。

除了創(chuàng)建和銷(xiāo)毀線程的開(kāi)銷(xiāo)之外，活動(dòng)的線程也消耗系統(tǒng)資源。在一個(gè) JVM 里創(chuàng)建太多的線程可能會(huì)導(dǎo)致系統(tǒng)由于過(guò)度消耗內(nèi)存而用完內(nèi)存或“切換過(guò)度”。為了防止資源不足，服務(wù)器應(yīng)用程序需要一些辦法來(lái)限制任何給定時(shí)刻處理的請(qǐng)求數(shù)目。

線程池為線程生命周期開(kāi)銷(xiāo)問(wèn)題和資源不足問(wèn)題提供了解決方案。通過(guò)對(duì)多個(gè)任務(wù)重用線程，線程創(chuàng)建的開(kāi)銷(xiāo)被分?jǐn)偟搅硕鄠€(gè)任務(wù)上。其好處是，因?yàn)樵谡?qǐng)求到達(dá)時(shí) 線程已經(jīng)存在，所以無(wú)意中也消除了線程創(chuàng)建所帶來(lái)的延遲。這樣，就可以立即為請(qǐng)求服務(wù)，使應(yīng)用程序響應(yīng)更快。而且，通過(guò)適當(dāng)?shù)卣{(diào)整線程池中的線程數(shù)目，也就是當(dāng)請(qǐng)求的數(shù)目超過(guò)某個(gè)閾值時(shí)，就強(qiáng)制其它任何新到的請(qǐng)求一直等待，直到獲得一個(gè)線程來(lái)處理為止，從而可以防止資源不足。

使用線程池的風(fēng)險(xiǎn)

雖然線程池是構(gòu)建多線程應(yīng)用程序的強(qiáng)大機(jī)制，但使用它并不是沒(méi)有風(fēng)險(xiǎn)的。用線程池構(gòu)建的應(yīng)用程序容易遭受任何其它多線程應(yīng)用程序容易遭受的所有并發(fā)風(fēng)險(xiǎn)，諸如同步錯(cuò)誤和死鎖，它還容易遭受特定于線程池的少數(shù)其它風(fēng)險(xiǎn)，諸如與池有關(guān)的死鎖、資源不足和線程泄漏。

死鎖

任何多線程應(yīng)用程序都有死鎖風(fēng)險(xiǎn)。當(dāng)一組進(jìn)程或線程中的每一個(gè)都在等待一個(gè)只有該組中另一個(gè)進(jìn)程才能引起的事件時(shí)，我們就說(shuō)這組進(jìn)程或線程死鎖了。死鎖的最簡(jiǎn)單情形是：線程 A 持有對(duì)象 X 的獨(dú)占鎖，并且在等待對(duì)象 Y 的鎖，而線程 B 持有對(duì)象 Y 的獨(dú)占鎖，卻在等待對(duì)象 X 的鎖。除非有某種方法來(lái)打破對(duì)鎖的等待（Java 鎖定不支持這種方法），否則死鎖的線程將永遠(yuǎn)等下去。

雖然任何多線程程序中都有死鎖的風(fēng)險(xiǎn)，但線程池卻引入了另一種死鎖可能，在那種情況下，所有池線程都在執(zhí)行已阻塞的等待隊(duì)列中另一任務(wù)的執(zhí)行結(jié)果的任務(wù)，但這一任務(wù)卻因?yàn)闆](méi)有未被占用的線程而不能運(yùn)行。當(dāng)線程池被用來(lái)實(shí)現(xiàn)涉及許多交互對(duì)象的模擬，被模擬的對(duì)象可以相互發(fā)送查詢，這些查詢接下來(lái)作為排隊(duì)的任務(wù)執(zhí)行，查詢對(duì)象又同步等待著響應(yīng)時(shí)，會(huì)發(fā)生這種情況。

資源不足

線程池的一個(gè)優(yōu)點(diǎn)在于：相對(duì)于其它替代調(diào)度機(jī)制（有些我們已經(jīng)討論過(guò)）而言，它們通常執(zhí)行得很好。但只有恰當(dāng)?shù)卣{(diào)整了線程池大小時(shí)才是這樣的。線程消耗包括內(nèi)存和其它系統(tǒng)資源在內(nèi)的大量資源。除了 Thread 對(duì)象所需的內(nèi)存之外，每個(gè)線程都需要兩個(gè)可能很大的執(zhí)行調(diào)用堆棧。除此以外，JVM 可能會(huì)為每個(gè) Java 線程創(chuàng)建一個(gè)本機(jī)線程，這些本機(jī)線程將消耗額外的系統(tǒng)資源。最后，雖然線程之間切換的調(diào)度開(kāi)銷(xiāo)很小，但如果有很多線程，環(huán)境切換也可能?chē)?yán)重地影響程序的性能。

如果線程池太大，那么被那些線程消耗的資源可能?chē)?yán)重地影響系統(tǒng)性能。在線程之間進(jìn)行切換將會(huì)浪費(fèi)時(shí)間，而且使用超出比您實(shí)際需要的線程可能會(huì)引起資源匱乏問(wèn)題，因?yàn)槌鼐€程正在消耗一些資源，而這些資源可能會(huì)被其它任務(wù)更有效地利用。除了線程自身所使用的資源以外，服務(wù)請(qǐng)求時(shí)所做的工作可能需要其它資源，例如 JDBC 連接、套接字或文件。這些也都是有限資源，有太多的并發(fā)請(qǐng)求也可能引起失效，例如不能分配 JDBC 連接。

并發(fā)錯(cuò)誤

線程池和其它排隊(duì)機(jī)制依靠使用 wait() 和 notify() 方法，這兩個(gè)方法都難于使用。如果編碼不正確，那么可能丟失通知，導(dǎo)致線程保持空閑狀態(tài)，盡管隊(duì)列中有工作要處理。使用這些方法時(shí)，必須格外小心；即便是專(zhuān)家也可能在它們上面出錯(cuò)。而最好使用現(xiàn)有的、已經(jīng)知道能工作的實(shí)現(xiàn)，例如在下面的無(wú)須編寫(xiě)您自己的池中討論的 util.concurrent 包。

線程泄漏

各種類(lèi)型的線程池中一個(gè)嚴(yán)重的風(fēng)險(xiǎn)是線程泄漏，當(dāng)從池中除去一個(gè)線程以執(zhí)行一項(xiàng)任務(wù)，而在任務(wù)完成后該線程卻沒(méi)有返回池時(shí)，會(huì)發(fā)生這種情況。發(fā)生線程泄漏的一種情形出現(xiàn)在任務(wù)拋出一個(gè) RuntimeException 或一個(gè) Error 時(shí)。如果池類(lèi)沒(méi)有捕捉到它們，那么線程只會(huì)退出而線程池的大小將會(huì)永久減少一個(gè)。當(dāng)這種情況發(fā)生的次數(shù)足夠多時(shí)，線程池最終就為空，而且系統(tǒng)將停止，因?yàn)闆](méi)有可用的線程來(lái)處理任務(wù)。

有些任務(wù)可能會(huì)永遠(yuǎn)等待某些資源或來(lái)自用戶的輸入，而這些資源又不能保證變得可用，用戶可能也已經(jīng)回家了，諸如此類(lèi)的任務(wù)會(huì)永久停止，而這些停止的任務(wù)也會(huì)引起和線程泄漏同樣的問(wèn)題。如果某個(gè)線程被這樣一個(gè)任務(wù)永久地消耗著，那么它實(shí)際上就被從池除去了。對(duì)于這樣的任務(wù)，應(yīng)該要么只給予它們自己的線程，要么只讓它們等待有限的時(shí)間。

請(qǐng)求過(guò)載

僅僅是請(qǐng)求就壓垮了服務(wù)器，這種情況是可能的。在這種情形下，我們可能不想將每個(gè)到來(lái)的請(qǐng)求都排隊(duì)到我們的工作隊(duì)列，因?yàn)榕旁陉?duì)列中等待執(zhí)行的任務(wù)可能會(huì) 消耗太多的系統(tǒng)資源并引起資源缺乏。在這種情形下決定如何做取決于您自己；在某些情況下，您可以簡(jiǎn)單地拋棄請(qǐng)求，依靠更高級(jí)別的協(xié)議稍后重試請(qǐng)求，您也可以用一個(gè)指出服務(wù)器暫時(shí)很忙的響應(yīng)來(lái)拒絕請(qǐng)求。

有效使用線程池的準(zhǔn)則

只要您遵循幾條簡(jiǎn)單的準(zhǔn)則，線程池可以成為構(gòu)建服務(wù)器應(yīng)用程序的極其有效的方法：

不要對(duì)那些同步等待其它任務(wù)結(jié)果的任務(wù)排隊(duì)。這可能會(huì)導(dǎo)致上面所描述的那種形式的死鎖，在那種死鎖中，所有線程都被一些任務(wù)所占用，這些任務(wù)依次等待排隊(duì)任務(wù)的結(jié)果，而這些任務(wù)又無(wú)法執(zhí)行，因?yàn)樗械木€程都很忙。
在為時(shí)間可能很長(zhǎng)的操作使用合用的線程時(shí)要小心。如果程序必須等待諸如 I/O 完成這樣的某個(gè)資源，那么請(qǐng)指定最長(zhǎng)的等待時(shí)間，以及隨后是失效還是將任務(wù)重新排隊(duì)以便稍后執(zhí)行。這樣做保證了：通過(guò)將某個(gè)線程釋放給某個(gè)可能成功完成的任務(wù)，從而將最終取得某些進(jìn)展。
理解任務(wù)。要有效地調(diào)整線程池大小，您需要理解正在排隊(duì)的任務(wù)以及它們正在做什么。它們是 CPU 限制的（CPU-bound）嗎？它們是 I/O 限制的（I/O-bound）嗎？您的答案將影響您如何調(diào)整應(yīng)用程序。如果您有不同的任務(wù)類(lèi)，這些類(lèi)有著截然不同的特征，那么為不同任務(wù)類(lèi)設(shè)置多個(gè)工作隊(duì) 列可能會(huì)有意義，這樣可以相應(yīng)地調(diào)整每個(gè)池。

posted @ 2011-09-01 14:01 crazy-李陽(yáng) 閱讀(241) | 評(píng)論 (0) | 編輯收藏

[置頂]線程池代碼

ibatis分頁(yè)<一>

線程池代碼

線程池

導(dǎo)航

統(tǒng)計(jì)

常用鏈接

留言簿

隨筆檔案

搜索

最新評(píng)論

閱讀排行榜

評(píng)論排行榜