Java实现多线程轮流打印1-100的数字操作
首先打印1-100数字如果用一个单线程实现那么只要一个for循环即可,那么如果要用两个线程打印出来呢?(一个线程打印奇数,一个线程打印偶数)于是大家会想到可以通过加锁实现,但是这样的效率是不是不高?这里我用一个变量来控制两个线程的输出
publicclassThreadTest{ volatileintflag=0; publicvoidrunThread()throwsInterruptedException{ Threadt1=newThread(newThread1()); Threadt2=newThread(newThread2()); t1.start(); t2.start(); } publicclassThread1implementsRunnable{ publicvoidrun(){ inti=0; while(i<=99){ if(flag==0) { System.out.println("t1="+i+"flag="+flag); i+=2; flag=1; } } } } publicclassThread2implementsRunnable{ publicvoidrun(){ inti=1; while(i<=99){ if(flag==1) { System.out.println("t2="+i+"flag="+flag); i+=2; flag=0; } } } } }
那么如果要实现三个线程轮流打印1-100的数字呢?是不是也可以用上面的方法实现呢?代码如下
publicclassThreadTest{ privateinti=0; privateThreadthread1,thread2,thread3; privateintflag=0; publicvoidrunThread()throwsInterruptedException{ thread1=newThread(newThread1()); thread2=newThread(newThread2()); thread3=newThread(newThread3()); thread1.start(); thread2.start(); thread3.start(); } publicclassThread1implementsRunnable{ publicvoidrun(){ while(i<=100){ if(flag==0){ System.out.println("t1="+i); i++; flag=1; } } } } publicclassThread2implementsRunnable{ publicvoidrun(){ while(i<=100){ if(flag==1){ System.out.println("t2="+i); i++; flag=2; } } } } publicclassThread3implementsRunnable{ publicvoidrun(){ while(i<=100){ if(flag==2){ System.out.println("t3="+i); i++; flag=0; } } } } }
运行结果
发现三个线程只打印了一次就停止不输出了,是什么原因呢?
可以用jdk自带的jstack来看看线程的状态,在windows系统中可以打开cmd然后进入jdk所在目录,然后执行Jsp,能查看到各线程id,然后执行jstack-Fpid就可以看的状态了
可以看到几个Threadstate是BLOCKED,就是阻塞了,什么原因呢?
尴尬发现flag变量和i变量前面忘记加volatile,导致flag和i被线程读取修改时,其他线程不可见,所以才导致上面的问题出现。
在JVM中每个线程读取变量到cache中时相互都是不可见的,也就是java五大内存区中的程序计数器区域对于每个线程都是独立的不共享的,只有堆内存区和方法区是对所有线程都是共享的。
当线程1读取了flag和i的值,并对其进行修改的时候,线程2并发运行,并不知道flag和i值已经改变,导致多线程数据不一致的情况,所以加了volatile后,当线程读取变量进行修改后会“通知”其它线程这个值已经进行了修改。
importjava.util.concurrent.atomic.AtomicInteger; publicclassThreadTest{ privatevolatileinti=0; privateThreadthread1,thread2,thread3; privatevolatileintflag=0; publicvoidrunThread()throwsInterruptedException{ thread1=newThread(newThread1()); thread2=newThread(newThread2()); thread3=newThread(newThread3()); thread1.start(); thread2.start(); thread3.start(); } publicclassThread1implementsRunnable{ publicvoidrun(){ while(i<100){ if(flag==0){ System.out.println("t1="+i); i++; flag=1; } } } } publicclassThread2implementsRunnable{ publicvoidrun(){ while(i<100){ if(flag==1){ System.out.println("t2="+i); i++; flag=2; } } } } publicclassThread3implementsRunnable{ publicvoidrun(){ while(i<100){ if(flag==2){ System.out.println("t3="+i); i++; flag=0; } } } } }
运行结果
-----未完-----
补充知识:Javan个线程轮流打印数字的问题
一、两个线程轮流打印数字。
加锁实现:
packagelianxi; /* *用锁实现两个线程轮流打印1——100 */ publicclassPrint1TO100TwoThread{ privateObjectlock=newObject(); privateinti=0; ThreadthreadA=newThread(newRunnable(){ @Override publicvoidrun(){ while(i<=100){ synchronized(lock){ try{ if(i>100) break; System.out.println("threadA:"+(i++)); lock.notify(); lock.wait(); }catch(InterruptedExceptione){ e.printStackTrace(); } } } } }); ThreadthreadB=newThread(newRunnable(){ @Override publicvoidrun(){ while(i<=100){ synchronized(lock){ try{ if(i>100) break; System.out.println("threadB:"+(i++)); lock.notify(); lock.wait(); }catch(InterruptedExceptione){ e.printStackTrace(); } } } } }); publicvoidstartTwoThread()throwsInterruptedException{ threadA.start(); Thread.sleep(20); threadB.start(); } publicstaticvoidmain(String[]args)throwsInterruptedException{ newPrint1TO100TwoThread().startTwoThread(); } }
用锁效率太低,用一个变量来控制打印的顺序。
packagelianxi; /* *用两个线程轮流打印1——10;用所实现效率太低,用变量来控制 */ publicclassPrinntNumTwoThread{ privatevolatileintnum=0; privatevolatilebooleanflag=false; ThreadthreadA=newThread(newRunnable(){ @Override publicvoidrun(){ while(true){ if(num>10) return; if(!flag){ System.out.println("threadA-->"+":"+(num++)); flag=!flag; } } } }); ThreadthreadB=newThread(newRunnable(){ @Override publicvoidrun(){ while(true){ if(num>10) return; if(flag){ System.out.println("threadB-->"+":"+(num++)); flag=!flag; } } } }); publicvoidstartTwoThread(){ threadA.start(); threadB.start(); } publicstaticvoidmain(String[]args){ newPrinntNumTwoThread().startTwoThread(); } }
二、那么如果要实现三个线程轮流打印1-100的数字呢?
packagelianxi; publicclassPrintNumThreeThread{ privatevolatileinti=0; privatevolatileintflag=0; ThreadthreadA=newThread(newRunnable(){ @Override publicvoidrun(){ while(true){ if(i>100) return; if(flag==0){ System.out.println("threadA->"+":"+(i++)); flag=1; } } } }); ThreadthreadB=newThread(newRunnable(){ @Override publicvoidrun(){ while(true){ if(i>100) return; if(flag==1){ System.out.println("threadB->"+":"+(i++)); flag=2; } } } }); ThreadthreadC=newThread(newRunnable(){ @Override publicvoidrun(){ while(true){ if(i>100) return; if(flag==2){ System.out.println("threadC->"+":"+(i++)); flag=0; } } } }); publicvoidstartThreeThread(){ threadA.start(); threadB.start(); threadC.start(); } publicstaticvoidmain(String[]args){ newPrintNumThreeThread().startThreeThread(); } }
以上这篇Java实现多线程轮流打印1-100的数字操作就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持毛票票。
声明:本文内容来源于网络,版权归原作者所有,内容由互联网用户自发贡献自行上传,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任。如果您发现有涉嫌版权的内容,欢迎发送邮件至:czq8825#qq.com(发邮件时,请将#更换为@)进行举报,并提供相关证据,一经查实,本站将立刻删除涉嫌侵权内容。