Java實(shí)現(xiàn)多線程輪流打印1-100的數(shù)字操作
更新時間：2020年08月26日 11:28:59 作者：一只菜鳥.....
這篇文章主要介紹了Java實(shí)現(xiàn)多線程輪流打印1-100的數(shù)字操作，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧
首先打印1-100數(shù)字如果用一個單線程實(shí)現(xiàn)那么只要一個for循環(huán)即可，那么如果要用兩個線程打印出來呢？（一個線程打印奇數(shù)，一個線程打印偶數(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;
}
}
}
}
}
那么如果要實(shí)現(xiàn)三個線程輪流打印1-100的數(shù)字呢？是不是也可以用上面的方法實(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;
}
}
}
}
}
運(yùn)行結(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ū)中的程序計(jì)數(shù)器區(qū)域?qū)τ诿總€線程都是獨(dú)立的不共享的，只有堆內(nèi)存區(qū)和方法區(qū)是對所有線程都是共享的。
當(dāng)線程1讀取了flag和i的值，并對其進(jìn)行修改的時候，線程2并發(fā)運(yùn)行，并不知道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;
}
}
}
}
}
運(yùn)行結(jié)果
-----未完-----
補(bǔ)充知識：Java n個線程輪流打印數(shù)字的問題
一、兩個線程輪流打印數(shù)字。
加鎖實(shí)現(xiàn)：
package lianxi;
/*
* 用鎖實(shí)現(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；用所實(shí)現(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();
}
}
二、那么如果要實(shí)現(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實(shí)現(xiàn)多線程輪流打印1-100的數(shù)字操作就是小編分享給大家的全部內(nèi)容了，希望能給大家一個參考，也希望大家多多支持腳本之家。
相關(guān)文章
本文給大家分享的是一段使用java制作Android日歷的代碼，非常簡單實(shí)用，實(shí)現(xiàn)了讀取日歷事件、插入事件、編輯日歷事件、查看日歷等功能，有需要的小伙伴參考下2015-03-03
java 方法泛型入?yún)和String的重載關(guān)系詳解
這篇文章主要介紹了java 方法泛型入?yún)和String的重載關(guān)系詳解，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-02-02
Java synchronized底層的實(shí)現(xiàn)原理
這篇文章主要介紹了Java synchronized底層的實(shí)現(xiàn)原理，文章基于Java來介紹 synchronized 是如何運(yùn)行的，內(nèi)容詳細(xì)具有一定的參考價值，需要的小伙伴可以參考一下2022-05-05
這篇文章主要給大家介紹了關(guān)于java對接微信支付之JSAPI支付(微信公眾號支付)的相關(guān)資料,微信JSAPI支付是近年來非常流行的一種支付方式,它使用了微信支付的SDK和demo來實(shí)現(xiàn)支付接口的對接,需要的朋友可以參考下2023-07-07
MyBatis通用Mapper實(shí)現(xiàn)原理及相關(guān)內(nèi)容
今天小編就為大家分享一篇關(guān)于MyBatis通用Mapper實(shí)現(xiàn)原理及相關(guān)內(nèi)容，小編覺得內(nèi)容挺不錯的，現(xiàn)在分享給大家，具有很好的參考價值，需要的朋友一起跟隨小編來看看吧2018-12-12
淺談Java回收對象的標(biāo)記和對象的二次標(biāo)記過程
這篇文章主要介紹了淺談Java回收對象的標(biāo)記和對象的二次標(biāo)記過程的相關(guān)內(nèi)容，小編覺得還是挺不錯的，這里給大家分享一下，需要的朋友可以參考。2017-10-10
Java Clone深拷貝與淺拷貝的兩種實(shí)現(xiàn)方法
今天小編就為大家分享一篇關(guān)于Java Clone深拷貝與淺拷貝的兩種實(shí)現(xiàn)方法，小編覺得內(nèi)容挺不錯的，現(xiàn)在分享給大家，具有很好的參考價值，需要的朋友一起跟隨小編來看看吧2018-10-10
LeetCode?動態(tài)規(guī)劃之矩陣區(qū)域和詳情
這篇文章主要介紹了LeetCode?動態(tài)規(guī)劃之矩陣區(qū)域和詳情，文章基于Java的相關(guān)資料展開對LeetCode?動態(tài)規(guī)劃的詳細(xì)介紹，需要的小伙伴可以參考一下2022-04-04
這篇文章主要介紹了java中Date日期類型的大小比較方式，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2023-07-07
這篇文章主要介紹了Java數(shù)組添加元素的兩種方法，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友跟著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-04-04