Java多線程管理課件

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

classThreadBextendsThread { publicvoidrun() { System.out.println("我是線程B"); } } 因?yàn)樵诖a段當(dāng)中我們把線程B的優(yōu)先級(jí)設(shè)置高于線程A，所以運(yùn)行結(jié)果先執(zhí)行線程B的run()方法后再執(zhí)行線程A的run()方法。線程優(yōu)先級(jí)的獲得JAVA中獲得線程優(yōu)先級(jí)的方法，是通過getPriority()方法來實(shí)現(xiàn)的。 publicclassPriThread { publicstaticvoidmain(Stringargs[]) { Threada=newThread(); Threadb=newThread(); intpriA=a.getPriority();//獲得優(yōu)先級(jí)的方法 intpriB=b.getPriority(); System.out.println(priA); System.out.println(priB); } }線程常量設(shè)置優(yōu)先級(jí)設(shè)置優(yōu)先級(jí)也可以用線程常量。MAX_PRIORITY為最高優(yōu)先級(jí)10；MIN_PRIORITY為最低優(yōu)先級(jí)1；NORM_PRIORITY是默認(rèn)優(yōu)先級(jí)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){//}鑰匙在對(duì)象中，而不在代碼中。

每個(gè)對(duì)象有一個(gè)鑰匙為了執(zhí)行synchronized()塊，線程需要得到對(duì)象中的鑰匙。一旦獲得了鑰匙，對(duì)象就不再擁有鑰匙。如果當(dāng)線程要執(zhí)行synchronized()時(shí)，鑰匙不在對(duì)象中，線程就wait。一直到鑰匙還到了對(duì)象中，才被這個(gè)線程拿到。當(dāng)線程離開synchorized()塊，鑰匙就還給了對(duì)象。死鎖的必要條件與解決方法死鎖圖，P1、P2表示兩個(gè)線程，R1、R2表示資源，P1已經(jīng)占用資源R1而且在等待R2，P2已經(jīng)占用資源R2而且在等待R1，這時(shí)就會(huì)產(chǎn)生兩個(gè)線程互相等待的狀態(tài)。wait和notify機(jī)制實(shí)際應(yīng)用中，多線程之間常常需要互相協(xié)調(diào)工作。例如生產(chǎn)者和消費(fèi)者的問題。在JAVA中，這個(gè)機(jī)制的實(shí)現(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示例消費(fèi)方法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("消費(fèi)了"+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示例測(cè)試類：public

classTestProducerConsumer{public

static

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