Java网络程序设计 课件 单元8-05 线程死锁和协作

线程应用单元八目录CONTENTS123多线程创建和使用线程线程控制线程死锁和协作目录CONTENTS5共享数据48.5.1线程死锁

多线程同步的好处是避免了线程获取错误数据，但多线程同步也带来了性能问题。多线程同步采用了同步代码块和同步方法的方式，依靠的是锁机制实现了互斥访问。因为是互斥的访问，所以不能并行处理，存在性能问题。

多线程同步的性能问题还只是快和慢的问题，但如果出现了线程死锁，那可能直接导致程序众多的线程都处于阻塞状态，无法继续运行。publicclassDeadLockThread{//创建两个线程之间竞争使用的对象privatestaticObjectlock1=newObject();privatestaticObjectlock2=newObject();publicstaticvoidmam(String[]args){newThread(newShareThreadl()).start();newThread(newShareThread2()).start();}示例代码——线程的死锁：privatestaticclassShareThreadlimplementsRunnable{publicvoidrun(){synchronized(lock1){try{Thread.sleep(50);}catch(InterruptedExceptione){e.printStackTrace();}synchronized(lock2){System.out.println("ShareThread1");}}}}8.5.1线程死锁privatestaticclassShareThread2implementsRunnable{publicvoidrun(){synchronized(lock2){try{Thread.sleep(50);}catch(InterruptedExceptione){e.printStackTrace();}synchronized(lock1){System.out.println("ShareThread2");}}}}}示例代码：8.5.1线程死锁8.5.2线程协作

线程协作的一个典型案例就是生产者和消费者问题，生产者和消费者的这种协作是通过线程之间的握手来实现的，而这种握手又是通过Object类的wait()和notity()方法来实现。8.5.2线程协作Java提供了wait()、notify()、notifyAll()三个方法，解决线程之间协作的问题。这三个方法均是java.lang.Object类的方法，但都只能在同步方法或者同步代码块中使用，否则会抛出异常。voidwait()当前线程等待，等待其他线程调用此对象的notify()方法或notifyAll()方法将其唤醒。voidnotify()唤醒在此对象锁上等待的单个线程。voidnotifyAll()唤醒在此对象锁上等待的所有线程。importjava.util.*;publicclassTestProdCons{//定义一个存放热狗的集合，里面存放的是整数，代表热狗编号privatestaticfinalList<Integer>hotDogs=newArrayList<Integer>();publicstaticvoidmain(String[]args){for(inti=1;i<=3;i++){newProducer(i).start();}for(inti=1;i<=5;i++){newConsumer(i).start();}try{Thread.sleep(2000);}catch(InterruptedExceptione){e.printStackTrace();}System.exit(0);}吃热狗活动示例代码：8.5.2线程协作//生产者线程，以热狗集合作为对象锁，所有对热狗集合的操作互斥privatestaticclassProducerextendsThread{inti=1;intpid=-1;publicProducer(intid){this.pid=id;}publicvoidrun(){while(true){try{//模拟消耗的时间Thread.sleep(100);}catch(InterruptedExceptione){e.printStackTrace();}synchronized(hotDogs){if(hotDogs.size()<10){//热狗编号，300002代表编号为3的生产者生产的第2个热狗hotDogs.add(pid*10000+i);System.out.println("生产者"+pid+"生产热狗，编号为："+pid*10000+i);i++;//唤醒hotDogs对象锁上所有调用wait()方法的线程hotDogs.notifyAll();}else{try{System.outprintln(“热狗数已到10个，等待消费！”)；hotDogs.wait();}catch(InterruptedExceptione){e.printStackTrace();}}}}}}8.5.2线程协作//消费者线程，以热狗集合作为对象锁，所有对热狗集合的操作互斥privatestaticclassConsumerextendsThread{intcid=-1;publicConsumer(intid){this.cid=id;}publicvoidrun(){while(true){synchronized(hotDogs){try{//模拟消耗的时间Thread.sleep(200);}catch(InterruptedExceptione){e.printStackTrace();}8.5.2线程协作if(hotDogs.size()>0){System.out.println("消费者"+this.cid+"正在消费一个热狗，其编号为："+hotDogs.remove(0));hotDogs.notifyAll