Java實現(xiàn)多線程輪流打印1-100的數(shù)字操作
更新時間：2020年08月26日 11:28:59 作者：一只菜鳥.....
這篇文章主要介紹了Java實現(xiàn)多線程輪流打印1-100的數(shù)字操作，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧
首先打印1-100數(shù)字如果用一個單線程實現(xiàn)那么只要一個for循環(huán)即可，那么如果要用兩個線程打印出來呢？（一個線程打印奇數(shù)，一個線程打印偶數(shù)）于是大家會想到可以通過加鎖實現(xiàn)，但是這樣的效率是不是不高？這里我用一個變量來控制兩個線程的輸出
public class ThreadTest {
volatile int flag=0;
public void runThread() throws InterruptedException{
Thread t1=new Thread(new Thread1());
Thread t2=new Thread(new Thread2());
t1.start();
t2.start();
}
public class Thread1 implements Runnable{
public void run() {
int i=0;
while(i<=99){
if(flag==0)
{
System.out.println("t1="+i+"flag="+flag);
i+=2;
flag=1;
}
}
}
}
public class Thread2 implements Runnable{
public void run() {
int i=1;
while(i<=99){
if(flag==1)
{
System.out.println("t2="+i+"flag="+flag);
i+=2;
flag=0;
}
}
}
}
}
那么如果要實現(xiàn)三個線程輪流打印1-100的數(shù)字呢？是不是也可以用上面的方法實現(xiàn)呢？代碼如下
public class ThreadTest {
private int i=0;
private Thread thread1,thread2,thread3;
private int flag=0;
public void runThread() throws InterruptedException{
thread1=new Thread(new Thread1());
thread2=new Thread(new Thread2());
thread3=new Thread(new Thread3());
thread1.start();
thread2.start();
thread3.start();
}
public class Thread1 implements Runnable{
public void run() {
while(i<=100){
if(flag==0) {
System.out.println("t1="+i);
i++;
flag=1;
}
}
}
}
public class Thread2 implements Runnable{
public void run() {
while(i<=100){
if(flag==1) {
System.out.println("t2="+i);
i++;
flag=2;
}
}
}
}
public class Thread3 implements Runnable{
public void run() {
while(i<=100){
if(flag==2) {
System.out.println("t3="+i);
i++;
flag=0;
}
}
}
}
}
運行結(jié)果
發(fā)現(xiàn)三個線程只打印了一次就停止不輸出了，是什么原因呢？
可以用jdk自帶的jstack來看看線程的狀態(tài)，在windows系統(tǒng)中可以打開cmd然后進(jìn)入jdk所在目錄，然后執(zhí)行Jsp，能查看到各線程id，然后執(zhí)行jstack -F pid就可以看的狀態(tài)了
可以看到幾個Thread state是BLOCKED，就是阻塞了，什么原因呢？
尷尬發(fā)現(xiàn)flag變量和i變量前面忘記加volatile，導(dǎo)致flag和i被線程讀取修改時，其他線程不可見，所以才導(dǎo)致上面的問題出現(xiàn)。
在JVM中每個線程讀取變量到cache中時相互都是不可見的，也就是java五大內(nèi)存區(qū)中的程序計數(shù)器區(qū)域?qū)τ诿總€線程都是獨立的不共享的，只有堆內(nèi)存區(qū)和方法區(qū)是對所有線程都是共享的。
當(dāng)線程1讀取了flag和i的值，并對其進(jìn)行修改的時候，線程2并發(fā)運行，并不知道flag和i值已經(jīng)改變，導(dǎo)致多線程數(shù)據(jù)不一致的情況，所以加了volatile后，當(dāng)線程讀取變量進(jìn)行修改后會“通知”其它線程這個值已經(jīng)進(jìn)行了修改。
import java.util.concurrent.atomic.AtomicInteger;
public class ThreadTest {
private volatile int i=0;
private Thread thread1,thread2,thread3;
private volatile int flag=0;
public void runThread() throws InterruptedException{
thread1=new Thread(new Thread1());
thread2=new Thread(new Thread2());
thread3=new Thread(new Thread3());
thread1.start();
thread2.start();
thread3.start();
}
public class Thread1 implements Runnable{
public void run() {
while(i<100){
if(flag==0) {
System.out.println("t1="+i);
i++;
flag=1;
}
}
}
}
public class Thread2 implements Runnable{
public void run() {
while(i<100){
if(flag==1){
System.out.println("t2="+i);
i++;
flag=2;
}
}
}
}
public class Thread3 implements Runnable{
public void run() {
while(i<100){
if(flag==2){
System.out.println("t3="+i);
i++;
flag=0;
}
}
}
}
}
運行結(jié)果
-----未完-----
補充知識：Java n個線程輪流打印數(shù)字的問題
一、兩個線程輪流打印數(shù)字。
加鎖實現(xiàn)：
package lianxi;
/*
* 用鎖實現(xiàn)兩個線程輪流打印1——100
*/
public class Print1TO100TwoThread {
private Object lock = new Object();
private int i = 0;
Thread threadA = new Thread(new Runnable() {
@Override
public void run() {
while (i <= 100) {
synchronized (lock) {
try {
if (i > 100)
break;
System.out.println("threadA :" + (i++));
lock.notify();
lock.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
});
Thread threadB = new Thread(new Runnable() {
@Override
public void run() {
while (i <= 100) {
synchronized (lock) {
try {
if (i > 100)
break;
System.out.println("threadB :" + (i++));
lock.notify();
lock.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
});
public void startTwoThread() throws InterruptedException {
threadA.start();
Thread.sleep(20);
threadB.start();
}
public static void main(String[] args) throws InterruptedException {
new Print1TO100TwoThread().startTwoThread();
}
}
用鎖效率太低，用一個變量來控制打印的順序。
package lianxi;
/*
* 用兩個線程輪流打印1——10；用所實現(xiàn)效率太低，用變量來控制
*/
public class PrinntNumTwoThread {
private volatile int num = 0;
private volatile boolean flag = false;
Thread threadA = new Thread(new Runnable() {
@Override
public void run() {
while (true) {
if (num > 10)
return;
if (!flag) {
System.out.println("threadA-->" + ":" + (num++));
flag = !flag;
}
}
}
});
Thread threadB = new Thread(new Runnable() {
@Override
public void run() {
while (true) {
if (num > 10)
return;
if (flag) {
System.out.println("threadB-->" + ":" + (num++));
flag = !flag;
}
}
}
});
public void startTwoThread() {
threadA.start();
threadB.start();
}
public static void main(String[] args) {
new PrinntNumTwoThread().startTwoThread();
}
}
二、那么如果要實現(xiàn)三個線程輪流打印1-100的數(shù)字呢？
package lianxi;
public class PrintNumThreeThread {
private volatile int i = 0;
private volatile int flag = 0;
Thread threadA = new Thread(new Runnable() {
@Override
public void run() {
while (true) {
if (i > 100)
return;
if (flag == 0) {
System.out.println("threadA->" + ":" + (i++));
flag = 1;
}
}
}
});
Thread threadB = new Thread(new Runnable() {
@Override
public void run() {
while (true) {
if (i > 100)
return;
if (flag == 1) {
System.out.println("threadB->" + ":" + (i++));
flag = 2;
}
}
}
});
Thread threadC = new Thread(new Runnable() {
@Override
public void run() {
while (true) {
if (i > 100)
return;
if (flag == 2) {
System.out.println("threadC->" + ":" + (i++));
flag = 0;
}
}
}
});
public void startThreeThread() {
threadA.start();
threadB.start();
threadC.start();
}
public static void main(String[] args) {
new PrintNumThreeThread().startThreeThread();
}
}
以上這篇Java實現(xiàn)多線程輪流打印1-100的數(shù)字操作就是小編分享給大家的全部內(nèi)容了，希望能給大家一個參考，也希望大家多多支持腳本之家。
相關(guān)文章
Java實現(xiàn)List反轉(zhuǎn)的方法總結(jié)
在Java中,反轉(zhuǎn)一個List意味著將其元素的順序顛倒,使得第一個元素變成最后一個,最后一個元素變成第一個,依此類推,這一操作在處理數(shù)據(jù)集合時非常有用,所以本文給大家總結(jié)了Java實現(xiàn)List反轉(zhuǎn)的方法,需要的朋友可以參考下2024-04-04
這篇文章主要介紹了Arrays.sort()和lambda表達(dá)式，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-12-12
這篇文章主要介紹了簡易JDBC框架實現(xiàn)過程詳解,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2020-02-02
SpringBoot基于redis自定義注解實現(xiàn)后端接口防重復(fù)提交校驗
本文主要介紹了SpringBoot基于redis自定義注解實現(xiàn)后端接口防重復(fù)提交校驗，文中通過示例代碼介紹的非常詳細(xì)，具有一定的參考價值，感興趣的小伙伴們可以參考一下2022-01-01
注解想必大家都用過，也叫元數(shù)據(jù)，是一種代碼級別的注釋，可以對類或者方法等元素做標(biāo)記說明。那么今天我想問大家的是類被繼承了，注解能否繼承呢？可能會和大家想的不一樣，感興趣的可以往下看2022-12-12
Cookie和Session都是為了保持用戶的訪問狀態(tài)，一方面為了方便業(yè)務(wù)實現(xiàn)，另一方面為了簡化服務(wù)端的程序設(shè)計。這篇文章主要介紹了java中cookie和session的知識,需要的朋友可以參考下2016-09-09
java byte與base64的互轉(zhuǎn)的實現(xiàn)示例
在項目開發(fā)中經(jīng)常用到,比如前端上送文件流(byte[])到后臺并轉(zhuǎn)成文件,本文主要介紹了java byte與base64的互轉(zhuǎn)的實現(xiàn)示例,具有一定的參考價值,感興趣的可以了解一下2024-02-02
如何在Spring?Boot中使用OAuth2認(rèn)證和授權(quán)
這篇文章主要介紹了如何在Spring?Boot中使用OAuth2認(rèn)證和授權(quán)的相關(guān)資料,OAuth2.0是一種開放的授權(quán)協(xié)議,它允許用戶授權(quán)第三方應(yīng)用訪問其賬戶(或資源),而無需共享其用戶賬戶憑據(jù),需要的朋友可以參考下2023-12-12
這篇文章主要介紹了Java 中的 File類，對于File而言，其封裝的并不是一個真正存在的文件，僅僅是一個路徑名而已，下面我們來看看文章對File類的詳情介紹吧,需要的朋友也可以參考一下2021-11-11
下面就為大家?guī)硪黄谖⑿藕灻鹲ignature獲取(實例講解)。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-09-09