<rt id="bn8ez"></rt>
<label id="bn8ez"></label>
  • 

    • <span id="bn8ez"></span>
    

    <label id="bn8ez"><meter id="bn8ez"></meter></label>
    

    
    

    




    







												


        


    
	
    
		
			

    

    
	
    
		
			
    Cyh的博客
    
			Email:kissyan4916@163.com
    

		    		
	
    

    

    

    

    posts - 26, comments - 19, trackbacks - 0, articles - 220
    


    		
	
    
	
    
		
			
		
		
			
    
				
					
	
    
		
    
			
    
				線程--任務(wù)執(zhí)行架構(gòu)
			
    
 			Posted on 2009-12-22 20:53 啥都寫點(diǎn) 閱讀(557) 評論(0)  編輯  收藏  所屬分類: J2SE 
			
			


		
    
		
        Executor服務(wù)對象是用來執(zhí)行Runnable任務(wù)的，常用的方法如下：
    
          execute方法用于執(zhí)行Ruannable類型的任務(wù)。
    
    ExecutorService服務(wù)對象能執(zhí)行和終止Callable任務(wù)，它繼承了Executor，所以也能執(zhí)行Runnable任務(wù)。常用的方法如下：
    

    
          submit方法用來提交Callable 或Runnable任務(wù)，并返回代表此任務(wù)的Future對象。
    
          invokeAll方法批處理任務(wù)集合，并返回一個代表這些任務(wù)的Future對象集合。
    
          shutdown方法在完成已提交的任務(wù)后關(guān)閉服務(wù)，不再接受新任務(wù)。
    
          shutdownNow方法停止所有正在執(zhí)行的任務(wù)并關(guān)閉服務(wù)。
    
          isTerminated測試是否所有任務(wù)都執(zhí)行完畢了。
    
          isShuttdown測試是否該ExecutorService已被關(guān)閉。
    

    
    ScheduledExecutorService服務(wù)對象繼承ExecutorService，提供了按時間安排執(zhí)行任務(wù)的功能。常用的方法如下:
    
           a>schedule(task,initDelay)方法安排所提交的Runnable任務(wù)按指定的間隔重復(fù)執(zhí)行。
    
           b>scheduleAtFixedRate方法安排所提交的Runnable任務(wù)按指定的間隔重復(fù)執(zhí)行。
    
           c>sheduleWithFixedDelay方法安排所提交的Runnable任務(wù)在每次執(zhí)行完后，等待delay所指定的時間后重復(fù)執(zhí)行。
    
    Executors類用來創(chuàng)建各種服務(wù)對象，常用的方法如下：
    
           a> callable（Runnable task）方法將Runnable的任務(wù)轉(zhuǎn)化成Callable的任務(wù)。
    
           b> newSingleThreadExecutor方法產(chǎn)生一個ExecutorService對象，這個對象只有一個線程可用來執(zhí)行任務(wù)，若任務(wù)多于一個，則按先后順序執(zhí)行任務(wù)。
    
           c>newCachedThreadPool方法產(chǎn)生一個ExecutorService對象，這個對象帶有一個線程池，線程池的大小會根據(jù)需要調(diào)整，線程執(zhí)行完任務(wù)后返回線程池，供執(zhí)行下一次任務(wù)使用。
    
           d>newFixedThreadPool(int poolSize)方法產(chǎn)生一個ExecutorService對象，這個對象帶有一個大小為poolSize的線程池，若任務(wù)數(shù)量大于poolSize，任務(wù)會被放在一個隊(duì)列里順序執(zhí)行
    
           e>   newSingleThreadScheduledExecutor方法產(chǎn)生一個ScheduledExecutorService對象，這個對象的線程池大小為1，若任務(wù)多余一個，任務(wù)將按先后順序執(zhí)行。
    
           f>newScheduledThreadPool(int poolSize) 方法產(chǎn)生一個ScheduleExecutorService對象，這個對象的線程池大小為poolSize，若任務(wù)數(shù)量大于poolSize，任務(wù)會在一個隊(duì)列里等待執(zhí)行。
    

    


    
    import java.util.concurrent.Callable;
    
    import java.util.concurrent.ExecutionException;
    
    import java.util.concurrent.ExecutorService;
    
    import java.util.concurrent.Executors;
    
    import java.util.concurrent.Future;
    
    import java.util.concurrent.ScheduledExecutorService;
    
    import java.util.concurrent.TimeUnit;
    

    
    /**
    
 * 新的任務(wù)執(zhí)行架構(gòu)。
    
 * 在Java 5.0之前啟動一個任務(wù)是通過調(diào)用Thread類的start()方法來實(shí)現(xiàn)的，
    
 * 任務(wù)的提于交和執(zhí)行是同時進(jìn)行的，如果你想對任務(wù)的執(zhí)行進(jìn)行調(diào)度，
    
 * 或是控制同時執(zhí)行的線程數(shù)量就需要額外編寫代碼來完成。
    
 * 5.0里提供了一個新的任務(wù)執(zhí)行架構(gòu)使你可以輕松地調(diào)度和控制任務(wù)的執(zhí)行，
    
 * 并且可以建立一個類似數(shù)據(jù)庫連接池的線程池來執(zhí)行任務(wù)。
    
 * 這個架構(gòu)主要有三個接口和其相應(yīng)的具體類組成。
    
 * 這三個接口是Executor, ExecutorService和ScheduledExecutorService。
    
 * （1）Executor接口：是用來執(zhí)行Runnable任務(wù)的，它只定義一個方法：
    
 * execute(Runnable command)：執(zhí)行Ruannable類型的任務(wù)
    
 * （2）ExecutorService：繼承了Executor的方法，并提供了執(zhí)行Callable任務(wù)和中止任務(wù)執(zhí)行的服務(wù)，
    
 * 其定義的方法主要有：
    
 * submit(task)：可用來提交Callable或Runnable任務(wù)，并返回代表此任務(wù)的Future對象 
    
 * invokeAll(collection of tasks)：批處理任務(wù)集合，并返回一個代表這些任務(wù)的Future對象集合 
    
 * shutdown()：在完成已提交的任務(wù)后關(guān)閉服務(wù)，不再接受新任務(wù) 
    
 * shutdownNow()：停止所有正在執(zhí)行的任務(wù)并關(guān)閉服務(wù)。 
    
 * isTerminated()：測試是否所有任務(wù)都執(zhí)行完畢了。 
    
 * isShutdown()：測試是否該ExecutorService已被關(guān)閉
    
 * （3）ScheduledExecutorService：繼承ExecutorService，提供了按時間安排執(zhí)行任務(wù)的功能、
    
 * schedule(task, initDelay): 安排所提交的Callable或Runnable任務(wù)在initDelay指定的時間后執(zhí)行。
    
 * scheduleAtFixedRate()：安排所提交的Runnable任務(wù)按指定的間隔重復(fù)執(zhí)行 
    
 * scheduleWithFixedDelay()：安排所提交的Runnable任務(wù)在每次執(zhí)行完后，等待delay所指定的時間后重復(fù)執(zhí)行。
    
 * 
    
 * 通過Executors類來獲得各種服務(wù)對象。
    
 * callable(Runnable task): 將Runnable的任務(wù)轉(zhuǎn)化成Callable的任務(wù) 
    
 * newSingleThreadExecutor: 產(chǎn)生一個ExecutorService對象，這個對象只有一個線程可用來執(zhí)行任務(wù)，若任務(wù)多于一個，任務(wù)將按先后順序執(zhí)行。 
    
 * newCachedThreadPool(): 產(chǎn)生一個ExecutorService對象，這個對象帶有一個線程池，線程池的大小會根據(jù)需要調(diào)整，線程執(zhí)行完任務(wù)后返回線程池，供執(zhí)行下一次任務(wù)使用。
    
 * newFixedThreadPool(int poolSize)：產(chǎn)生一個ExecutorService對象，這個對象帶有一個大小為poolSize的線程池，若任務(wù)數(shù)量大于poolSize，任務(wù)會被放在一個queue里順序執(zhí)行。 
    
 * newSingleThreadScheduledExecutor：產(chǎn)生一個ScheduledExecutorService對象，這個對象的線程池大小為1，若任務(wù)多于一個，任務(wù)將按先后順序執(zhí)行。 
    
 * newScheduledThreadPool(int poolSize): 產(chǎn)生一個ScheduledExecutorService對象，這個對象的線程池大小為poolSize，若任務(wù)數(shù)量大于poolSize，任務(wù)會在一個queue里等待執(zhí)行 
    
     */
    
    public class ExecuteArch {
    
    
    
        /**
    
     * 該線程輸出一行字符串
    
         */
    
        public static class MyThread implements Runnable {
    
            public void run() {
    
            System.out.println(    "Task repeating. " + System.currentTimeMillis());
    
                try {
    
                Thread.sleep(    1000);
    
            }     catch (InterruptedException e) {
    
                System.out.println(    "Task interrupted. "
    
                            + System.currentTimeMillis());
    
            }
    
        }
    
    }
    

    
        /**
    
     * 該Callable結(jié)束另一個任務(wù)
    
         */
    
        public static class MyCallable implements Callable {
    
            private Future future;
    

    
            public MyCallable(Future future) {
    
                this.future = future;
    
        }
    

    
            public String call() {
    
            System.out.println(    "To cancell Task"
    
                        + +System.currentTimeMillis());
    
                this.future.cancel(true);
    
                return "Task cancelled!";
    
        }
    
    }
    

    
        /**
    
     *     @param args
    
     *     @throws ExecutionException 
    
     *     @throws InterruptedException 
    
         */
    
        public static void main(String[] args) throws InterruptedException,
    
            ExecutionException     {
    
            // 產(chǎn)生一個ExecutorService對象，這個對象帶有一個線程池，線程池的大小會根據(jù)需要調(diào)整，
    
            // 線程執(zhí)行完任務(wù)后返回線程池，供執(zhí)行下一次任務(wù)使用。
    
            ExecutorService cachedService = Executors.newCachedThreadPool();
    
        Future myThreadFuture     = cachedService.submit(new MyThread());
    
        Future myCallableFuture     = cachedService.submit(new MyCallable(
    
                myThreadFuture));
    
        System.out.println(myCallableFuture.get());
    
        System.out.println(    "-----------------");
    

    
            // 將Runnable任務(wù)轉(zhuǎn)換成Callable任務(wù)
    
            Callable myThreadCallable = Executors.callable(new MyThread());
    
        Future myThreadCallableFuture     = cachedService.submit(myThreadCallable);
    
            // 對于Runnable任務(wù)，轉(zhuǎn)換成Callable任務(wù)后，也沒有返回值
    
            System.out.println(myThreadCallableFuture.get());
    
        cachedService.shutdownNow();
    
        System.out.println(    "-----------------");
    

    
            // 產(chǎn)生一個ExecutorService對象，這個對象帶有一個大小為poolSize的線程池，
    
            // 若任務(wù)數(shù)量大于poolSize，任務(wù)會被放在一個queue里順序執(zhí)行
    
            ExecutorService fixedService = Executors.newFixedThreadPool(2);
    
        fixedService.submit(    new MyThread());
    
        fixedService.submit(    new MyThread());
    
            // 由于線程池大小為2，所以后面的任務(wù)必須等待前面的任務(wù)執(zhí)行完后才能被執(zhí)行。
    
            myThreadFuture = fixedService.submit(new MyThread());
    
        myCallableFuture     = fixedService.submit(new MyCallable(myThreadFuture));
    
        System.out.println(myCallableFuture.get());
    
        fixedService.shutdownNow();
    
        System.out.println(    "-----------------");
    

    
            // 產(chǎn)生一個ScheduledExecutorService對象，這個對象的線程池大小為poolSize，
    
            // 若任務(wù)數(shù)量大于poolSize，任務(wù)會在一個queue里等待執(zhí)行
    
            ScheduledExecutorService fixedScheduledService = Executors
    
                .newScheduledThreadPool(    2);
    
            // 新建任務(wù)1
    
            MyThread task1 = new MyThread();
    
            // 使用任務(wù)執(zhí)行服務(wù)立即執(zhí)行任務(wù)1，而且此后每隔2秒執(zhí)行一次任務(wù)1。
    
            myThreadFuture = fixedScheduledService.scheduleAtFixedRate(task1, 0, 2,
    
                TimeUnit.SECONDS);
    
            // 新建任務(wù)2
    
            MyCallable task2 = new MyCallable(myThreadFuture);
    
            // 使用任務(wù)執(zhí)行服務(wù)等待5秒后執(zhí)行任務(wù)2，執(zhí)行它后會將任務(wù)1關(guān)閉。
    
            myCallableFuture = fixedScheduledService.schedule(task2, 5,
    
                TimeUnit.SECONDS);
    
        System.out.println(myCallableFuture.get());
    
        fixedScheduledService.shutdownNow();
    
    }
    
}
    

    



                                                                                                           --    學(xué)海無涯
    
             
    

    
	
    


    
	    
    

    

				
			
    
		    		
	
    
	
    
		
			

		
	
    

    


    



    
        
	



