Java多線程管理課件

第三講線程管理本章目標(biāo)線程的優(yōu)先級：優(yōu)先級概述線程優(yōu)先級的具體應(yīng)用線程同步：線程同步的目的線程同步的具體應(yīng)用線程死鎖：產(chǎn)生死鎖的必要條件與解決方法wait和notify機制線程優(yōu)先級多線程運行時需要定義線程運行的先后順序線程優(yōu)先級是用數(shù)字表示，數(shù)字越大線程優(yōu)先級越高，取值在（1到10）。默認(rèn)優(yōu)先級（為5）。優(yōu)先級應(yīng)用二 classThreadAextendsThread { publicvoidrun() { System.out.println("我是線程A"); } }

classThreadBextendsThread { publicvoidrun() { System.out.println("我是線程B"); } } 因為在代碼段當(dāng)中我們把線程B的優(yōu)先級設(shè)置高于線程A，所以運行結(jié)果先執(zhí)行線程B的run()方法后再執(zhí)行線程A的run()方法。線程優(yōu)先級的獲得JAVA中獲得線程優(yōu)先級的方法，是通過getPriority()方法來實現(xiàn)的。 publicclassPriThread { publicstaticvoidmain(Stringargs[]) { Threada=newThread(); Threadb=newThread(); intpriA=a.getPriority();//獲得優(yōu)先級的方法 intpriB=b.getPriority(); System.out.println(priA); System.out.println(priB); } }線程常量設(shè)置優(yōu)先級設(shè)置優(yōu)先級也可以用線程常量。MAX_PRIORITY為最高優(yōu)先級10；MIN_PRIORITY為最低優(yōu)先級1；NORM_PRIORITY是默認(rèn)優(yōu)先級5。線程安全問題public

classPiao{public

intnum;publicPiao(intnum){this.num=num;}public

voidsell(Stringname){if(num<=0){return;}System.out.println(name+"賣"+num);try{Thread.sleep(10);}catch(InterruptedExceptione){e.printStackTrace();}num=num-1;}}安全問題的解決Java中嵌套同步是安全的同步化方法同步塊的方式：voidmethod(){synchronized(this){//}}同步方法：synchronizedvoidmethod(){//}同步原理synchronized(object){//}鑰匙在對象中，而不在代碼中。

每個對象有一個鑰匙為了執(zhí)行synchronized()塊，線程需要得到對象中的鑰匙。一旦獲得了鑰匙，對象就不再擁有鑰匙。如果當(dāng)線程要執(zhí)行synchronized()時，鑰匙不在對象中，線程就wait。一直到鑰匙還到了對象中，才被這個線程拿到。當(dāng)線程離開synchorized()塊，鑰匙就還給了對象。死鎖的必要條件與解決方法死鎖圖，P1、P2表示兩個線程，R1、R2表示資源，P1已經(jīng)占用資源R1而且在等待R2，P2已經(jīng)占用資源R2而且在等待R1，這時就會產(chǎn)生兩個線程互相等待的狀態(tài)。wait和notify機制實際應(yīng)用中，多線程之間常常需要互相協(xié)調(diào)工作。例如生產(chǎn)者和消費者的問題。在JAVA中，這個機制的實現(xiàn)依賴于wait()/notify()方法。 synchronized(obj) { while(!condition) { obj.wait(); } obj.doSomething(); }

Wait與notify示例以生產(chǎn)產(chǎn)品面包為例。classBread{private

intid;publicBread(intid){this.id=id;}publicStringtoString(){return"面包"+id;}}Wait與notify示例生產(chǎn)方法pushpublic

synchronized

voidpush(Breadbread){if(index==breads.length){try{this.wait();}catch(InterruptedExceptione){e.printStackTrace();}}breads[index]=bread;index++;System.out.println("生產(chǎn)了"+bread);this.notify();}Wait與notify示例消費方法pop（）public

synchronized

voidpop(){try{Thread.sleep(1);}catch(InterruptedExceptione1){e1.printStackTrace();}if(index==0){try{this.wait();}catch(InterruptedExceptione){e.printStackTrace();}}index--;Breadbread=breads[index];System.out.println("消費了"+bread);this.notify();}Wait與notify示例生產(chǎn)者classProducerimplementsRunnable{privateBasketbasket;publicProducer(Basketbasket){this.basket=basket;}public

voidrun(){for(inti=0;i<20;i++){Breadbread=newBread(i);basket.push(bread);}}}Wait與notify示例測試類：public

classTestProducerConsumer{public

static

voidmain(String[]args){Basketbasket=newBasket();Producerproducer=newProducer(basket);Consumerconsumer=newConsumer(basket);Threadthread=newThread(producer);Threadthread2=newThr