Java多线程管理

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

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

3、优先级的方法，是通过getPriority()方法来实现的。public class PriThreadpublic 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);线程常量设置优先级线程常量设置优先级设置优先级也可以用线程常量。MAX_PRIORITY为最高优先级10；MIN_P

4、RIORITY为最低优先级1；NORM_PRIORITY是默认优先级5。线程常量设置优先级示例线程常量设置优先级示例public class PriConstantpublic 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);/设置此线程优先级最低System.o

5、ut.println(a.getPriority();temp=Thread.NORM_PRIORITY;a.setPriority(temp);/将线程优先级设置为默认 System.out.println(a.getPriority();线程安全问题线程安全问题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+卖+num);try Thread.sleep(10); c

6、atch (InterruptedException e) e.printStackTrace();num=num-1;安全问题的解决安全问题的解决Java中嵌套同步是安全的同步化方法同步块的方式： void method() synchronized(this) / 同步方法：synchronized void method() / 同步原理同步原理synchronized (object) / 钥匙在对象中，而不在代码中。 每个对象有一个钥匙 w为了执行synchronized()块，线程需要得到对象中的钥匙。一旦获得了钥匙，对象就不再拥有钥匙。 w如果当线程要执行synchronized

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

8、者和消费者的问题。 在JAVA中，这个机制的实现依赖于wait()/notify()方法。synchronized(obj) while(!condition) obj.wait();obj.doSomething(); Wait与与notify示例示例 以生产产品面包为例。class Breadprivate int id;public Bread(int id)this.id = id;public String toString() return 面包+id;Wait与与notify示例示例面包是放在一个篮子中，篮子满了生产者必须等待，篮子空了，消费者必须等待。两者之间互相要有通讯。cl

9、ass Basketprivate Bread breads = new Bread6;private int index = 0;Wait与与notify示例示例生产方法pushpublic synchronized void push(Bread bread)if(index = breads.length)try this.wait(); catch (InterruptedException e) e.printStackTrace();breadsindex = bread;index+;System.out.println(生产了+bread);this.notify();Wait

10、与与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;System.out.println(消费了+bread);this.notify();Wait与与notify示例示例生

11、产者class Producer implements Runnableprivate 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);Wait与与notify示例示例消费者class Consumer implements Runnableprivate Basket basket;public Consumer(Basket basket)thi

12、s.basket = basket;public void run() for(int i=0;i20;i+)basket.pop();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(producer);Thread t