Java语言程序设计基础教程.pptx

《Java语言程序设计基础教程.pptx》由会员分享，可在线阅读，更多相关《Java语言程序设计基础教程.pptx（50页珍藏版）》请在淘文阁 - 分享文档赚钱的网站上搜索。

1、会计学1Java语言语言(yyn)程序设计基础教程程序设计基础教程第一页，共50页。7.1线程简介线程简介(jin ji)n n到到目目前前为为止止所所介介绍绍过过的的各各种种范范例例都都是是单单线线程程程程序序，也也就就是是启启动动的的JavaJava程程序序在在“同同一一时时间间”内内只只会会做做一一件件事事。文文本本(wnbn)(wnbn)模模式式下下最最常常进进行行的的就就是是单单线线程程程程序序。有有时时需需要要程程序序“同同时时”可可以以作作很很多多事事，即即所所谓谓多多线线程程（Multi-threadMulti-thread）程程序序，在在窗窗口口程程序序、网网络络程程序序中中

2、常常使使用用多多线线程程功功能能，了了解解多多线线程程概概念与注意事项是非常重要的。念与注意事项是非常重要的。第1页/共50页第二页，共50页。7.1.1进程进程(jnchng)与线程与线程n n程序是一段静态的代码，它是应用软件执行的蓝本。程序是一段静态的代码，它是应用软件执行的蓝本。n n进程是程序的一次动态执行过程，它对应了从代码加载、进程是程序的一次动态执行过程，它对应了从代码加载、执行至执行完毕的一个完整过程，这个过程也是进程本执行至执行完毕的一个完整过程，这个过程也是进程本身从产生、发展至消亡的过程。线程是比进程更小的执身从产生、发展至消亡的过程。线程是比进程更小的执行单位行单位,

3、一个进程在其执行过程中，可以产生多个线程，一个进程在其执行过程中，可以产生多个线程，形成多条执行线索，每条线索，即每个线程也有它自身形成多条执行线索，每条线索，即每个线程也有它自身的产生、存在和消亡的过程，也是一个动态的概念的产生、存在和消亡的过程，也是一个动态的概念(ginin)(ginin)。n nJavaJava的多线程就是在操作系统每次分时给的多线程就是在操作系统每次分时给JavaJava程序一个时程序一个时间片的间片的CPUCPU时间内，在若干个独立的可控制的线程之间时间内，在若干个独立的可控制的线程之间切换。切换。第2页/共50页第三页，共50页。7.1.2线程的状态线程的状态(z

4、hungti)n nJava使用Thread类及其子类的对象(duxing)来表示线程，线程在它的一个完整的生命周期中通常要经历如下的4种状态：n n1.创建状态(new Thread)n n2.可运行状态(Runnable)n n3.不可运行状态（Not Runnable）n n4.死亡状态（Dead）第3页/共50页第四页，共50页。7.2 Thread类的子类创建类的子类创建(chungjin)线程线程n n用Thread类或子类创建线程对象.n n编写Thread类的子类时，需要重写父类的run方法，其目的(md)是规定线程的具体操作，否则线程就什么也不做，因为父类的run方法中没有任

5、何操作语句。n n当JVM将CPU使用权切换给线程时，如果线程是Thread的子类创建的，该类中的run方法就立刻执行。第4页/共50页第五页，共50页。7.3实现实现(shxin)Runnable接口接口 n n创建线程的另一个途径就是用创建线程的另一个途径就是用ThreadThread类直接创建线程类直接创建线程对象。使用对象。使用ThreadThread类创建线程对象时，常用的构造方类创建线程对象时，常用的构造方法是：法是：n nThread(Runnable target);Thread(Runnable target);n n该构造方法中的参数是一个该构造方法中的参数是一个Runna

6、bleRunnable类型的接口，因类型的接口，因此，在创建线程对象时，必须向构造方法的参数传递此，在创建线程对象时，必须向构造方法的参数传递一个实现一个实现RunnableRunnable接口类的实例，该实例对象称为接口类的实例，该实例对象称为(chn(chn wi)wi)所创线程的目标对象。所创线程的目标对象。第5页/共50页第六页，共50页。【例【例7-3】通过接口】通过接口(ji ku)构造构造线程体线程体n nimport java.awt.Graphics;import java.awt.Graphics;n nimport java.util.Date;import java.u

