Java多線程管理的學(xué)習(xí)課件

Java多線程管理的學(xué)習(xí)課件第1頁(yè)/共23頁(yè)本章目標(biāo)線程的優(yōu)先級(jí)：優(yōu)先級(jí)概述線程優(yōu)先級(jí)的具體應(yīng)用線程同步：線程同步的目的線程同步的具體應(yīng)用線程死鎖：產(chǎn)生死鎖的必要條件與解決方法wait和notify機(jī)制第2頁(yè)/共23頁(yè)線程優(yōu)先級(jí)多線程運(yùn)行時(shí)需要定義線程運(yùn)行的先后順序線程優(yōu)先級(jí)是用數(shù)字表示，數(shù)字越大線程優(yōu)先級(jí)越高，取值在（1到10）。默認(rèn)優(yōu)先級(jí)（為5）。第3頁(yè)/共23頁(yè)優(yōu)先級(jí)應(yīng)用一 publicclassPriThread { publicstaticvoidmain(Stringargs[]) { ThreadAa=newThreadA(); ThreadBb=newThreadB(); a.setPriority(2);//設(shè)置優(yōu)先級(jí)別，數(shù)值越大優(yōu)先級(jí)越高

b.setPriority(3); a.start(); b.start(); } }第4頁(yè)/共23頁(yè)優(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()方法。第5頁(yè)/共23頁(yè)線程優(yōu)先級(jí)的獲得JAVA中獲得線程優(yōu)先級(jí)的方法，是通過(guò)getPriority()方法來(lái)實(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); } }第6頁(yè)/共23頁(yè)線程常量設(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。第7頁(yè)/共23頁(yè)線程常量設(shè)置優(yōu)先級(jí)示例publicclassPriConstant{ publicstaticvoidmain(Stringargs[]) { Threada=newThread(); inttemp=Thread.MAX_PRIORITY; a.setPriority(temp); //設(shè)置此線程優(yōu)先級(jí)最高

System.out.println(a.getPriority());

temp=Thread.MIN_PRIORITY; a.setPriority(temp); //設(shè)置此線程優(yōu)先級(jí)最低

System.out.println(a.getPriority());

temp=Thread.NORM_PRIORITY; a.setPriority(temp); //將線程優(yōu)先級(jí)設(shè)置為默認(rèn)

System.out.println(a.getPriority()); }}第8頁(yè)/共23頁(yè)線程安全問(wèn)題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;}}第9頁(yè)/共23頁(yè)安全問(wèn)題的解決Java中嵌套同步是安全的同步化方法同步塊的方式：

voidmethod(){synchronized(this){//}}同步方法：synchronizedvoidmethod(){//}第10頁(yè)/共23頁(yè)同步原理synchronized(object){//}鑰匙在對(duì)象中，而不在代碼中。

每個(gè)對(duì)象有一個(gè)鑰匙為了執(zhí)行synchronized()塊，線程需要得到對(duì)象中的鑰匙。一旦獲得了鑰匙，對(duì)象就不再擁有鑰匙。如果當(dāng)線程要執(zhí)行synchronized()時(shí)，鑰匙不在對(duì)象中，線程就wait。一直到鑰匙還到了對(duì)象中，才被這個(gè)線程拿到。當(dāng)線程離開synchorized()塊，鑰匙就還給了對(duì)象。第11頁(yè)/共23頁(yè)階段回顧線程優(yōu)先級(jí)的概念？什么是線程同步？如何實(shí)現(xiàn)線程同步？實(shí)現(xiàn)同步的要點(diǎn)：兩個(gè)線程對(duì)相同的公共資源進(jìn)行訪問(wèn)。通過(guò)同步公共資源的訪問(wèn)方法實(shí)現(xiàn)線程安全。第12頁(yè)/共23頁(yè)死鎖的必要條件與解決方法死鎖圖，P1、P2表示兩個(gè)線程，R1、R2表示資源，P1已經(jīng)占用資源R1而且在等待R2，P2已經(jīng)占用資源R2而且在等待R1，這時(shí)就會(huì)產(chǎn)生兩個(gè)線程互相等待的狀態(tài)。第13頁(yè)/共23頁(yè)wait和notify機(jī)制實(shí)際應(yīng)用中，多線程之間常常需要互相協(xié)調(diào)工作。例如生產(chǎn)者和消費(fèi)者的問(wèn)題。在JAVA中，這個(gè)機(jī)制的實(shí)現(xiàn)依賴于wait()/notify()方法。

synchronized(obj) { while(!condition) { obj.wait(); } obj.doSomething(); }

第14頁(yè)/共23頁(yè)Wait與notify示例以生產(chǎn)產(chǎn)品面包為例。classBread{private

intid;publicBread(intid){this.id=id;}publicStringtoString(){return"面包"+id;}}第15頁(yè)/共23頁(yè)Wait與notify示例面包是放在一個(gè)籃子中，籃子滿了生產(chǎn)者必須等待，籃子空了，消費(fèi)者必須等待。兩者之間互相要有通訊。classBasket{privateBread[]breads=newBread[6];private

intindex=0;…}第16頁(yè)/共23頁(yè)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();}第17頁(yè)/共23頁(yè)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();}第18頁(yè)/共23頁(yè)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);}}}第19頁(yè)/共23頁(yè)Wait與notify示例消費(fèi)者classConsumerimplementsRunnable{privateBasketbasket;publicConsumer(Basketbasket){this.basket=basket;}public

voidrun(){for(inti=0;i<20;i++){basket.pop();}}}第20頁(yè)/共23頁(yè)Wait與notify示例測(cè)試類：public

classTestProducerConsumer{public

static

voidmain(String[]args){Basketbasket=newBasket();Producerproducer=newProducer(basket);Consumerconsume