版权说明:本文档由用户提供并上传,收益归属内容提供方,若内容存在侵权,请进行举报或认领
文档简介
第八章线程
本章导读1.Java中的线程2.线程的生命周期3.线程的优先级与调度管理4.Thread的子类创建线程5.使用Runable接口6.线程的常用方法7.线程同步8.在同步方法中使用wait()、notify和notifyAll9.线程的联合10.守护线程第八章线程本章导读18.1Java中的线程程序是一段静态的代码,它是应用软件执行的蓝本。进程是程序的一次动态执行过程,它对应了从代码加载、执行至执行完毕的一个完整过程,这个过程也是进程本身从产生、发展至消亡的过程。线程是比进程更小的执行单位。一个进程在其执行过程中,可以产生多个线程,形成多条执行线索,每条线索,即每个线程也有它自身的产生、存在和消亡的过程,也是一个动态的概念。为理解线程这个概念我们看一段程序:8.1Java中的线程程序是一段静态28.1Java中的线程ClassQution{publicstaticvoidmain(Stringargs[]){while(true){System.outprintln(“123”);}while(true){System.outprintln(“abc”);}}}第2个while是不会执行的,但将如创建两个线程Java的虚拟机会负责使俩、个线程轮流执行。8.1Java中的线程ClassQution{3
Java应用程序总是从主类的main方法开始执行。当JVM加载代码,发现main方法之后,就会启动一个线程,这个线程称作“主线程”,该线程负责执行main方法。那么,在main方法中再创建的线程,就称为主线程中的线程。如果main方法中没有创建其他的线程,那么当main方法执行完最后一个语句,即main方法返回时,JVM就会结束我们的Java应用程序。如果main方法中又创建了其他线程,那么JVM就要在主线程和其他线程之间轮流切换,保证每个线程都有机会使用CPU资源,main方法即使执行完最后的语句,JVM也不会结束我们的程序,JVM一直要等到主线程中的所有线程都结束之后,才结束我们的Java应用程序。返回Java应用程序总是从主类的main方法开48.2线程的生命周期
1.线程的4种状态在Java语言中,Thread类及其子类创建的对象称作线程,新建的线程在它的一个完整的生命周期中通常要经历4种状态,(1)新建(2)运行线程创建后仅仅是占有了内存资源,在JVM管理的线程中还没有这个线程,此线程必须调用start()方法(从父类继承的方法)通知JVM,这样JVM就会知道又有一个新一个线程排队等候切换了。8.2线程的生命周期1.线程的4种状态5
当JVM将CUP使用权切换给线程时,如果线程是Thread的子类创建的,该类中的run方法就立刻执行。所以我们必须在子类中重写父类的run方法,Thread类中的run()方法没有具体内容,程序要在Thread类的子类中重写run()方法来覆盖父类的run()方法,run方法规定了该线程的具体使命。在线程没有结束run方法之前,不要让线程再调用start方法,否则将发生ILLegalThreadStateException异常。当JVM将CUP使用权切换给线程时,如果6(3)中断有4种原因的中断:(a)JVM将CPU资源从当前线程切换给其他线程,使本线程让出CPU的使用权处于中断状态。(b)线程使用CPU资源期间,执行了sleep(intmillsecond)方法,使当前线程进入休眠状态。sleep(intmillsecond)方法是Thread类中的一个类方法,线程一旦执行了sleep(intmillsecond)方法,就立刻让出CPU的使用权,使当前线程处于中断状态。经过参数millsecond指定的豪秒数之后,该线程就重新进到线程队列中排队等待CPU资源,以便从中断处继续运行。(3)中断7(c)线程使用CPU资源期间,执行了wait()方法,使得当前线程进入等待状态。等待状态的线程不会主动进到线程队列中排队等待CPU资源,必须由其他线程调用notify()方法通知它,使得它重新进到线程队列中排队等待CPU资源,以便从中断处继续运行。有关wait、noftify和notifyAll方法将在第8节详细讨论(d)线程使用CPU资源期间,执行某个操作进入阻塞状态,比如执行读/写操作引起阻塞。进入阻塞状态时线程不能进入排队队列,只有当引起阻塞的原因消除时,线程才重新进到线程队列中排队等待CPU资源,以便从原来中断处开始继续运行。
(c)线程使用CPU资源期间,执行了wait()方法,使得当8
(4)死亡处于死亡状态的线程不具有继续运行的能力。线程死亡的原因有二,一个是正常运行的线程完成了它的全部工作,即执行完run方法中的全部语句,结束了run方法。另一个原因是线程被提前强制性地终止,即强制run方法结束。所谓死亡状态就是线程释放了实体,即释放分配给线程对象的内存。现在,我们看一个完整的例子1,通过分析运行结果阐述线程的4种状态。该例子中我们用Thread的子类:WriteWordThread创建了两个线程。(4)死亡9publicclassExample8_1{publicstaticvoidmain(Stringargs[]){WriteWordThreadzhang,wang;zhang=newWriteWordThread("张小红");//新建线程wang=newWriteWordThread("JamsKeven");//新建线程zhang.start();//启动线程for(inti=1;i<=8;i++){System.out.println("我是主线程中的语句");}wang.start();//启动线程}}publicclassExample8_1{10classWriteWordThreadextendsThread{//Thread的子类负责创建线程对象WriteWordThread(Strings){setName(s);//调用Thread类的setName方法为线程起个名字}publicvoidrun(){for(inti=1;i<=8;i++){System.out.println("我是一个线程,我的名字是"+getName());}}}Javappt课件第八章-线程11
上述程序在不同的计算机运行或在同一台计算机反复运行的结果不尽相同,输出结果依赖当前CPU资源的使用情况。为了使结果尽量不依赖于当前CPU资源的使用情况,我们应当让线程主动调用sleep方法让出CPU的使用权进入中断状态,如例子2所示:
publicclassExample8_2{publicstaticvoidmain(Stringargs[]){WriteWordThreadzhang,wang;
返回上述程序在不同的计算机运行或在同一台计算机反复运行的结12zhang=newWriteWordThread("张小红",200);//新建线程wang=newWriteWordThread("JamsKeven",100);//新建线程zhang.start();//启动线程wang.start();//启动线程}}classWriteWordThreadextendsThread{intn=0;WriteWordThread(Strings,intn){返回zhang=newWriteWordThr13
setName(s);//调用Thread类的方法setName为线程起个名字this.n=n;}publicvoidrun(){for(inti=1;i<=8;i++){System.out.println("我是一个线程,我的名字是"+getName());try{sleep(n);}catch(InterruptedExceptione){}}}}返回setName(s);//调用T148.3线程的优先级与调度管理
Java虚拟机(JVM)中的线程调度器负责管理线程,调度器把线程的优先级分为10个级别,分别用Thread类中的类常量表示。每个Java线程的优先级都在常数1:Thread.MINPRIORITY到常数10:Thread.MAX_PRIORITY的范围内。如果没有明确地设置线程的优先级别,每个线程的优先级都为常数5(包括主线程):Thread.NORM_PRIORITY,线程的优先级可以通过setPriority(intgrade)方法调整,这一方法需要一个int类型参数。如果此参数不在1~10的范围内,那么setPriority便产生一个lllegalArgumenException异常。getPriority方法返回线程的优先级。需要注意是,有些操作系统只能识别3个级别:1,5,10。返回8.3线程的优先级与调度管理Java158.4Thread的子类创建线程
在Java语言中,用Thread类或子类创建线程对象。这一节讲述怎样用Thread子类创建对象。用户可以扩展Thread类,但需要重写父类的run方法,其目的是规定线程的具体操作,否则线程就什么也不做,因为父类的run方法中没有任何操作语句。下面例子3中除主线程外还有两个线程,这两个线程分别在命令行窗口的左侧和右侧顺序地一行一行地输出字符串。主线程负责判断输出的行数,当其中任何一个线程输出8行后,就结束进程。本例题中用到了System类中的类方法:exit(intn),主线程使用该方法结束整个程序。publicclassExample8_3{publicstaticvoidmain(Stringargs[]){
返回8.4Thread的子类创建线程在J16Leftleft=newLeft();Rightright=newRight();left.start();right.start();while(true){if(left.n==8||right.n==8)System.exit(0);}}}classLeftextendsThread{intn=0;publicvoidrun(){while(true){n++;返回Leftleft=newLeft();返178.4Thread的子类创建线程System.out.printf("\n%s","我在左面写字");try{sleep((int)(Math.random()*100)+100);}catch(InterruptedExceptione){}}}}classRightextendsThread{intn=0;publicvoidrun(){返回8.4Thread的子类创建线程188.4Thread的子类创建线程while(true){n++;System.out.printf("\n%40s","我在右面写字");try{sleep((int)(Math.random()*100)+100);}catch(InterruptedExceptione){}}}}返回8.4Thread的子类创建线程whil198.5使用Runable接口
使用Thread子类创建线程的优点是:我们可以在子类中增加新的成员变量,使线程具有某种属性,也可以在子类中新增加方法,使线程具有某种功能。但是,Java不支持多继承,Thread类的子类不能再扩展其他的类。8.5使用Runable接口使用Th20
1.Runnable接口与目标对象创建线程的另一个途径就是用Thread类直接创建线程对象。使用Thread创建线程对象时,通常使用的构造方法是:Thread(Runnabletarget),该构造方法中的参数是一个Runnable类型的接口,因此,在创建线程对象时必须向构造方法的参数传递一个实现Runnable接口类的实例,该实例对象称作所创线程的目标对象,当线程调用start方法后,一旦轮到它来享用CPU资源,目标对象就会自动调用接口中的run方法(接口回调),这一过程是自动实现的,用户程序只需要让线程调用start方法即可,也就是说,当线程被调度并转入运行状态时,所执行的就是run()方法中所规定的操作。1.Runnable接口与目标对象21
线程间可以共享相同的内存单元(包括代码与数据),并利用这些共享单元实现数据的交换、实时通讯与必要的同步操作。对于thread(Runnabletarget)构造的线程使用同一目标对象的线程,目标对象的成员变量自然成为这些线程共享的数据单元。线程间可以共享相同的内存单元(包括代码与数据),22
下面的例子4中,两个线程:zhang和cheng,使用同一目标对象(Bank类对象)。两个线程共享目标对象的money。当money的值小于100时,线程zhang结束自己的run方法进入死亡状态;当money的值小于60时,线程cheng结束自己的run方法进入死亡状态。publicclassExample8_4{publicstaticvoidmain(Stringargs[]){Strings1="会计",s2="出纳";Bankbank=newBank(s1,s2);
23Threadzhang,cheng;zhang=newThread(bank);cheng=newThread(bank);//cheng和zhang是同一目标对象zhang.setName(s1);//会计cheng.setName(s2);//出纳bank.setMoney(160);//线程的目标对象修改被线程共享的moneyzhang.start();cheng.start();}}Threadzhang,cheng;24classBankimplementsRunnable{
//Bank类必须实现Runnable接口privateintmoney=0;Stringname1,name2;Bank(Strings1,Strings2){name1=s1;name2=s2;}publicvoidsetMoney(intmount){money=mount;}classBankimplementsRunnable25publicvoidrun(){//接口中的方法while(true){money=money-10;if(Thread.currentThread().getName().equals(name1)){System.out.println("我是"+name1+"现在有"+money+"元");if(money<=100){System.out.println(name1+“进入死亡状态”);return;//如果money小于100,当前线程结束run方法}}publicvoidrun(){26elseif(Thread.currentThread().getName().equals(name2)){System.out.println("我是"+name2+"现在有"+money+"元");if(money<=60){System.out.println(name2+"进入死亡状态");return;//如果money小于60,当前线程结束run方法}}elseif(Thread.curren27try{Thread.sleep(800);}catch(InterruptedExceptione){}}}}try{28
例子5中共有4个线程:threadA、threadB、threadC和threadD,其中threadA和threadB的目标对象a1,threadC和threadD的目标对象是a2。threadA和threadB共享a1的成员number,而threadC和threadD共享a2的成员number。在这种情况下threadA,和threadB共用一个全局变量number,;threadC和threadD相同。classTargetObjectimplementsRunnable{privateintnumber=0;publicvoidsetNumber(intn){number=n;}publicvoidrun(){while(true){if(Thread.currentThread().getName().equals("add")){number++;例子5中共有4个线程:threadA、threa29System.out.printf("%d\n",number);}if(Thread.currentThread().getName().equals("sub")){number--;System.out.printf("%12d\n",number);}try{Thread.sleep(1000);}catch(InterruptedExceptione){}}}}System.out.prin30publicclassExample8_5{publicstaticvoidmain(Stringargs[]){ThreadthreadA,threadB,threadC,threadD;TargetObjecta1=newTargetObject(),//线程的目标对象a2=newTargetObject();threadA=newThread(a1);//目标对象是a1的线程threadB=newThread(a1);a1.setNumber(10);threadA.setName("add");threadB.setName("add");threadC=newThread(a2);//目标对象是a2的线程publicclassExample8_5{31threadD=newThread(a2);a2.setNumber(-10);threadC.setName("sub");threadD.setName("sub");threadA.start();threadB.start();threadC.start();threadD.start();}}
threadD=newThread(a2)32
2.关于run方法中的局部变量对于具有相同目标对象的线程,当其中一个线程享用CPU资源时,目标对象自动调用接口中的run方法,当轮到另一个线程享用CPU资源时,目标对象会再次调用接口中的run方法,。不同线程的run方法中的局部变量互不干扰,一个线程改变了自己的run方法中局部变量的值不会影响其他线程的run方法中的局部变量。看例子6返回2.关于run方法中的局部变量返回33publicclassExample8_6{publicstaticvoidmain(Stringargs[]){Strings1="张三",s2="Jam.keven";Movemove=newMove(s1,s2);Threadzhang,keven;zhang=newThread(move);//共享目标对象keven=newThread(move);zhang.setName(s1);keven.setName(s2);zhang.start();keven.start();}}publicclassExample8_6{34classMoveimplementsRunnable{Strings1,s2;Move(Strings1,Strings2){this.s1=s1;this.s2=s2;}publicvoidrun(){inti=0;while(true){classMoveimplementsRunnable35if(Thread.currentThread().getName().equals(s1)){i=i+1;System.out.println(s1+"线程的局部变量:"+i);if(i>=4){System.out.println(s1+"线程进入死亡状态");if(Thread.currentTh36return;}}elseif(Thread.currentThread().getName().equals(s2)){i=i-1;System.out.println(s2+"线程的局部变量:"+i);return;37if(i<=-4){System.out.println(s2+"线程进入死亡状态");return;}}try{Thread.sleep(800);}catch(InterruptedExceptione){}}}}if(i<=-4){388.6线程的常用方法
1.start()
线程调用该方法将启动线程,使之从新建状态进入就绪队列排队,一旦轮到它来享用CPU资源时,就可以脱离创建它的主线程独立开始自己的生命周期了。2.run()Thread类的run()方法与Runnable接口中的run()方法的功能和作用相同,都用来定义线程对象被调度之后所执行的操作,都是系统自动调用而用户程序不得引用的方法。8.6线程的常用方法1.start()39
3.sleep(intmillsecond)优先级高的线程可以在它的run()方法中调用sleep方法来使自己放弃处理器资源,休眠一段时间。3.sleep(intmillsecond)40
4.isAlive()在线程的run方法结束之前,即没有进入死亡状态之前,线程调用isAlive()方法返回true,当线程进入死亡状态后(实体内存被释放),线程仍可以调用方法isAlive(),这时返回的值是false。(线程未调用start方法之前,调用isAlive()方法返回false).需要注意的是,一个已经运行的线程在没有进入死亡状态时,不要再给线程分配实体,由于线程只能引用最后分配的实体,先前的实体就会成为“垃圾”,并且不会被垃圾收集机收集掉。4.isAlive()41
现在让我们看一个例子,在下面的例子7中一个线程每隔1秒钟在命令行窗口输出机器的当前时间,在输出3秒之后,该线程又被分配了实体,新实体又开始运行。这时,我们在命令行每秒钟能看见两行当前时间,因为垃圾实体仍然在工作。publicclassExample8_7{publicstaticvoidmain(Stringargs[]){Aa=newA();a.thread.start();}}现在让我们看一个例子,在下面的例子7中一个线程每隔142classAimplementsRunnable{Threadthread;intn=0;A(){thread=newThread(this);}publicvoidrun(){classAimplementsRunnable{43while(true){n++;
System.out.println(newjava.util.Date());try{Thread.sleep(1000);}catch(InterruptedExceptione){}if(n==3){while(true){44thread=newThread(this);thread.start();}}}}
thread=newThread(this455.currentThread()currentThread()方法是Thread类中的类方法,可以用类名调用,该方法返回当前正在使用CPU资源的线程。6.interrupt()intertupt方法经常用来“吵醒”休眠的线程。当一些线程调用sleep方法处于休眠状态时,一个使用CPU资源的其它线程在执行过程中,可以让休眠的线程分别调用interrupt方法“吵醒”自己,即导致休眠的线程发生InterruptedException异常,从而结束休眠,重新排队等待CPU资源。
5.currentThread()46在下面的例子8中,有3个线程:zhangXiao、zhengMing和teacher,其中2个线程:zhangXiao和zhengMing准备休眠10秒钟后,再分别输出“早上好!”和“goodmorning!”。teacher线程在输出3句“上课”后,“吵醒”休眠的线程:zhangXiao和zhengMing。
publicclassExample8_8{publicstaticvoidmain(Stringargs[]){ClassRoomroom=newClassRoom();room.zhangXiao.start();返回在下面的例子8中,有3个线程:zhangXiao47room.zhengMing.start();room.teacher.start();}}classClassRoomimplementsRunnable{ThreadzhangXiao,zhengMing,teacher;返回room.zhengMing.start()48ClassRoom(){teacher=newThread(this);zhangXiao=newThread(this);zhangXiao.setName("张小");zhengMing=newThread(this);zhengMing.setName("郑明");teacher.setName("刘老师");}publicvoidrun(){Threadthread=Thread.currentThread();if(thread==zhangXiao||thread==zhengMing){返回ClassRoom(){返回49try{System.out.println(thread.getName()+"休息10秒后再说问候");Thread.sleep(10000);}catch(InterruptedExceptione){System.out.println(thread.getName()+"被吵醒了");返回try{返回50}System.out.println(thread.getName()+"说:早上好!");}elseif(thread==teacher){for(inti=1;i<=3;i++){System.out.println(thread.getName()+"说:\t上课!");返回}返回51
try{Thread.sleep(500);}catch(InterruptedExceptione){}}zhengMerrupt();//吵醒zhengMingzhangXerrupt();//吵醒zhangXiao}}}返回try{返回528.7线程同步两个或多个线程访问同一个变量时就要注意同步问题:
线程同步是指多个线程要执行一个synchronized修饰的方法,如果一个线程A占有CPU资源期间,使用的synchronized方法正在被调用执行,那么在该synchronized方法返回之前,即synchronized方法调用执行完毕之前,其他占有CPU资源的线程一旦调用这个synchronized方法就会引起堵塞,堵塞的线程要一直等到堵塞的原因消除(synchronized方法返回),再排队等待CPU资源,以便使用这个同步方法。8.7线程同步两个或多个线程访问同一个变量时就要53
在下面的例子9中有两个线程:accountant和cashier,他俩共同拥有一个帐本。他俩都可以使用saveOrTake(intnumber)对帐本进行访问,会计使用saveOrTake方法时,向帐本上写入存钱记录;出纳使用saveOrTake方法时,向帐本写入取钱记录。因此,当会计正在使用saveOrTake方法时,出纳被禁止使用,反之也是这样。publicclassExample8_9{publicstaticvoidmain(Stringargs[]){StringaccountantName="会计",cashierName="出纳";Bankbank=newBank(accountantName,cashierName);返回在下面的例子9中有两个线程:accountant和ca54Threadaccountant,cashier;accountant=newThread(bank);cashier=newThread(bank);accountant.setName(accountantName);cashier.setName(cashierName);accountant.start();cashier.start();}}返回Threadaccountant,cash55classBankimplementsRunnable{intmoney=300;StringaccountantName,cashierName;publicBank(Strings1,Strings2){accountantName=s1;cashierName=s2;}publicvoidrun(){saveOrTake(30);//线程占有CPU资源期间调用了同步方法}返回classBankimplementsRunnable56publicsynchronizedvoidsaveOrTake(intnumber){//同步方法if(Thread.currentThread().getName().equals(accountantName)){for(inti=1;i<=3;i++){money=money+number;返回publicsynchronizedvoidsaveO57try{Thread.sleep(1000);//存入30万稍歇一下,出纳仍不能使用该方法}catch(InterruptedExceptione){}System.out.println("我是"+accountantName+"目前帐上有"+money+"万");}}返回try{Thread.sleep(100058elseif(Thread.currentThread().getName().equals(cashierName)){for(inti=1;i<=2;i++){money=money-number/2;try{Thread.sleep(1000);}catch(InterruptedExceptione){}System.out.println("我是"+cashierName+"目前帐上有"+money+"万");}}}}
返回elseif(Thread.current598.8在同步方法中使用wait()、notify和notifyall
wait()、notify()和notifyAll()都是Object类中的final方法,被所有的类继承,且不允许重写的方法。当一个线程使用的同步方法中用到某个变量,而此变量又需要其它线程修改后才能符合本线程的需要,那么可以在同步方法中使用wait()方法。使用wait()方法可以中断方法的执行,使本线程等待,暂时让出CPU的使用权,并允许其它线程使用这个同步方法。其它线程如果在使用这个同步方法时不需要等待,那么它使用完这个同步方法的同时,应当用notifyAll()方法通知所有的由于使用这个同步方法而处于等待的线程结束等待。
8.8在同步方法中使用wait()、notify和not60
在下面的例子10中,模拟3个人排队买票,每人买1张票。售票员只有1张五元的钱,电影票五元钱一张。张某拿1张二十元的人民币排在孙某前面买票,孙某拿1张十元的人民币排在赵的前面买票,赵某拿1张五元的人民币排在最后。那么,最终的卖票次序应当是孙、赵、张。publicclassExample8_10{publicstaticvoidmain(Stringargs[]){Strings1="张三",s2="孙大名",s3="赵中堂";Cinemacanema=newCinema(s1,s2,s3);Threadzhang,sun,zhao;
返回在下面的例子10中,模拟3个人排队买票,每61
zhang=newThread(canema);sun=newThread(canema);zhao=newThread(canema);zhang.setName(s1);sun.setName(s2);zhao.setName(s3);zhang.start();sun.start();zhao.start();}}classCinemaimplementsRunnable{//实现Runnable接口的类(电影院)TicketSellerseller;//电影院的售票员返回zhang=newThread(canem62Stringname1,name2,name3;//买票人的名字(线程的名字)Cinema(Strings1,Strings2,Strings3){seller=newTicketSeller();name1=s1;name2=s2;name3=s3;}publicvoidrun(){if(Thread.currentThread().getName().equals(name1)){返回Stringname1,name2,name3;63seller.sellTicket(20);}elseif(Thread.currentThread().getName().equals(name2)){seller.sellTicket(10);}elseif(Thread.currentThread().getName().equals(name3)){seller.sellTicket(5);}}}返回seller.sellTicket(2064classTicketSeller{//负责卖票的类intfiveNumber=1,tenNumber=0,twentyNumber=0;publicsynchronizedvoidsellTicket(intreceiveMoney){Strings=Thread.currentThread().getName();if(receiveMoney==5){fiveNumber=fiveNumber+1;System.out.println(s+"给售票员5元钱,售票员卖给"+s+"一张票,不必找赎");}elseif(receiveMoney==10){返回classTicketSeller{//负责65while(fiveNumber<1){try{System.out.println(s+"给售票员10元钱");System.out.println("售票员请"+s+"靠边等一会");wait();//如果线程占有CPU期间执行了wait(),就进入中断状态System.out.println(s+"结束等待,继续买票");}catch(InterruptedExceptione){}}fiveNumber=fiveNumber-1;tenNumber=tenNumber+1;返回while(fiveNumber<1)66System.out.println(s+"给售票员10元钱,售票员卖给"+s+"一张票,找赎5元");}elseif(receiveMoney==20){while(fiveNumber<1||tenNumber<1){try{System.out.println(s+"给售票员20元钱");System.out.println("售票员请"+s+"靠边等一会");wait();//如果线程占有CPU期间执行了wait(),就进入中断状态System.out.println(s+"结束等待,继续买票");}catch(InterruptedExceptione){}返回System.out.println(67}fiveNumber=fiveNumber-1;tenNumber=tenNumber-1;twentyNumber=twentyNumber+1;System.out.println(s+"给售票员20元钱,售票员卖给"+s+"一张票,找赎15元");}notifyAll();}}
返回}返回688.9挂起、恢复和终止线程挂起:有时候两个线程,不涉及需要调用同一个同步方法,但线程也可能需要临时停止,即所谓挂起一个线程,就是暂时让出CPU的使用权,暂时停止执行,但停止的时间不确定,不能使用sleep方法,停止线程。线程如果有目标对象,那么当前线程在占用CPU期间,只要调用wait()方法流可以挂起一个线程。为了恢复这个挂起的线程,其它线程在占有CPU资源期间让挂起线程的目标对象在同步方法中调用notifyAll();方法即可。8.9挂起、恢复和终止线程挂起:有时候两个线程,不涉及需698.9挂起、恢复和终止线程线程如果没有目标对象(用thread子类创建的线程)那么当前线程在占用CPU期间,只要在某个同步方法中调用wait()方法就可以挂起一个线程。恢复线程只需调用notifyAll()即可。终止线程只需结束run()方法即可。8.9挂起、恢复和终止线程线程如果没有目标对象(用thr708.9挂起、恢复和终止线程在下面的例子11中,线程thread每隔一秒钟输出一个整数,输出3个整数后,该线程挂起;主线程负责恢复thread线程继续执行。publicclassExample8_11{publicstaticvoidmain(Stringargs[]){Atarget=newA();//线程thread的目标对象Threadthread=newThread(target);8.9挂起、恢复和终止线程在下面的例子11中,线程thr718.9挂起、恢复和终止线程thread.setName("张三");thread.start();while(target.getStop()==false){}System.out.println("我是主线程,负责恢复"+thread.getName()+"线程");target.restart();//恢复thread线程}}8.9挂起、恢复和终止线程thread.728.9挂起、恢复和终止线程classAimplementsRunnable{intnumber=0;booleanstop=false;booleangetStop(){8.9挂起、恢复和终止线程738.9挂起、恢复和终止线程returnstop;}publicvoidrun(){while(true){number++;System.out.println(Thread.currentThread().getName()+"的number="+number);8.9挂起、恢复和终止线程ret748.9挂起、恢复和终止线程if(number==3){try{System.out.println(Thread.currentThread().getName()+"被挂起");stop=true;hangUP();//挂起线程System.out.println(Thread.currentThread().getName()+"恢复执行");8.9挂起、恢复和终止线程if(758.9挂起、恢复和终止线程}catch(Exceptione){}}try{Thread.sleep(1000);}catch(Exceptione){}8.9挂起、恢复和终止线程768.9挂起、恢复和终止线程}}publicsynchronizedvoidhangUP()throwsInterruptedException{wait();}8.9挂起、恢复和终止线程}778.9挂起、恢复和终止线程publicsynchronizedvoidrestart(){notifyAll();}}对于用Thread的子类创建的对象的线程:面的例子12中,thread是用Thread的子类创建的对象,每隔一秒钟输出一个整数,输出3个整数后,该线程挂起。主线程负责恢复thread线程继续执行。8.9挂起、恢复和终止线程publicsync78publicclassExample8_12{publicstaticvoidmain(Stringargs[]){MyThreadthread=newMyThread();thread.setName("张三");thread.start();while(thread.getStop()==false){}System.out.println("我是主线程,负责恢复"+thread.getName()+"线程");thread.restart();//恢复thread线程}}publicclassExample8_12{79classMyThreadextendsThread{intnumber=0;booleanstop=false;booleangetStop(){returnstop;}publicvoidrun(){while(true){number++;System.out.println(Thread.currentThread().getName()+"的number="+number);classMyThreadextendsThread{80if(number==3){try{System.out.println(Thread.currentThread().getName()+"被挂起");stop=true;hangUP();//挂起线程System.out.println(Thread.currentThread().getName()+"恢复执行");}catch(Exceptione){}}try{Thread.sleep(1000);}if(number==3){81catch(Exceptione){}}}publicsynchronizedvoidhangUP()throwsInterruptedException{wait();}publicsynchronizedvoidrestart(){notifyAll();}}catch(Exceptione){828.10线程联合一个线程A在占有CPU资源期间,可以让其它线程调用join()和本线程联合,如:B.join();我们称A在运行期间联合了B。如果线程A在占有CPU资源期间一旦联合B线程,那么A线程将立刻中断执行,一直等到它联合的线程B执行完毕,A线程再重新排队等待CPU资源,以便恢复执行。如果A准备联合的B线程已经结束,那么B.join()不会产生任何效果。在下面的例子13中,一个线程在运行期间联合了另外一个线程。返回8.10线程联合一个线程A在占有CPU资源83publicclassExample8_13{publicstaticvoidmain(Stringargs[]){JoinThreada=newJoinThread();a.threadA.start();}}classJoinThreadimplementsRunnable{ThreadthreadA,threadB;Stringcontent[]={"今天晚上,","大家不要","回去的太早,","还有工作","需要大家做!"};publicclassExample8_13{84JoinThread(){threadA=newThread(this);threadB=newThread(this);threadB.setName("经理");}publicvoidrun(){if(Thread.currentThread()==threadA){System.out.println("我等"+threadB.getName()+"说完再说话");threadB.start();JoinThread(){85while(threadB.isAlive()==false){}try{threadB.join();//线程threadA开始等待threadB结束}catch(InterruptedExceptione){}System.out.printf("\n我开始说话:\"我明白你的意思了,谢谢\"");}elseif(Thread.currentThread()==threadB){System.out.println(threadB.getName()+"说:");for(inti=0;i<content.length;i++){while(threadB.isAl86System.out.print(content[i]);try{threadB.sleep(1000);}catch(InterruptedExceptione){}}}}}System.out.prin878.10守护线程
一个线程调用voidsetDaemon(booleanon)方法可以将自己设置成一个守护(Daemon)线程,例如:thread.setDaemon(true);线程默认是非守护线程,非守护线程也称作用户(user)线程。当程序中的所有用户线程都已结束运行时,即使守护线程的run方法中还有需要执行的语句,守护线程也立刻结束运行。一般地,用守护线程做一些不是很严格的工作,线程的随时结束不会产生什么不良的后果。一个线程必须在运行之前设置自己是否是守护线程。下面的例子14中有一个守护线程返回8.10守护线程一个线程调用返回88classDaemonimplementsRunnable{ThreadA,B;Daemon(){A=newThread(this);B=newThread(this);}publicvoidrun(){if(Thread.currentThread()==A){classDaemonimplementsRunnab89for(inti=0;i<8;i++){
温馨提示
- 1. 本站所有资源如无特殊说明,都需要本地电脑安装OFFICE2007和PDF阅读器。图纸软件为CAD,CAXA,PROE,UG,SolidWorks等.压缩文件请下载最新的WinRAR软件解压。
- 2. 本站的文档不包含任何第三方提供的附件图纸等,如果需要附件,请联系上传者。文件的所有权益归上传用户所有。
- 3. 本站RAR压缩包中若带图纸,网页内容里面会有图纸预览,若没有图纸预览就没有图纸。
- 4. 未经权益所有人同意不得将文件中的内容挪作商业或盈利用途。
- 5. 人人文库网仅提供信息存储空间,仅对用户上传内容的表现方式做保护处理,对用户上传分享的文档内容本身不做任何修改或编辑,并不能对任何下载内容负责。
- 6. 下载文件中如有侵权或不适当内容,请与我们联系,我们立即纠正。
- 7. 本站不保证下载资源的准确性、安全性和完整性, 同时也不承担用户因使用这些下载资源对自己和他人造成任何形式的伤害或损失。
最新文档
- 健康主题新媒体运营方案
- 家居设计公司运营方案
- 丰收直播运营方案
- 加油站公司运营模式方案
- 画廊空间运营方案
- 烘焙店线上运营渠道方案
- 谷雨的运营推广方案
- 防水品牌运营方案
- 安全生产监督管理要严格落实 一岗一责
- 2025年化妆品行业经济效益评估方案
- 联合办公协议书范本
- 三年级寒假阅读与写作专项提高资料汇编
- 高考地理一轮复习课件运用水循环环节及其影响因素分析相关现象++
- 深度学习及其应用-复旦大学中国大学mooc课后章节答案期末考试题库2023年
- 人像摄影的造型技巧课件
- 抖音生活服务平台通案
- 广东工商职业技术大学辅导员考试真题2022
- 中考初中生物总复习消化系统循环系统呼吸系统泌尿系统复习课件
- 国家开放大学《应用概率统计》综合作业1-4参考答案
- YY/T 0681.4-2010无菌医疗器械包装试验方法第4部分:染色液穿透法测定透气包装的密封泄漏
- JJG 7-2004直角尺
评论
0/150
提交评论