7、til.Date;n npublic class ep7_3 extends java.applet.Applet implements Runnable/public class ep7_3 extends java.applet.Applet implements Runnable/实现实现(shxin)(shxin)接口接口n nThread clockThread;Thread clockThread;n npublic void start()public void start()n nif(clockThread=null)if(clockThread=null)n nclockT

8、hread=new Thread(this,Clock);clockThread=new Thread(this,Clock);n nclockThread.start();/clockThread.start();/启动线程启动线程n n n n 第6页/共50页第七页，共50页。n npublic void run()/run()public void run()/run()方法中是线程执行方法中是线程执行(zhxng)(zhxng)的内容的内容n nwhile(clockThread!=null)while(clockThread!=null)n nrepaint();/repaint(

9、);/刷新显示画面刷新显示画面n ntry try n nclockThread.sleep(1000);/clockThread.sleep(1000);/睡眠睡眠1 1秒，即每隔秒，即每隔1 1秒秒执行执行(zhxng)(zhxng)一次一次n n catch(InterruptedException e)catch(InterruptedException e)n n n n n n 第7页/共50页第八页，共50页。n npublic void paint(Graphics g)public void paint(Graphics g)n nDate now=new Date();/D

10、ate now=new Date();/获得当前的时间获得当前的时间(shjin)(shjin)对象对象n ng.drawString(now.getHours()+:+now.getMinutes()+:g.drawString(now.getHours()+:+now.getMinutes()+:n n+now.getSeconds(),5,10);/+now.getSeconds(),5,10);/显示当前时间显示当前时间(shjin)(shjin)n n n npublic void stop()public void stop()n nclockThread.stop();clock

11、Thread.stop();n nclockThread=null;clockThread=null;n n n n 第8页/共50页第九页，共50页。n n本程序是本程序是AppletApplet，要运行，要运行(ynxng)Applet(ynxng)Applet程序，必须定义一个程序，必须定义一个htmlhtml文件，文件，ep7_3.htmlep7_3.html文件内容如下：文件内容如下：n nn n n n n n n n n n applet codebase=.height=100n n n n n n第9页/共50页第十页，共50页。n n上面这个(zh ge)例子是通过每隔1秒

12、种就执行线程的刷新画面功能，显示当前的时间；看起来的效果就是一个时钟，每隔1秒就变化一次。由于采用的是实现接口Runnable的方式，所以该类Clock还继承了Applet，Clock就可以Applet的方式运行。第10页/共50页第十一页，共50页。构造线程体的两种方法构造线程体的两种方法(fngf)的比较：的比较：n n1.1.使用使用RunnableRunnable接口接口 n n1)1)可以将可以将CPUCPU，代码和数据分开，形成清晰，代码和数据分开，形成清晰(qngx)(qngx)的模型的模型;n n2)2)还可以从其他类继承还可以从其他类继承;n n3)3)保持程序风格的一致性。

13、保持程序风格的一致性。n n2.2.直接继承直接继承ThreadThread类类 n n1)1)不能再从其他类继承不能再从其他类继承;n n2)2)编写简单，可以直接操纵线程，无需使用编写简单，可以直接操纵线程，无需使用Thread.currentThread()Thread.currentThread()。第11页/共50页第十二页，共50页。7.4基本基本(jbn)的线程控制的线程控制 n n可以通过线程的方法进行基本的线程控制，下面我们熟悉一下常用的方法。n n1start()方法 n n线程调用(dioyng)该方法将启动线程，从新建状态进入就绪队列排队。一旦CPU资源轮转到它时，就脱

