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（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。