Java多线程管理的学习课件

Java多线程管理的学习课件第1页/共23页本章目标线程的优先级：优先级概述线程优先级的具体应用线程同步：线程同步的目的线程同步的具体应用线程死锁：产生死锁的必要条件与解决方法wait和notify机制第2页/共23页线程优先级多线程运行时需要定义线程运行的先后顺序线程优先级是用数字表示，数字越大线程优先级越高，取值在（1到10）。默认优先级（为5）。第3页/共23页优先级应用一 publicclassPriThread { publicstaticvoidmain(Stringargs[]) { ThreadAa=newThreadA(); ThreadBb=newThreadB(); a.setPriority(2);//设置优先级别，数值越大优先级越高

b.setPriority(3); a.start(); b.start(); } }第4页/共23页优先级应用二 classThreadAextendsThread { publicvoidrun() { System.out.println("我是线程A"); } }

classThreadBextendsThread { publicvoidrun() { System.out.println("我是线程B"); } }

因为在代码段当中我们把线程B的优先级设置高于线程A，所以运行结果先执行线程B的run()方法后再执行线程A的run()方法。第5页/共23页线程优先级的获得JAVA中获得线程优先级的方法，是通过getPriority()方法来实现的。

publicclassPriThread { publicstaticvoidmain(Stringargs[]) { Threada=newThread(); Threadb=newThread(); intpriA=a.getPriority();//获得优先级的方法

intpriB=b.getPriority(); System.out.println(priA); System.out.println(priB); } }第6页/共23页线程常量设置优先级设置优先级也可以用线程常量。MAX_PRIORITY为最高优先级10；MIN_PRIORITY为最低优先级1；NORM_PRIORITY是默认优先级5。第7页/共23页线程常量设置优先级示例publicclassPriConstant{ publicstaticvoidmain(Stringargs[]) { Threada=newThread(); inttemp=Thread.MAX_PRIORITY; a.setPriority(temp); //设置此线程优先级最高

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

temp=Thread.MIN_PRIORITY; a.setPriority(temp); //设置此线程优先级最低

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

temp=Thread.NORM_PRIORITY; a.setPriority(temp); //将线程优先级设置为默认

System.out.println(a.getPriority()); }}第8页/共23页线程安全问题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页/共23页安全问题的解决Java中嵌套同步是安全的同步化方法同步块的方式：

voidmethod(){synchronized(this){//}}同步方法：synchronizedvoidmethod(){//}第10页/共23页同步原理synchronized(object){//}钥匙在对象中，而不在代码中。

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

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

第14页/共23页Wait与notify示例以生产产品面包为例。classBread{private

intid;publicBread(intid){this.id=id;}publicStringtoString(){return"面包"+id;}}第15页/共23页Wait与notify示例面包是放在一个篮子中，篮子满了生产者必须等待，篮子空了，消费者必须等待。两者之间互相要有通讯。classBasket{privateBread[]breads=newBread[6];private

intindex=0;…}第16页/共23页Wait与notify示例生产方法pushpublic

synchronized

voidpush(Breadbread){if(index==breads.length){try{this.wait();}catch(InterruptedExceptione){e.printStackTrace();}}breads[index]=bread;index++;System.out.println("生产了"+bread);this.notify();}第17页/共23页Wait与notify示例消费方法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("消费了"+bread);this.notify();}第18页/共23页Wait与notify示例生产者classProducerimplementsRunnable{privateBasketbasket;publicProducer(Basketbasket){this.basket=basket;}public

voidrun(){for(inti=0;i<20;i++){Breadbread=newBread(i);basket.push(bread);}}}第19页/共23页Wait与notify示例消费者classConsumerimplementsRunnable{privateBasketbasket;publicConsumer(Basketbasket){this.basket=basket;}public

voidrun(){for(inti=0;i<20;i++){basket.pop();}}}第20页/共23页Wait与notify示例测试类：public

classTestProducerConsumer{public

static

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