欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

java多線程累加計數(shù)的實現(xiàn)方法

 更新時間:2021年05月20日 11:00:44   作者:安迪爸爸  
在多線程協(xié)作任務(wù)中,如何計算也是很重的,這篇文章主要介紹了java多線程累加計數(shù)的實現(xiàn)方法,感興趣的朋友可以了解一下

題目

給定count=0;讓5個線程并發(fā)累加到1000;

思路

  • 創(chuàng)建一個類MyRunnable,實現(xiàn)Runnable(繼承Thread類也可)
  • 定義一個公共變量count(初始值為0),5個線程都可以訪問到;
  • 創(chuàng)建5個線程并發(fā)遞增count到1000;

注意

這塊注意Thread和Runnable類的區(qū)別,Thread類是線程類,可以直接new Thread().start運行。而Runnable類是任務(wù)類,需要一個線程來承載任務(wù),通過new Thread(new Runnable()).start()來運行任務(wù)。

方法

方法一

將count公共變量放到測試類Test的類成員變量里,將MyRunnable類作為Test類的內(nèi)部類,在Test類的main方法里創(chuàng)建5個線程,實現(xiàn)累加。

代碼

public class Test {
 //公共變量
 int count=0;
 public static void main(String[] args){
  //new一個實現(xiàn)Runnable的類
  Test test=new Test();
  //創(chuàng)建5個任務(wù)
  MyRunnable myRunnable1=test.new MyRunnable();
  MyRunnable myRunnable2=test.new MyRunnable();
  MyRunnable myRunnable3=test.new MyRunnable();
  MyRunnable myRunnable4=test.new MyRunnable();
  MyRunnable myRunnable5=test.new MyRunnable();
  //創(chuàng)建5個線程
  new Thread(myRunnable1).start();
  new Thread(myRunnable2).start();
  new Thread(myRunnable3).start();
  new Thread(myRunnable4).start();
  new Thread(myRunnable5).start();
 }
 //創(chuàng)建一個實現(xiàn)Runnable的類
 class MyRunnable implements Runnable{
  public void run() {
   while(true){
    //鎖住的是整個MyRunnable類
    synchronized(MyRunnable.class){
     if(count>=1000){
      break;
     }
     System.out.println(Thread.currentThread().getName()+":count:"+(++count));
     //測試時,線程更容易切換
     Thread.yield();
    }    
   }
  }  
 } 
}

方法二
以上代碼沒有問題,成功實現(xiàn)5個線程累加count到1000,接下來我們將上邊代碼稍作修改。

  • 將5個線程執(zhí)行5個任務(wù),修改為5個線程執(zhí)行同一任務(wù)。
  • 將synchronized(MyRunnable.class)修改為synchronized(this)

代碼

public class Test {
 //公共變量
 int count=0;
 public static void main(String[] args){
  //new一個實現(xiàn)Runnable的類
  Test test=new Test();
  //創(chuàng)建1個任務(wù)
  MyRunnable myRunnable1=test.new MyRunnable();
//  MyRunnable myRunnable2=test.new MyRunnable();
//  MyRunnable myRunnable3=test.new MyRunnable();
//  MyRunnable myRunnable4=test.new MyRunnable();
//  MyRunnable myRunnable5=test.new MyRunnable();
  //創(chuàng)建5個線程
  for(int i=0;i<4;i++){
   new Thread(myRunnable1).start();
  }
//  new Thread(myRunnable2).start();
//  new Thread(myRunnable3).start();
//  new Thread(myRunnable4).start();
//  new Thread(myRunnable5).start();
 }
 //創(chuàng)建一個實現(xiàn)Runnable的類
 class MyRunnable implements Runnable{
  public void run() {
   while(true){
    //鎖住的是同一對象
    synchronized(this){
     if(count>=1000){
      break;
     }
     System.out.println(Thread.currentThread().getName()+":count:"+(++count));
     //測試時,線程更容易切換
     Thread.yield();
    }
    
   }
  }  
 }
}

