import java.util.concurrent.ExecutorService;  
import java.util.concurrent.Executors;  
import java.util.concurrent.ScheduledExecutorService;  
import java.util.concurrent.TimeUnit;  
  
public class ThreadPoolTest {  
    static int num = 100;  
    public static void main(String[] args) throws InterruptedException {  
        //固定線程數(shù)量的線程池，有任務(wù)就派空閑線程去執(zhí)行，多余的任務(wù)等待  
        //ExecutorService  pool= Executors.newFixedThreadPool(3);  
        //根據(jù)任務(wù)需要，自動(dòng)創(chuàng)建線程，且 前面已創(chuàng)建的線程，空閑時(shí)，可被復(fù)用  
        //ExecutorService  pool= Executors.newCachedThreadPool();  
        //單個(gè)線程，若執(zhí)行期出現(xiàn)失敗而終止此單個(gè)線程，則會(huì)建一個(gè)新線程來代替，運(yùn)行任務(wù)  
        ExecutorService  pool= Executors.newSingleThreadExecutor();  
        //給線程池加 10條任務(wù)  
        for (int j= 0; j < 10; j++) {  
            final int task = j;  
            pool.execute(new Runnable() {  
                  
                @Override  
                public void run() {  
                    // TODO Auto-generated method stub  
                    for (int i=0; i < 10; i++) {  
                        System.out.println(Thread.currentThread().getName() + "--" +i  
                                + "--" + task + " of taks" + " 計(jì)數(shù)：" + (--num));  
                    }  
                }  
            });  
            // Thread.sleep(20);  
        }  
        //可安排在給定的延遲后運(yùn)行或定期執(zhí)行的命令。   
        ScheduledExecutorService service = Executors.newScheduledThreadPool(3);  
        for (int i = 0; i < 5; i++) {  
            final int x = i;  
            service.scheduleAtFixedRate(new Runnable() {  
                  
                @Override  
                public void run() {  
                    // TODO Auto-generated method stub  
                    System.out.println("Boon " + x + "  "  + Thread.currentThread().getName());  
                }  
            },0,2,TimeUnit.SECONDS);//延遲0秒，周期2秒  
        }  
          
        //poor.shutdownNow();//試圖馬上停了所有正在執(zhí)行的任務(wù)，返回任務(wù)列表  
        pool.shutdown();//把分配給線程池的任務(wù)都執(zhí)行完，就不再等待接受新任務(wù)了，  
    //  service.shutdown();  
          
    }  
}

標(biāo)簽：

版權(quán)申明：本站文章部分自網(wǎng)絡(luò)，如有侵權(quán)，請(qǐng)聯(lián)系：west999com@outlook.com
特別注意：本站所有轉(zhuǎn)載文章言論不代表本站觀點(diǎn)！
本站所提供的圖片等素材，版權(quán)歸原作者所有，如需使用，請(qǐng)與原作者聯(lián)系。