14、离主线程开始自己的生命周期。第12页/共50页第十三页，共50页。n n2 2run()run()方法方法方法方法 n n系统的系统的系统的系统的ThreadThread类中，类中，类中，类中，run()run()方法没有具体内容，用户需要在程序中方法没有具体内容，用户需要在程序中方法没有具体内容，用户需要在程序中方法没有具体内容，用户需要在程序中重写重写重写重写run()run()方法来覆盖原来的方法来覆盖原来的方法来覆盖原来的方法来覆盖原来的run()run()方法，方法，方法，方法，run()run()方法中定义线程对象方法中定义线程对象方法中定义线程对象方法中定义线程对象被调度之后所执

15、行的操作，是系统自动调用而用户不能引用的方被调度之后所执行的操作，是系统自动调用而用户不能引用的方被调度之后所执行的操作，是系统自动调用而用户不能引用的方被调度之后所执行的操作，是系统自动调用而用户不能引用的方法。当法。当法。当法。当run()run()方法执行完毕，线程就变成死亡状态，在线程没有结方法执行完毕，线程就变成死亡状态，在线程没有结方法执行完毕，线程就变成死亡状态，在线程没有结方法执行完毕，线程就变成死亡状态，在线程没有结束束束束run()run()方法之前，不要让线程再调用方法之前，不要让线程再调用方法之前，不要让线程再调用方法之前，不要让线程再调用start()start()方

16、法，否则将发生方法，否则将发生方法，否则将发生方法，否则将发生IllegalThreadStateExceptionIllegalThreadStateException异常，这一点异常，这一点异常，这一点异常，这一点(y di(y di n)n)在写程序的时候在写程序的时候在写程序的时候在写程序的时候需要注意。需要注意。需要注意。需要注意。第13页/共50页第十四页，共50页。n n3sleep(int millsecond)方法方法 n nsleep方法可以方法可以(ky)暂停一个线程的执行，暂停一个线程的执行，在适当的时候再恢复其执行。就是让当前在适当的时候再恢复其执行。就是让当前线程睡

17、眠（停止执行）若干毫秒，线程由线程睡眠（停止执行）若干毫秒，线程由运行中状态进入不可运行状态，停止执行运行中状态进入不可运行状态，停止执行时间到后线程进入可运行状态。时间到后线程进入可运行状态。第14页/共50页第十五页，共50页。n n4isAlive()方法方法 n n测试线程状态。可以通过测试线程状态。可以通过Thread 中的中的isAlive()方法来获取方法来获取(huq)线程是否处于活动状线程是否处于活动状态；线程由态；线程由start()方法启动后，直到其被终方法启动后，直到其被终止之间的任何时刻，都处于止之间的任何时刻，都处于Alive状态。线状态。线程处于新建状态时，调用程

18、处于新建状态时，调用isAlive()方法返回方法返回false，线程进入死亡状态后，调用，线程进入死亡状态后，调用isAlive()方法返回方法返回false。第15页/共50页第十六页，共50页。n n5currentThread()方法方法 n ncurrentThread()方法是方法是Thread类的类方法，类的类方法，可以直接通过类名调用可以直接通过类名调用(dioyng)，该方法，该方法返回当前正在使用返回当前正在使用CPU资源的线程。资源的线程。第16页/共50页第十七页，共50页。n n6Interrupt()方法方法 n ninterrupt()方法常用来方法常用来“吵醒吵

19、醒”休眠的线程。休眠的线程。但线程调用但线程调用sleep方法处于休眠状态时，一方法处于休眠状态时，一个占有个占有CPU资源的线程可以让休眠的线程资源的线程可以让休眠的线程调用调用interrupt方法唤醒自己。导致休眠的线方法唤醒自己。导致休眠的线程发生程发生InterruptedException异常异常(ychng)，结束休眠，重新排队等待，结束休眠，重新排队等待CPU资源。资源。第17页/共50页第十八页，共50页。n n7stop()方法方法 n n通过调用线程的实例通过调用线程的实例(shl)方法方法stop()来终来终止线程。线程终止后，其生命周期结束了，止线程。线程终止后，其生