以上代碼沒有問題,成功實現(xiàn)5個線程累加count到1000。 

雖然結(jié)果是一樣的,但是代碼實現(xiàn)是不一樣的,代碼一是創(chuàng)建了5個MyRunnable對象,代碼二只創(chuàng)建了1個MyRunnable對象??紤]并發(fā)時用到的鎖就是不一樣的,

代碼一和代碼二雖然synchronized中的鎖不同,但目的都是為了括號中的鎖是恒定不變的。

  • synchronized(this)代表鎖是this對象,代碼二中之所以可以使用this,是因為幾個線程使用的this都是同一個對象。
  • synchronized(MyRunnable.class)代表鎖是MyRunnable.class.this,因為MyRunnable.class.this是類加載到靜態(tài)方法區(qū)中,是一直存在不變的,代碼一中可以使用,當(dāng)然代碼二也可以這樣寫。
  • 代碼一和代碼二可以使用更通用的方式就是專門new一個鎖對象,這個鎖對象可以放在類成員變量里,加上static就可以一直常存。如定義成public static Object lock=new Object();代碼一和代碼二都可以使用synchronized(lock)來加鎖。synchronized(this)這種方式主要是因為書寫方便。

方法三

使用AtomicInteger類,來實現(xiàn)多線程累加,AtomicInteger類是線程安全的,使用它的優(yōu)點就是我們不需要在代碼里寫Synchronized關(guān)鍵字了,這些事都交給它去做了。

代碼

public class Test {
    static CountDownLatch cdl=new CountDownLatch(1000);;
    static AtomicInteger ai=new AtomicInteger(0);
    public static void main(String[] args) throws InterruptedException{ 
     ExecutorService exec=Executors.newFixedThreadPool(100);
       for (int i = 0; i < 1000; i++) {
        exec.execute(new Runnable() {
    @Override
    public void run() {
     System.out.println(Thread.currentThread().getName()+":"+ai.getAndIncrement());
     cdl.countDown();
    }
   });
          }
     cdl.await();
     System.out.println(ai.get());
     exec.shutdown();
    } 
}

代碼中用到了CountDownLatch類,用法就是給其設(shè)定一個初始值1000,然后在不同線程中執(zhí)行countDown方法,每執(zhí)行一次,初始值-1,await方法就是等初始值減到0時,停止等待,否則一直等待。

我在代碼里新建了100個線程來并發(fā)累加,讓我們看下最后結(jié)果。

控制臺輸出如下:

可以看到雖然輸出不是按照順序輸出的,但是最后的結(jié)果是我們想要的結(jié)果,沒有出現(xiàn)重復(fù)值的情況。

總結(jié)

這到題目只是舉了一個多線程的例子,以及鎖的簡單知識。在實際應(yīng)用中,從0累加到1000用多線程是沒有意義的。因為根本不會比單線程快。就像讓一個人數(shù)數(shù),從0數(shù)到1000,或者讓5個人接替數(shù)到1000,應(yīng)該一個人更快點吧,5個人還要考慮配合的問題。但假如這5個人都是磕巴(口語不好),一個人每讀一個數(shù)都要停頓1秒,但是讓5個人協(xié)作,省去中間的等待時間,才是多線程應(yīng)用的真正意義。
多線程的真正應(yīng)用應(yīng)該是,任務(wù)中有等待的時間,這個等待時間如果交給一個線程做就堵塞在這塊了。如果交由多個線程去做,會充分利用等待時間,去做其他事情。這才是多線程的意思。在我們?nèi)粘9ぷ髦校馡O,網(wǎng)絡(luò),圖片處理等,有些地方都是需要等待的,這幾塊用多線程,可能會提高效率。

當(dāng)然,也有一種情況,比如多個用戶訪問后臺接口,每個用戶訪問其實都是一個單獨的線程,假如想計算累計有多少次訪問的話,就需要用到多線程累加。

