<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
    


    		
	
    
	
    
		
			
		
		
			
    
				
					
	
    
		
    
			
    
				線程--條件Condition
			
    
 			Posted on 2009-12-23 22:50 啥都寫點 閱讀(440) 評論(0)  編輯  收藏  所屬分類: J2SE 
			
			


		
    
		
        本例介紹一個籃子程序，為了簡化問題，籃子中最多只能有一個蘋果。消費者必須在籃子里有蘋果的時候才能吃蘋果，否則它必須暫時放棄對籃子的鎖定，等到生產者往籃子里放了蘋果后再去拿來吃。而生產者也必須等到籃子空了才能往里放蘋果，否則它也需要暫時解鎖等消費者把蘋果吃了才能往籃子里放蘋果。
    
 
    
     通過Lock的newCondition方法創建Condition對象。
    
     Condition的await方法使當前線程進入等待狀態，并且釋放它占據的Lock，直到有其他線程喚醒當前線程時，重新占有Lock。
    
     Condition的signal方法喚醒其他正在等待該Condition的線程。
    

    


    
    import java.util.concurrent.ExecutorService;
    
    import java.util.concurrent.Executors;
    
    import java.util.concurrent.locks.Condition;
    
    import java.util.concurrent.locks.Lock;
    
    import java.util.concurrent.locks.ReentrantLock;
    

    
    /**
    
 * 有時候線程取得lock后需要在一定條件下才能做某些工作，比如說經典的Producer和Consumer問題。
    
 * 在Java 5.0以前，這種功能是由Object類的wait(), notify()和notifyAll()等方法實現的，
    
 * 在5.0里面，這些功能集中到了Condition這個接口來實現。
    
     */
    
    public class ConditionTest {
    

    
        /**
    
     * 籃子程序，這里為了簡化問題，籃子中最多只能有一個蘋果。
    
     * Consumer必須在籃子里有蘋果的時候才能吃蘋果，否則它必須暫時放棄對籃子的鎖定，
    
     * 等到Producer往籃子里放了蘋果后再去拿來吃。而Producer必須等到籃子空了才能往里放蘋果，
    
     * 否則它也需要暫時解鎖等Consumer把蘋果吃了才能往籃子里放蘋果。
    
         */
    
        public static class Basket {
    
            // 鎖
    
            Lock lock = new ReentrantLock();
    
            //    根據鎖產生Condition對象
    
            Condition produced = lock.newCondition();
    
        Condition consumed     = lock.newCondition();
    
            // 籃子中的蘋果數，最多為1
    
            int num = 0;
    

    
            /**
    
         * 生產蘋果，往籃子里放
    
         *     @throws InterruptedException
    
             */
    
            public void produce() throws InterruptedException {
    
                // 獲得鎖
    
                lock.lock();
    
            System.out.println(    "Producer get a lock");
    
                try {
    
                    // 判斷是否滿足生產條件
    
                    while (num == 1) {
    
                        // 如果有蘋果，則不生產，放棄鎖，進入睡眠
    
                        // 等待消費者消費
    
                        System.out.println("Producer sleep");
    
                    consumed.await(); 
    
                    System.out.println(    "Producer awaked");
    
                }
    
                    /*生產蘋果*/
    
                Thread.sleep(    500);
    
                System.out.println(    "Producer produced an Apple.");
    
                num     = 1;
    
                    // 通知等待produced Condition的線程
    
                    produced.signal();
    
            }     finally {
    
                lock.unlock();
    
            }
    
        }
    
            /**
    
         * 消費蘋果，從籃子中取
    
         *     @throws InterruptedException
    
             */
    
            public void consume() throws InterruptedException {
    
                // 獲得鎖
    
                lock.lock();
    
            System.out.println(    "Consumer get a lock");
    
                try {
    
                    // 判斷是否滿足消費條件
    
                    while (num == 0) {
    
                        // 如果沒有蘋果，無法消費，則放棄鎖，進入睡眠
    
                        // 等待生產者生產蘋果
    
                        System.out.println("Consumer sleep");
    
                    produced.await();  
    
                    System.out.println(    "Consumer awaked");
    
                }
    
                    /*吃蘋果*/
    
                Thread.sleep(    500);
    
                System.out.println(    "Consumer consumed an Apple.");
    
                num     = 0;
    
                    // 發信號喚醒某個等待consumed Condition的線程
    
                    consumed.signal();
    
            }     finally {
    
                lock.unlock();
    
            }
    
        }
    
    }
    
        /**
    
     * 測試Basket程序
    
         */
    
        public static void testBasket() throws Exception {
    
            final Basket basket = new Basket();
    
            //    定義一個producer
    
            Runnable producer = new Runnable() {
    
                public void run() {
    
                    try {
    
                    basket.produce();
    
                }     catch (InterruptedException ex) {
    
                    ex.printStackTrace();
    
                }
    
            }
    
        }    ;
    

    
            // 定義一個consumer
    
            Runnable consumer = new Runnable() {
    
                public void run() {
    
                    try {
    
                    basket.consume();
    
                }     catch (InterruptedException ex) {
    
                    ex.printStackTrace();
    
                }
    
            }
    
        }    ;
    

    
            //    各產生3個consumer和producer
    
            ExecutorService service = Executors.newCachedThreadPool();
    
            for (int i = 0; i < 3; i++){
    
            service.submit(producer);
    
        }
    
            for (int i = 0; i < 3; i++){
    
            service.submit(consumer);
    
        }
    
        service.shutdown();
    
    }          
    

    
        public static void main(String[] args) throws Exception {
    
        ConditionTest.testBasket();
    
    }
    
}


                                                                                                           --    學海無涯
    
             
    

    
	
    


    
	    
    

    

				
			
    
		    		
	
    
	
    
		
			

		
	
    

    


    



    
        
	



主站蜘蛛池模板：
亚洲国产另类久久久精品黑人
|
91av在线免费视频|
亚洲va久久久噜噜噜久久
|
亚洲色欲一区二区三区在线观看|
华人在线精品免费观看|
亚洲日本乱码一区二区在线二产线
|
免费影院未满十八勿进网站|
亚洲色欲啪啪久久WWW综合网|
亚洲免费视频一区二区三区|
国产麻豆成人传媒免费观看|
免费无码一区二区|
久久久久久亚洲精品|
成年女人喷潮毛片免费播放|
caoporm超免费公开视频|
亚洲精品视频在线免费|
四虎影视精品永久免费|
无码av免费一区二区三区试看|
亚洲精品无码久久久久牙蜜区|
国产亚洲精品无码拍拍拍色欲|
国产91色综合久久免费分享|
日本视频免费观看|
久久亚洲欧美国产精品|
亚洲AV日韩AV高潮无码专区|
国产亚洲精品国看不卡|
亚洲福利精品一区二区三区|
思思re热免费精品视频66
|
国产自偷亚洲精品页65页|
无码人妻久久一区二区三区免费丨|
大片免费观看92在线视频线视频|
亚洲最新中文字幕|
少妇中文字幕乱码亚洲影视|
亚洲福利精品一区二区三区|
亚洲乱码日产精品a级毛片久久|
国产一区视频在线免费观看|
国产一区二区视频免费|
heyzo亚洲精品日韩|
思思re热免费精品视频66|
永久免费毛片在线播放|
最近最新MV在线观看免费高清
|
亚洲AV日韩AV永久无码色欲|
国产亚洲一卡2卡3卡4卡新区|