主站蜘蛛池模板：
国产精品美女自在线观看免费|
精品国产免费人成电影在线观看
|
亚洲综合综合在线|
a色毛片免费视频|
国产亚洲一区二区三区在线观看|
久久一区二区三区免费|
亚洲夜夜欢A∨一区二区三区|
在线观看片免费人成视频播放|
精品亚洲综合久久中文字幕|
九九精品成人免费国产片|
羞羞漫画在线成人漫画阅读免费|
在线播放免费播放av片|
亚洲精品无AMM毛片|
国产裸模视频免费区无码|
国产亚洲情侣久久精品|
国产亚洲老熟女视频|
a级成人毛片免费图片|
91久久亚洲国产成人精品性色|
最近免费字幕中文大全视频|
麻豆狠色伊人亚洲综合网站|
免费看无码自慰一区二区|
污污污视频在线免费观看|
亚洲成AV人在线观看天堂无码|
91久久成人免费|
亚洲人成色777777精品|
亚洲精品第一国产综合精品99
|
99久久免费精品视频|
国产精品亚洲四区在线观看
|
亚洲国产成人AV网站|
精品国产人成亚洲区|
97精品免费视频|
亚洲乱码av中文一区二区|
亚洲国产精品人人做人人爱|
无码国产精品一区二区免费模式|
jlzzjlzz亚洲jzjzjz|
亚洲国产成人a精品不卡在线|
日韩精品久久久久久免费|
美国免费高清一级毛片|
亚洲AV无码久久精品色欲|
成人免费无码大片a毛片软件|
国产伦精品一区二区免费|