同類型文章

感興趣的也可以參考我的另外一篇文章,多線程計算數(shù)組之和。

參考資料

深入理解synchronized(synchronized鎖住的是代碼還是對象)

深入理解java并發(fā)之sychronized實現(xiàn)原理

java中Sychronized用法

到此這篇關(guān)于java多線程累加計數(shù)的實現(xiàn)方法的文章就介紹到這了,更多相關(guān)java多線程累加計數(shù)內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • Java多線程并發(fā)的指令重排序問題及volatile寫屏障原理詳解

    Java多線程并發(fā)的指令重排序問題及volatile寫屏障原理詳解

    這篇文章主要介紹了Java多線程并發(fā)的指令重排序問題及volatile寫屏障原理詳解,指令重排序是編譯器或處理器為了提高性能而對指令執(zhí)行順序進行重新排列的優(yōu)化技術(shù),需要的朋友可以參考下
    2024-01-01
  • Java static(靜態(tài)變量)和私有化功能與用法分析

    Java static(靜態(tài)變量)和私有化功能與用法分析

    這篇文章主要介紹了Java static(靜態(tài)變量)和私有化功能與用法,結(jié)合具體實例形式分析了Java static(靜態(tài)變量)和私有化的相關(guān)概念、原理、使用方法及操作注意事項,需要的朋友可以參考下
    2019-07-07
  • 如何使用NSSM將jar包打成Windows服務(wù)

    如何使用NSSM將jar包打成Windows服務(wù)

    這篇文章主要介紹了如何使用NSSM將jar包打成Windows服務(wù),本文通過圖文并茂的形式給大家介紹的非常詳細(xì),感興趣的朋友跟隨小編一起看看吧
    2024-03-03
  • springboot+vue實現(xiàn)阿里云oss上傳的示例代碼

    springboot+vue實現(xiàn)阿里云oss上傳的示例代碼

    文件上傳是常用的功能,本文主要介紹了springboot+vue實現(xiàn)阿里云oss上傳的示例代碼,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2024-06-06
  • Java Servlet線程中AsyncContext異步處理Http請求

    Java Servlet線程中AsyncContext異步處理Http請求

    這篇文章主要介紹了Java Servlet線程中AsyncContext異步處理Http請求及在業(yè)務(wù)中應(yīng)用,AsyncContext是Servlet 3.0使Servlet 線程不再需要一直阻塞,直到業(yè)務(wù)處理完畢才能再輸出響應(yīng),最后才結(jié)束該Servlet線程
    2023-03-03
  • Java的HashSet源碼詳解

    Java的HashSet源碼詳解

    這篇文章主要介紹了Java的HashSet源碼詳解,HashSet底層封裝的是HashMap,所以元素添加會放到HashMap的key中,value值使用new Object對象作為value,所以HashSet和HashMap的所具有的特點是類似的,需要的朋友可以參考下
    2023-09-09
  • SpringBoot配置發(fā)送Email的示例代碼

    SpringBoot配置發(fā)送Email的示例代碼

    本篇文章主要介紹了SpringBoot配置發(fā)送Email的示例代碼,小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2017-07-07
  • idea同時編輯多行問題-win&mac都支持

    idea同時編輯多行問題-win&mac都支持

    這篇文章主要介紹了idea同時編輯多行問題-win&mac都支持,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
    2023-09-09
  • Kotlin中的抽象類實現(xiàn)

    Kotlin中的抽象類實現(xiàn)

    這篇文章主要介紹了Kotlin中的抽象類實現(xiàn),文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2019-11-11
  • java局域網(wǎng)聊天小程序

    java局域網(wǎng)聊天小程序

    這篇文章主要為大家詳細(xì)介紹了java局域網(wǎng)聊天小程序,文中示例代碼介紹的非常詳細(xì),具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2019-01-01

最新評論