20、命周期结束了，即进入死亡态，终止后的线程不能再被调即进入死亡态，终止后的线程不能再被调度执行。度执行。第18页/共50页第十九页，共50页。n n8 8join()join()方法方法方法方法 n n一个线程在占有一个线程在占有一个线程在占有一个线程在占有CPUCPU资源期间，可以让其他线程调用资源期间，可以让其他线程调用资源期间，可以让其他线程调用资源期间，可以让其他线程调用join()join()方法和本线程联合。当前线程等待调用方法和本线程联合。当前线程等待调用方法和本线程联合。当前线程等待调用方法和本线程联合。当前线程等待调用该方法的线程结束后，再重新排队等待该方法的线程结束后，再重新

21、排队等待该方法的线程结束后，再重新排队等待该方法的线程结束后，再重新排队等待CPUCPU资源，以便恢复执行。如果当前线程准备联合的线程已资源，以便恢复执行。如果当前线程准备联合的线程已资源，以便恢复执行。如果当前线程准备联合的线程已资源，以便恢复执行。如果当前线程准备联合的线程已经结束，也就是经结束，也就是经结束，也就是经结束，也就是startstart方法体已经执行完，那么不会产生任何方法体已经执行完，那么不会产生任何方法体已经执行完，那么不会产生任何方法体已经执行完，那么不会产生任何(rnh)(rnh)效果。效果。效果。效果。n nTimerThread tt=new TimerThrea

22、d(100);TimerThread tt=new TimerThread(100);n ntt.start();tt.start();n n n npublic void timeout()public void timeout()n ntt.join();/tt.join();/当前线程等待线程当前线程等待线程当前线程等待线程当前线程等待线程tt tt 执行完后再继续往下执行执行完后再继续往下执行执行完后再继续往下执行执行完后再继续往下执行n n 第19页/共50页第二十页，共50页。【例【例7-5】线程联合】线程联合(linh)的例的例子。子。n npublic class ep7_5

23、public class ep7_5 n npublic static void main(String args)public static void main(String args)n nThreadJoin a=new ThreadJoin();ThreadJoin a=new ThreadJoin();n na.customer.start();a.customer.start();n na.tvMaker.start();a.tvMaker.start();n n n n 第20页/共50页第二十一页，共50页。n nclass ThreadJoin implements Runn

