《Java多線程管理》PPT幻燈片

1、1,第三講,線程管理,2,本章目標(biāo),線程的優(yōu)先級(jí)： 優(yōu)先級(jí)概述 線程優(yōu)先級(jí)的具體應(yīng)用 線程同步： 線程同步的目的 線程同步的具體應(yīng)用 線程死鎖： 產(chǎn)生死鎖的必要條件與解決方法 wait和notify機(jī)制,3,線程優(yōu)先級(jí),多線程運(yùn)行時(shí)需要定義線程運(yùn)行的先后順序 線程優(yōu)先級(jí)是用數(shù)字表示，數(shù)字越大線程優(yōu)先級(jí)越高，取值在（1到10）。 默認(rèn)優(yōu)先級(jí)（為5）。,4,優(yōu)先級(jí)應(yīng)用一,public class PriThread public static void main(String args ) ThreadA a=new ThreadA(); ThreadB b=new ThreadB(); a.se

2、tPriority(2);/設(shè)置優(yōu)先級(jí)別，數(shù)值越大優(yōu)先級(jí)越高 b.setPriority(3); a.start(); b.start(); ,5,優(yōu)先級(jí)應(yīng)用二,class ThreadA extends Thread public void run() System.out.println(我是線程A); class ThreadB extends Thread public void run() System.out.println(我是線程B); 因?yàn)樵诖a段當(dāng)中我們把線程B的優(yōu)先級(jí)設(shè)置高于線程A，所以運(yùn)行結(jié)果先執(zhí)行線程B的run()方法后再執(zhí)行線程A的run()方法。,6,線程優(yōu)先級(jí)的

3、獲得,JAVA中獲得線程優(yōu)先級(jí)的方法，是通過(guò)getPriority()方法來(lái)實(shí)現(xiàn)的。 public class PriThread public static void main(String args ) Thread a=new Thread(); Thread b=new Thread(); int priA=a.getPriority();/獲得優(yōu)先級(jí)的方法 int priB=b.getPriority(); System.out.println(priA); System.out.println(priB); ,7,線程常量設(shè)置優(yōu)先級(jí),設(shè)置優(yōu)先級(jí)也可以用線程常量。 MAX_PRIOR

4、ITY為最高優(yōu)先級(jí)10； MIN_PRIORITY為最低優(yōu)先級(jí)1； NORM_PRIORITY是默認(rèn)優(yōu)先級(jí)5。,8,線程常量設(shè)置優(yōu)先級(jí)示例,public class PriConstant public static void main(String args ) Thread a=new Thread(); int temp=Thread.MAX_PRIORITY; a.setPriority(temp);/設(shè)置此線程優(yōu)先級(jí)最高 System.out.println(a.getPriority(); temp=Thread.MIN_PRIORITY; a.setPriority(temp);

5、/設(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(); ,9,線程安全問(wèn)題,public class Piao public int num; public Piao(int num) this.num = num; public void sell(String name) if(num=0) return; System.out.println(name+賣+n

6、um); try Thread.sleep(10); catch (InterruptedException e) e.printStackTrace(); num=num-1; ,10,安全問(wèn)題的解決,Java中嵌套同步是安全的 同步化方法 同步塊的方式： void method() synchronized(this) / 同步方法： synchronized void method() / ,11,同步原理,synchronized (object) / 鑰匙在對(duì)象中，而不在代碼中。 每個(gè)對(duì)象有一個(gè)鑰匙 為了執(zhí)行synchronized()塊，線程需要得到對(duì)象中的鑰匙。一旦獲得了鑰匙，對(duì)

7、象就不再擁有鑰匙。 如果當(dāng)線程要執(zhí)行synchronized()時(shí)，鑰匙不在對(duì)象中，線程就wait。一直到鑰匙還到了對(duì)象中，才被這個(gè)線程拿到。 當(dāng)線程離開(kāi)synchorized()塊，鑰匙就還給了對(duì)象。,12,階段回顧,線程優(yōu)先級(jí)的概念？ 什么是線程同步？如何實(shí)現(xiàn)線程同步？ 實(shí)現(xiàn)同步的要點(diǎn)： 兩個(gè)線程對(duì)相同的公共資源進(jìn)行訪問(wèn)。 通過(guò)同步公共資源的訪問(wèn)方法實(shí)現(xiàn)線程安全。,13,死鎖的必要條件與解決方法,死鎖圖，P1、P2表示兩個(gè)線程，R1、R2表示資源，P1已經(jīng)占用資源R1而且在等待R2，P2已經(jīng)占用資源R2而且在等待R1，這時(shí)就會(huì)產(chǎn)生兩個(gè)線程互相等待的狀態(tài)。,14,wait和notify機(jī)制,

8、實(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(); ,15,Wait與notify示例,以生產(chǎn)產(chǎn)品面包為例。 class Bread private int id; public Bread(int id) this.id = id; public String toString() return 面包+id; ,16,Wait與notify示例,面包是放在一個(gè)籃子中，籃

9、子滿了生產(chǎn)者必須等待，籃子空了，消費(fèi)者必須等待。兩者之間互相要有通訊。 class Basket private Bread breads = new Bread6; private int index = 0; ,17,Wait與notify示例,生產(chǎn)方法push public synchronized void push(Bread bread) if(index = breads.length) try this.wait(); catch (InterruptedException e) e.printStackTrace(); breadsindex = bread; index+;

10、 System.out.println(生產(chǎn)了+bread); this.notify(); ,18,Wait與notify示例,消費(fèi)方法pop（） public synchronized void pop() try Thread.sleep(1); catch (InterruptedException e1) e1.printStackTrace(); if(index = 0) try this.wait(); catch (InterruptedException e) e.printStackTrace(); index-; Bread bread = breadsindex; S

11、ystem.out.println(消費(fèi)了+bread); this.notify(); ,19,Wait與notify示例,生產(chǎn)者 class Producer implements Runnable private Basket basket; public Producer(Basket basket) this.basket = basket; public void run() for(int i=0;i20;i+) Bread bread = new Bread(i); basket.push(bread); ,20,Wait與notify示例,消費(fèi)者 class Consumer

12、 implements Runnable private Basket basket; public Consumer(Basket basket) this.basket = basket; public void run() for(int i=0;i20;i+) basket.pop(); ,21,Wait與notify示例,測(cè)試類： public class TestProducerConsumer public static void main(String args) Basket basket = new Basket(); Producer producer = new Producer(basket); Consumer consumer = new Consumer(basket); Thread thread = new Thread(prod