《Java多线程管理》PPT幻灯片

1、1,第三讲,线程管理,2,本章目标,线程的优先级： 优先级概述 线程优先级的具体应用 线程同步： 线程同步的目的 线程同步的具体应用 线程死锁： 产生死锁的必要条件与解决方法 wait和notify机制,3,线程优先级,多线程运行时需要定义线程运行的先后顺序 线程优先级是用数字表示，数字越大线程优先级越高，取值在（1到10）。 默认优先级（为5）。,4,优先级应用一,public class PriThread public static void main(String args ) ThreadA a=new ThreadA(); ThreadB b=new ThreadB(); a.se

2、tPriority(2);/设置优先级别，数值越大优先级越高 b.setPriority(3); a.start(); b.start(); ,5,优先级应用二,class ThreadA extends Thread public void run() System.out.println(我是线程A); class ThreadB extends Thread public void run() System.out.println(我是线程B); 因为在代码段当中我们把线程B的优先级设置高于线程A，所以运行结果先执行线程B的run()方法后再执行线程A的run()方法。,6,线程优先级的

3、获得,JAVA中获得线程优先级的方法，是通过getPriority()方法来实现的。 public class PriThread public static void main(String args ) Thread a=new Thread(); Thread b=new Thread(); int priA=a.getPriority();/获得优先级的方法 int priB=b.getPriority(); System.out.println(priA); System.out.println(priB); ,7,线程常量设置优先级,设置优先级也可以用线程常量。 MAX_PRIOR

4、ITY为最高优先级10； MIN_PRIORITY为最低优先级1； NORM_PRIORITY是默认优先级5。,8,线程常量设置优先级示例,public class PriConstant public static void main(String args ) Thread a=new Thread(); int temp=Thread.MAX_PRIORITY; a.setPriority(temp);/设置此线程优先级最高 System.out.println(a.getPriority(); temp=Thread.MIN_PRIORITY; a.setPriority(temp);

5、/设置此线程优先级最低 System.out.println(a.getPriority(); temp=Thread.NORM_PRIORITY; a.setPriority(temp);/将线程优先级设置为默认 System.out.println(a.getPriority(); ,9,线程安全问题,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,安全问题的解决,Java中嵌套同步是安全的 同步化方法 同步块的方式： void method() synchronized(this) / 同步方法： synchronized void method() / ,11,同步原理,synchronized (object) / 钥匙在对象中，而不在代码中。 每个对象有一个钥匙 为了执行synchronized()块，线程需要得到对象中的钥匙。一旦获得了钥匙，对

7、象就不再拥有钥匙。 如果当线程要执行synchronized()时，钥匙不在对象中，线程就wait。一直到钥匙还到了对象中，才被这个线程拿到。 当线程离开synchorized()块，钥匙就还给了对象。,12,阶段回顾,线程优先级的概念？ 什么是线程同步？如何实现线程同步？ 实现同步的要点： 两个线程对相同的公共资源进行访问。 通过同步公共资源的访问方法实现线程安全。,13,死锁的必要条件与解决方法,死锁图，P1、P2表示两个线程，R1、R2表示资源，P1已经占用资源R1而且在等待R2，P2已经占用资源R2而且在等待R1，这时就会产生两个线程互相等待的状态。,14,wait和notify机制,

8、实际应用中，多线程之间常常需要互相协调工作。例如生产者和消费者的问题。 在JAVA中，这个机制的实现依赖于wait()/notify()方法。 synchronized(obj) while(!condition) obj.wait(); obj.doSomething(); ,15,Wait与notify示例,以生产产品面包为例。 class Bread private int id; public Bread(int id) this.id = id; public String toString() return 面包+id; ,16,Wait与notify示例,面包是放在一个篮子中，篮

9、子满了生产者必须等待，篮子空了，消费者必须等待。两者之间互相要有通讯。 class Basket private Bread breads = new Bread6; private int index = 0; ,17,Wait与notify示例,生产方法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(生产了+bread); this.notify(); ,18,Wait与notify示例,消费方法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(消费了+bread); this.notify(); ,19,Wait与notify示例,生产者 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示例,消费者 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示例,测试类： 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