24、able class ThreadJoin implements Runnable n nTV tv;TV tv;n nThread customer,tvMaker;Thread customer,tvMaker;n nThreadJoin()ThreadJoin()n ncustomer=new Thread(this);customer=new Thread(this);n ntvMaker=new Thread(this);tvMaker=new Thread(this);n ncustomer.setName(customer.setName(顾客顾客(gk);(gk);n ntvM

25、aker.setName(tvMaker.setName(电视制造厂电视制造厂););n n 第21页/共50页第二十二页，共50页。nnpublic void run()public void run()nnif(Thread.currentThread()=customer)if(Thread.currentThread()=customer)nnSystem.out.println(customer.getName()+System.out.println(customer.getName()+等等+tvMaker.getName()+tvMaker.getName()nn+生产电视生产

26、电视););nntry try nntvMaker.join();/tvMaker.join();/线程线程customercustomer开始等待开始等待tvMakertvMaker结束结束(jish)(jish)nn catch(InterruptedException e)catch(InterruptedException e)nn nnSystem.out.println(customer.getName()+System.out.println(customer.getName()+买了一台电视：买了一台电视：+tv.name+tv.namenn+价钱价钱:+tv.price);:

27、+tv.price);nn else if(Thread.currentThread()=tvMaker)else if(Thread.currentThread()=tvMaker)nnSystem.out.println(tvMaker.getName()+System.out.println(tvMaker.getName()+开始生产电视开始生产电视,请等请等.);.);nntry try nntvMaker.sleep(2000);tvMaker.sleep(2000);nn catch(InterruptedException e)catch(InterruptedExceptio

28、n e)nn nntv=new TV(tv=new TV(红星牌红星牌,3288);,3288);nnSystem.out.println(tvMaker.getName()+System.out.println(tvMaker.getName()+生产完毕生产完毕););nn nn nn 第22页/共50页第二十三页，共50页。n nclass TV class TV n nfloat price;float price;n nString name;String name;n nTV(String name,float price)TV(String name,float price)n

29、nthis.name=name;this.name=name;n nthis.price=price;this.price=price;n n n n 第23页/共50页第二十四页，共50页。7.5线程的调度线程的调度(diod)n nJavaJava提供一个线程调度器来监控程序中启动后进入就绪状态的所有提供一个线程调度器来监控程序中启动后进入就绪状态的所有线程。线程调度器按照线程的优先级决定应调度哪些线程来执行。线程。线程调度器按照线程的优先级决定应调度哪些线程来执行。n n线程的优先级用数字来表示线程的优先级用数字来表示(bi(bi osh)osh)，范围从，范围从1 1到到1010，即，

30、即Thread.MIN_PRIORITYThread.MIN_PRIORITY到到Thread.MAX_PRIORITYThread.MAX_PRIORITY。一个线程的缺。一个线程的缺省优先级是省优先级是5 5，即，即Thread.NORM_PRIORITYThread.NORM_PRIORITY。第24页/共50页第二十五页，共50页。n n下述方法可以对优先级进行操作(cozu)：n nint getPriority();n n得到线程的优先级。n nvoid setPriority(int newPriority);n n当线程被创建后，可通过此方法改变线程的优先级。第25页/共50页

31、第二十六页，共50页。n n线程调度器按线程的优先级高低选择高优先级线程（进入运行中状态）执行，同时线线程调度器按线程的优先级高低选择高优先级线程（进入运行中状态）执行，同时线程调度是抢先式调度，即如果程调度是抢先式调度，即如果(rgu(rgu)在当前线程执行过程中，一个更高优先级的线程在当前线程执行过程中，一个更高优先级的线程进入可运行状态，则这个线程立即被调度执行。进入可运行状态，则这个线程立即被调度执行。n n抢先式调度又分为：时间片方式和独占方式。在时间片方式下，当前活动线程执行完抢先式调度又分为：时间片方式和独占方式。在时间片方式下，当前活动线程执行完当前时间片后，如果当前时间片后，

32、如果(rgu(rgu)有其他处于就绪状态的相同优先级的线程，系统会将执行有其他处于就绪状态的相同优先级的线程，系统会将执行权交给其他就绪态的同优先级线程；当前活动线程转入等待执行队列，等待下一个时权交给其他就绪态的同优先级线程；当前活动线程转入等待执行队列，等待下一个时间片的调度。间片的调度。n n在独占方式下，当前活动线程一旦获得执行权，将一直执行下去，直到执行完毕或由在独占方式下，当前活动线程一旦获得执行权，将一直执行下去，直到执行完毕或由于某种原因主动放弃于某种原因主动放弃CPUCPU，或者是有一高优先级的线程处于就绪状态。，或者是有一高优先级的线程处于就绪状态。第26页/共50页第二十

33、七页，共50页。n n下面几种情况下，当前线程会放弃下面几种情况下，当前线程会放弃CPUCPU：n n1 1）线程调用了）线程调用了yield()yield()或或sleep()sleep()方法主动放弃；方法主动放弃；n n2 2）由于当前线程进行）由于当前线程进行I/O I/O 访问，外存读写，等待用户输入等操作，导致线程访问，外存读写，等待用户输入等操作，导致线程阻塞；或者是为等候一个阻塞；或者是为等候一个(y(y )条件变量，以及线程调用条件变量，以及线程调用wait()wait()方法；方法；n n3 3）抢先式系统下，由高优先级的线程参与调度；时间片方式下，当前时间）抢先式系统下，

34、由高优先级的线程参与调度；时间片方式下，当前时间片用完，由同优先级的线程参与调度。片用完，由同优先级的线程参与调度。第27页/共50页第二十八页，共50页。7.6多线程的互斥与同步多线程的互斥与同步(tngb)n n经常有一些同时运行的线程需要共享数据，此时就需考虑其他线程的状态和行为，否则(fuz)就不能保证程序的运行结果的正确性。第28页/共50页第二十九页，共50页。7.6.1临界临界(ln ji)资源问题资源问题n n下面是一个堆栈的类定义：下面是一个堆栈的类定义：n nclass stack class stack n nint idx=0;/int idx=0;/堆栈指针堆栈指针(

35、zh(zh zhn)zhn)的初始值为的初始值为0 0n nchar data=new char6;/char data=new char6;/堆栈有堆栈有6 6个字符的空间个字符的空间n npublic void push(char c)/public void push(char c)/压栈操作压栈操作n ndataidx=c;/dataidx=c;/数据入栈数据入栈n nidx+;/idx+;/指针指针(zh(zh zhn)zhn)向上移动一位向上移动一位n n n npublic char pop()/public char pop()/出栈操作出栈操作n nidx-;/idx-;/指

36、针指针(zh(zh zhn)zhn)向下移动一位向下移动一位n nreturn dataidx;/return dataidx;/数据出栈数据出栈n n n n 第29页/共50页第三十页，共50页。n n两个线程两个线程A A和和B B在同时使用在同时使用StackStack的同一个实例对象，的同一个实例对象，A A正在往堆栈正在往堆栈里里pushpush一个数据，一个数据，B B则要从堆栈中则要从堆栈中poppop一个数据。如果由于线程一个数据。如果由于线程A A和和B B在对在对StackStack对象的操作上的不完整性，会导致操作的失败，具体过对象的操作上的不完整性，会导致操作的失败，

37、具体过程如下所示：程如下所示：n n1)1)操作之前操作之前 n ndata=|p|q|idx=2 data=|p|q|idx=2 n n2)A2)A执行执行(zhxng)push(zhxng)push中的第一个语句，将中的第一个语句，将r r推入堆栈；推入堆栈；n ndata=|p|q|r|idx=2 data=|p|q|r|idx=2 第30页/共50页第三十一页，共50页。n n3)A还未执行idx+语句，A的执行被B中断，B执行pop方法，返回q；n ndata=|p|q|r|idx=1 n n4A继续执行push的第二个语句：n ndata=|p|q|r|,|idx=2 n n最后的

