多线程(04)-生产者和消费者问题、Object类中对线程的支持_以及面试题目.docx

26. 多线程（04） 本季讲解了线程通讯的经典案例，之后又讲解了Object类中对线程的支持，以及面试题目。 blog: 零基础学JAVAJava SE应用部分-26.多线程（04） 2009-02-19生产者和消费者问题（1）生产者和消费者问题（2）classPersonString name =张三;String sex =男;/ 张三 - 男/ 李四 - 女classProimplementsRunnable/声明一个共享区域Person per =null;publicPro(Person p)this.per = p;publicvoidrun()inti = 0;while(true)if(i=0) =李四;per.sex =女;i=1; =张三;per.sex =男;i =0;classCusimplementsRunnablePerson per =null;publicCus(Person p)this.per = p;publicvoidrun()while(true)System.out.println(+ - +per.sex);publicclassThreadDemo01publicstaticvoidmain(String args)Person per =newPerson();Pro p =newPro(per);Cus c =newCus(per);newThread(p).start();newThread(c).start();看下效果：以上代码已经可以从输出中看见了一些错误了，所以此处我们可以将代码进行修改，加入一些延迟，这样错误比较明显了classPersonString name =张三;String sex =男;/ 张三 - 男/ 李四 - 女classProimplementsRunnable/声明一个共享区域Person per =null;publicPro(Person p)this.per = p;publicvoidrun()inti = 0;while(true)if(i=0) =李四;tryThread.sleep(100);catch(Exception e)per.sex =女;i=1; =张三;per.sex =男;i =0;classCusimplementsRunnablePerson per =null;publicCus(Person p)this.per = p;publicvoidrun()while(true)tryThread.sleep(100);catch(Exception e)System.out.println(+ - +per.sex);publicclassThreadDemo02publicstaticvoidmain(String args)Person per =newPerson();Pro p =newPro(per);Cus c =newCus(per);newThread(p).start();newThread(c).start();之前的两个问题已经全部出现了，现在解决第一个：关于设置内容的问题； 永远要保持张三是男，李四是女。classPersonprivateString name =张三;privateString sex =男;/ 张三 - 男/ 李四 - 女publicsynchronizedvoidset(String name,String sex) = name;/ 加入延迟验证设置是否生效tryThread.sleep(100);catch(Exception e)this.sex = sex;/设置一个输出方法publicsynchronizedvoidget()tryThread.sleep(100);catch(Exception e)System.out.println(+ - +this.sex);classProimplementsRunnable/声明一个共享区域Person per =null;publicPro(Person p)this.per = p;publicvoidrun()inti = 0;while(true)if(i=0)per.set(李四,女);i=1;elseper.set(张三,男);i =0;classCusimplementsRunnablePerson per =null;publicCus(Person p)this.per = p;publicvoidrun()while(true)per.get();publicclassThreadDemo03publicstaticvoidmain(String args)Person per =newPerson();Pro p =newPro(per);Cus c =newCus(per);newThread(p).start();newThread(c).start();通过同步方法，确实解决了设置上的问题，张三是男的，李四是女的，但是第二个问题还没有解决，以上效果看到得只是假像，如果休眠时间设置都取消的话可以看出问题哈classPersonprivateString name =张三;privateString sex =男;/ 张三 - 男/ 李四 - 女publicsynchronizedvoidset(String name,String sex) = name;/ 加入延迟验证设置是否生效this.sex = sex;/设置一个输出方法publicsynchronizedvoidget()System.out.println(+ - +this.sex);classProimplementsRunnable/声明一个共享区域Person per =null;publicPro(Person p)this.per = p;publicvoidrun()inti = 0;while(true)if(i=0)per.set(李四,女);i=1;elseper.set(张三,男);i =0;classCusimplementsRunnablePerson per =null;publicCus(Person p)this.per = p;publicvoidrun()while(true)per.get();publicclassThreadDemo04publicstaticvoidmain(String args)Person per =newPerson();Pro p =newPro(per);Cus c =newCus(per);newThread(p).start();newThread(c).start();如果设置成只有一个休眠中断的话看得明显classPersonprivateString name =张三;privateString sex =男;/ 张三 - 男/ 李四 - 女publicsynchronizedvoidset(String name,String sex) = name;/ 加入延迟验证设置是否生效this.sex = sex;/设置一个输出方法publicsynchronizedvoidget()System.out.println(+ - +this.sex);classProimplementsRunnable/声明一个共享区域Person per =null;publicPro(Person p)this.per = p;publicvoidrun()inti = 0;while(true)if(i=0)per.set(李四,女);i=1;elseper.set(张三,男);i =0;classCusimplementsRunnablePerson per =null;publicCus(Person p)this.per = p;publicvoidrun()while(true)tryThread.sleep(500);catch(Exception e)per.get();publicclassThreadDemo04publicstaticvoidmain(String args)Person per =newPerson();Pro p =newPro(per);Cus c =newCus(per);newThread(p).start();newThread(c).start();如果不让其重复取值，我们可以学习下下面的知识绿灯可以放数据，不能取数据红灯可以取数据，不能放数据同理依次执行哈如果红灯时，即消费者（read）取数据时，CPU将资源给了生产者，当生产者将数据要放入时，发现是红灯，只能等待哈等到绿灯时生产者才能将cccc数据放入哈这样的机制就是线程的等待和唤醒，也就是下面的内容哈线程的等待及唤醒当发现消费者没有取走内容的时候，生产者应该等待当消费者把内容取走之后，生产者才可以放。classPersonprivateString name =张三;privateString sex =男;privatebooleanflag =false;/ flag = true时表示允许生产但不允许取走/ flag = false时表示允许取走但不允许生产/ 张三 - 男/ 李四 - 女/编写一个设置内容的方法publicsynchronizedvoidset(String name,String sex)/如果flag的值不是true则要等待if(!flag)/等待trywait();catch(Exception e)tryThread.sleep(100);catch(Exception e)/ 如果向下继续执行了，则表示可以设置,flag = = name;this.sex = sex;/ 修改设置的标志flag =false;/唤醒其他线程notify();/设置一个输出方法publicsynchronizedvoidget()/ 如果flag的值为true的时候，表示要等待if(flag)trywait();catch(Exception e)tryThread.sleep(100);catch(Exception e)/如果向下执行了，则表示允许取出System.out.println(+ - +this.sex);/改变标志，表示可以生产了flag =true;notify();classProimplementsRunnable/声明一个共享区域Person per =null;publicPro(Person p)this.per = p;publicvoidrun()inti = 0;while(true)if(i=0)per.set(李四,女);i=1;elseper.set(张三,男);i =0;classCusimplementsRunnablePerson per =null;publicCus(Person p)this.per = p;publicvoidrun()while(true)per.get();publicclassThreadDemo05publicstaticvoidmain(String args)Person per =newPerson();Pro p =newPro(per);Cus c =newCus(per);newThread(p).start();newThread(c).start();看下效果：这样就解决了第二个问题以上的三个方法，实际上是Object类中的三个方法。控制线程的生命周期以上的很多方法都不建议继续使用了，因为会造成死锁，那么如果我现在要停止一个线程的运行，该怎么办？C盘拷贝内容到D盘，中止拷贝时系统会有些延迟，同理我们可以通过设置标志位让其停止。classMyThreadimplementsRunnableprivatebooleanflag =true;publicvoidrun()inti=0;while(flag)System.out.println(Thread.currentThread().getName()+ - 运行，i =+(i+);publicvoidsetFlag(booleanflag)this.flag = flag;publicclassThreadDemo06publicstaticvoidmain(String args)MyThread mt =newMyThread();newThread(mt).start();tryThread.sleep(300);catch(Exception e)/将线程的运行的条件修改了，则肯定停止运行mt.setFlag(false);或者也可以修改成throws ExceptionclassMyThreadimplementsRunnableprivatebooleanflag =true;publicvoidrun()inti=0;while(flag)System.out.println(Thread.currentThread().getName()+ - 运行，i =+(i+);publicvoidsetFlag(booleanflag)this.flag = flag;publicclassThreadDemo06publicstaticvoidmain(String args)throwsExceptionMyThread mt =newMyThread();newThread(mt).start();Thread.sleep(300);/将线程的运行的条件修改了，则肯定停止运行mt.setFlag(false);发现程序运行一段时间后自己停止运行了哈多线程面试题：可以直接参考生产者和消费者问题。classNumintj = 0;classIncimplementsRunnableprivateNum n =null;publicInc(Num n)this.n = n;publi