38、结果相当于r没有入栈。产生这种问题的原因在于对共享数据(shj)访问的操作的不完整性。第31页/共50页第三十二页，共50页。7.6.2互斥锁互斥锁n n为解决操作的不完整性问题，在Java 语言(yyn)中，引入了对象互斥锁的概念，来保证共享数据操作的完整性。每个对象都对应于一个可称为“互斥锁”的标记，这个标记用来保证在任一时刻，只能有一个线程访问该对象。关键字synchronized 来与对象的互斥锁联系。当某个对象用synchronized 修饰时，表明该对象在任一时刻只能由一个线程访问。第32页/共50页第三十三页，共50页。n npublic void push(char c)pub

39、lic void push(char c)n nsynchronized(this)/thissynchronized(this)/this表示表示(bi(bi osh)Stackosh)Stack的当前对象的当前对象n ndataidx=c;dataidx=c;n nidx+;idx+;n n n n n npublic char pop()public char pop()n nsynchronized(this)/thissynchronized(this)/this表示表示(bi(bi osh)Stackosh)Stack的当前对象的当前对象n nidx-;idx-;n nreturn

40、 dataidx;return dataidx;n n n n 第33页/共50页第三十四页，共50页。n nsynchronized synchronized 除了象上面讲的放在对象前面限制一段代码的执行外，除了象上面讲的放在对象前面限制一段代码的执行外，还可以还可以(ky(ky)放在方法声明中，表示整个方法为同步方法。放在方法声明中，表示整个方法为同步方法。n npublic synchronized void push(char c)public synchronized void push(char c)n n n n n n如果如果synchronizedsynchronized用在

41、类声明中，则表明该类中的所有方法都是用在类声明中，则表明该类中的所有方法都是synchronizedsynchronized的。的。第34页/共50页第三十五页，共50页。7.6.3多线程的同步多线程的同步(tngb)n n本小节将讨论如何控制互相交互的线程之间的运行进度，即多线程之间的同步问题(wnt)，下面我们将通过多线程同步的模型：生产者-消费者问题(wnt)来说明怎样实现多线程的同步。n n我们把系统中使用某类资源的线程称为消费者，产生或释放同类资源的线程称为生产者。第35页/共50页第三十六页，共50页。n n在下面的Java的应用程序中，生产者线程向文件中写数据，消费者从文件中读数

42、据，这样，在这个程序中同时(tngsh)运行的两个线程共享同一个文件资源。通过这个例子我们来了解怎样使它们同步。第36页/共50页第三十七页，共50页。n nclass SyncStack /class SyncStack /同步同步(tngb)(tngb)堆栈类堆栈类n nprivate int index=0;/private int index=0;/堆栈指针初始值为堆栈指针初始值为0 0n nprivate char buffer=new char6;/private char buffer=new char6;/堆栈有堆栈有6 6个字符的空间个字符的空间n npublic synch

43、ronized void push(char c)/public synchronized void push(char c)/加上互斥锁加上互斥锁n nwhile(index=buffer.length)/while(index=buffer.length)/堆栈已满，不能压栈堆栈已满，不能压栈n ntry try n nthis.wait();/this.wait();/等待，直到有数据出栈等待，直到有数据出栈n n catch(InterruptedException e)catch(InterruptedException e)n n n n n nthis.notify();/thi

44、s.notify();/通知其它线程把数据出栈通知其它线程把数据出栈n nbufferindex=c;/bufferindex=c;/数据入栈数据入栈n nindex+;/index+;/指针向上移动指针向上移动n n 第37页/共50页第三十八页，共50页。n npublic synchronized char pop()/public synchronized char pop()/加上互斥锁加上互斥锁n nwhile(index=0)/while(index=0)/堆栈堆栈(duzhn)(duzhn)无数据，不能出栈无数据，不能出栈n ntry try n nthis.wait();/t

45、his.wait();/等待其它线程把数据入栈等待其它线程把数据入栈n n catch(InterruptedException e)catch(InterruptedException e)n n n n n nthis.notify();/this.notify();/通知其它线程入栈通知其它线程入栈n nindex-;/index-;/指针向下移动指针向下移动n nreturn bufferindex;/return bufferindex;/数据出栈数据出栈n n n n 第38页/共50页第三十九页，共50页。nnclass Producer implements Runnable

46、/class Producer implements Runnable /生产者类生产者类nnSyncStack theStack;SyncStack theStack;nnpublic Producer(SyncStack s)public Producer(SyncStack s)nntheStack=s;theStack=s;nn nnpublic void run()public void run()nnchar c;char c;nnfor(int i=0;i 10;i+)for(int i=0;i 10;i+)nnc=(char)(Math.random()*26+A);c=(ch

47、ar)(Math.random()*26+A);nntheStack.push(c);/theStack.push(c);/把字符把字符(z f)(z f)入栈入栈nnSystem.out.println(Produced:+c);/System.out.println(Produced:+c);/打印字符打印字符(z f)(z f)nntry try nnThread.sleep(int)(Math.random()*1000);Thread.sleep(int)(Math.random()*1000);nn catch(InterruptedException e)catch(Interr

48、uptedException e)nn nn nn nn 第39页/共50页第四十页，共50页。n nclass Consumer implements Runnable /class Consumer implements Runnable /消费者类消费者类n nSyncStack theStack;SyncStack theStack;n npublic Consumer(SyncStack s)public Consumer(SyncStack s)n ntheStack=s;theStack=s;n n n npublic void run()public void run()n n

49、char c;char c;n nfor(int i=0;i 10;i+)for(int i=0;i 10;i+)n nc=theStack.pop();/c=theStack.pop();/从堆栈从堆栈(duzhn)(duzhn)中读取字符中读取字符n nSystem.out.println(Consumed:+c);System.out.println(Consumed:+c);n ntry try n nThread.sleep(int)(Math.random()*1000);Thread.sleep(int)(Math.random()*1000);n n catch(Interru

50、ptedException e)catch(InterruptedException e)n n n n n n n n 第40页/共50页第四十一页，共50页。n npublic class ep7_7 public class ep7_7 n npublic static void main(String args)public static void main(String args)n nSyncStack stack=new SyncStack();SyncStack stack=new SyncStack();n n/下面的消费者类对象和生产者类对象所操作的是同一个同步下面的消费者