日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時間:8:30-17:00
你可能遇到了下面的問題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
Java 多線程同步的五種方法

一、引言

嵐縣網(wǎng)站建設(shè)公司成都創(chuàng)新互聯(lián)公司,嵐縣網(wǎng)站設(shè)計制作,有大型網(wǎng)站制作公司豐富經(jīng)驗。已為嵐縣成百上千家提供企業(yè)網(wǎng)站建設(shè)服務(wù)。企業(yè)網(wǎng)站搭建\成都外貿(mào)網(wǎng)站建設(shè)公司要多少錢,請找那個售后服務(wù)好的嵐縣做網(wǎng)站的公司定做!

前幾天面試,被大師虐殘了,好多基礎(chǔ)知識必須得重新拿起來啊。閑話不多說,進入正題。

二、為什么要線程同步

因為當我們有多個線程要同時訪問一個變量或?qū)ο髸r,如果這些線程中既有讀又有寫操作時,就會導(dǎo)致變量值或?qū)ο蟮臓顟B(tài)出現(xiàn)混亂,從而導(dǎo)致程序異常。舉 個例子,如果一個銀行賬戶同時被兩個線程操作,一個取100塊,一個存錢100塊。假設(shè)賬戶原本有0塊,如果取錢線程和存錢線程同時發(fā)生,會出現(xiàn)什么結(jié)果 呢?取錢不成功,賬戶余額是100.取錢成功了,賬戶余額是0.那到底是哪個呢?很難說清楚。因此多線程同步就是要解決這個問題。

三、不同步時的代碼

 
 
  1. Bank.java 
  2.  
  3. package threadTest;  
  4.  
  5. /** 
  6. * @author ww 
  7. */  
  8. public class Bank {  
  9.  
  10.     private int count =0;//賬戶余額  
  11.  
  12.     //存錢  
  13.     public  void addMoney(int money){  
  14.         count +=money;  
  15.         System.out.println(System.currentTimeMillis()+"存進:"+money);  
  16.     }  
  17.  
  18.     //取錢  
  19.     public  void subMoney(int money){  
  20.         if(count-money < 0){  
  21.             System.out.println("余額不足");  
  22.             return;  
  23.         }  
  24.         count -=money;  
  25.         System.out.println(+System.currentTimeMillis()+"取出:"+money);  
  26.     }  
  27.  
  28.     //查詢  
  29.     public void lookMoney(){  
  30.         System.out.println("賬戶余額:"+count);  
  31.     }  
  32.  
  33. SyncThreadTest.java 
  34.  
  35. package threadTest;  
  36.  
  37. public class SyncThreadTest {  
  38.  
  39.     public static void main(String args[]){  
  40.         final Bank bank=new Bank();  
  41.  
  42.         Thread tadd=new Thread(new Runnable() {  
  43.  
  44.             @Override  
  45.             public void run() {  
  46.                 // TODO Auto-generated method stub  
  47.                 while(true){  
  48.                     try {  
  49.                         Thread.sleep(1000);  
  50.                     } catch (InterruptedException e) {  
  51.                         // TODO Auto-generated catch block  
  52.                         e.printStackTrace();  
  53.                     }  
  54.                     bank.addMoney(100);  
  55.                     bank.lookMoney();  
  56.                     System.out.println("\n");  
  57.  
  58.                 }  
  59.             }  
  60.         });  
  61.  
  62.         Thread tsub = new Thread(new Runnable() {  
  63.  
  64.             @Override  
  65.             public void run() {  
  66.                 // TODO Auto-generated method stub  
  67.                 while(true){  
  68.                     bank.subMoney(100);  
  69.                     bank.lookMoney();  
  70.                     System.out.println("\n");  
  71.                     try {  
  72.                         Thread.sleep(1000);  
  73.                     } catch (InterruptedException e) {  
  74.                         // TODO Auto-generated catch block  
  75.                         e.printStackTrace();  
  76.                     }     
  77.                 }  
  78.             }  
  79.         });  
  80.         tsub.start();  
  81.  
  82.         tadd.start();  
  83.     }  
  84.  

代碼很簡單,我就不解釋了,看看運行結(jié)果怎樣呢?截取了其中的一部分,是不是很亂,有寫看不懂。

余額不足 
賬戶余額:0

余額不足 
賬戶余額:100

1441790503354存進:100 
賬戶余額:100

1441790504354存進:100 
賬戶余額:100

1441790504354取出:100 
賬戶余額:100

1441790505355存進:100 
賬戶余額:100

1441790505355取出:100 
賬戶余額:100

四、使用同步時的代碼

(1)同步方法:

即有synchronized關(guān)鍵字修飾的方法。 由于java的每個對象都有一個內(nèi)置鎖,當用此關(guān)鍵字修飾方法時,內(nèi)置鎖會保護整個方法。在調(diào)用該方法前,需要獲得內(nèi)置鎖,否則就處于阻塞狀態(tài)。

修改后的Bank.java

再看看運行結(jié)果:

余額不足 
賬戶余額:0

余額不足 
賬戶余額:0

1441790837380存進:100 
賬戶余額:100

1441790838380取出:100 
賬戶余額:0 
1441790838380存進:100 
賬戶余額:100

1441790839381取出:100 
賬戶余額:0

瞬間感覺可以理解了吧。

注: synchronized關(guān)鍵字也可以修飾靜態(tài)方法,此時如果調(diào)用該靜態(tài)方法,將會鎖住整個類

(2)同步代碼塊

即有synchronized關(guān)鍵字修飾的語句塊。被該關(guān)鍵字修飾的語句塊會自動被加上內(nèi)置鎖,從而實現(xiàn)同步

Bank.java代碼如下:

 
 
  1. package threadTest;  
  2.  
  3. /** 
  4. * @author ww 
  5. */  
  6. public class Bank {  
  7.  
  8.     private int count =0;//賬戶余額  
  9.  
  10.     //存錢  
  11.     public   void addMoney(int money){  
  12.  
  13.         synchronized (this) {  
  14.             count +=money;  
  15.         }  
  16.         System.out.println(System.currentTimeMillis()+"存進:"+money);  
  17.     }  
  18.  
  19.     //取錢  
  20.     public   void subMoney(int money){  
  21.  
  22.         synchronized (this) {  
  23.             if(count-money < 0){  
  24.                 System.out.println("余額不足");  
  25.                 return;  
  26.             }  
  27.             count -=money;  
  28.         }  
  29.         System.out.println(+System.currentTimeMillis()+"取出:"+money);  
  30.     }  
  31.  
  32.     //查詢  
  33.     public void lookMoney(){  
  34.         System.out.println("賬戶余額:"+count);  
  35.     }  

運行結(jié)果如下:

余額不足 
賬戶余額:0

1441791806699存進:100 
賬戶余額:100

1441791806700取出:100 
賬戶余額:0

1441791807699存進:100 
賬戶余額:100

效果和方法一差不多。

注:同步是一種高開銷的操作,因此應(yīng)該盡量減少同步的內(nèi)容。通常沒有必要同步整個方法,使用synchronized代碼塊同步關(guān)鍵代碼即可。

(3)使用特殊域變量(Volatile)實現(xiàn)線程同步

a.volatile關(guān)鍵字為域變量的訪問提供了一種免鎖機制
b.使用volatile修飾域相當于告訴虛擬機該域可能會被其他線程更新
c.因此每次使用該域就要重新計算,而不是使用寄存器中的值
d.volatile不會提供任何原子操作,它也不能用來修飾final類型的變量

Bank.java代碼如下:

 
 
  1. package threadTest;  
  2.  
  3. /** 
  4. * @author ww 
  5. */  
  6. public class Bank {  
  7.  
  8.     private volatile int count = 0;// 賬戶余額  
  9.  
  10.     // 存錢  
  11.     public void addMoney(int money) {  
  12.  
  13.         count += money;  
  14.         System.out.println(System.currentTimeMillis() + "存進:" + money);  
  15.     }  
  16.  
  17.     // 取錢  
  18.     public void subMoney(int money) {  
  19.  
  20.         if (count - money < 0) {  
  21.             System.out.println("余額不足");  
  22.             return;  
  23.         }  
  24.         count -= money;  
  25.         System.out.println(+System.currentTimeMillis() + "取出:" + money);  
  26.     }  
  27.  
  28.     // 查詢  
  29.     public void lookMoney() {  
  30.         System.out.println("賬戶余額:" + count);  
  31.     }  

運行效果怎樣呢?

余額不足 
賬戶余額:0

余額不足 
賬戶余額:100

1441792010959存進:100 
賬戶余額:100

1441792011960取出:100 
賬戶余額:0

1441792011961存進:100 
賬戶余額:100

是不是又看不懂了,又亂了。這是為什么呢?就是因為volatile不能保證原子操作導(dǎo)致的,因此volatile不能代替 synchronized。此外volatile會組織編譯器對代碼優(yōu)化,因此能不使用它就不適用它吧。它的原理是每次要線程要訪問volatile修飾 的變量時都是從內(nèi)存中讀取,而不是存緩存當中讀取,因此每個線程訪問到的變量值都是一樣的。這樣就保證了同步。

(4)使用重入鎖實現(xiàn)線程同步

在JavaSE5.0中新增了一個java.util.concurrent包來支持同步。ReentrantLock類是可重入、互斥、實現(xiàn)了Lock接口的鎖, 它與使用synchronized方法和快具有相同的基本行為和語義,并且擴展了其能力。
ReenreantLock類的常用方法有:
ReentrantLock() : 創(chuàng)建一個ReentrantLock實例
lock() : 獲得鎖
unlock() : 釋放鎖
注:ReentrantLock()還有一個可以創(chuàng)建公平鎖的構(gòu)造方法,但由于能大幅度降低程序運行效率,不推薦使用
Bank.java代碼修改如下:

 
 
  1. package threadTest;  
  2.  
  3. import java.util.concurrent.locks.Lock;  
  4. import java.util.concurrent.locks.ReentrantLock;  
  5.  
  6. /** 
  7. * @author ww 
  8. */  
  9. public class Bank {  
  10.  
  11.     private  int count = 0;// 賬戶余額  
  12.  
  13.     //需要聲明這個鎖  
  14.     private Lock lock = new ReentrantLock();  
  15.  
  16.     // 存錢  
  17.     public void addMoney(int money) {  
  18.         lock.lock();//上鎖  
  19.         try{  
  20.         count += money;  
  21.         System.out.println(System.currentTimeMillis() + "存進:" + money);  
  22.  
  23.         }finally{  
  24.             lock.unlock();//解鎖  
  25.         }  
  26.     }  
  27.  
  28.     // 取錢  
  29.     public void subMoney(int money) {  
  30.         lock.lock();  
  31.         try{  
  32.  
  33.         if (count - money < 0) {  
  34.             System.out.println("余額不足");  
  35.             return;  
  36.         }  
  37.         count -= money;  
  38.         System.out.println(+System.currentTimeMillis() + "取出:" + money);  
  39.         }finally{  
  40.             lock.unlock();  
  41.         }  
  42.     }  
  43.  
  44.     // 查詢  
  45.     public void lookMoney() {  
  46.         System.out.println("賬戶余額:" + count);  
  47.     }  

運行效果怎么樣呢?

余額不足 
賬戶余額:0

余額不足 
賬戶余額:0

1441792891934存進:100 
賬戶余額:100

1441792892935存進:100 
賬戶余額:200

1441792892954取出:100 
賬戶余額:100

效果和前兩種方法差不多。

如果synchronized關(guān)鍵字能滿足用戶的需求,就用synchronized,因為它能簡化代碼 。如果需要更高級的功能,就用ReentrantLock類,此時要注意及時釋放鎖,否則會出現(xiàn)死鎖,通常在finally代碼釋放鎖

(5)使用局部變量實現(xiàn)線程同步

Bank.java代碼如下:

 
 
  1. package threadTest;  
  2.  
  3. /** 
  4. * @author ww 
  5. */  
  6. public class Bank {  
  7.  
  8.     private static ThreadLocal count = new ThreadLocal(){  
  9.  
  10.         @Override  
  11.         protected Integer initialValue() {  
  12.             // TODO Auto-generated method stub  
  13.             return 0;  
  14.         }  
  15.  
  16.     };  
  17.  
  18.     // 存錢  
  19.     public void addMoney(int money) {  
  20.         count.set(count.get()+money);  
  21.         System.out.println(System.currentTimeMillis() + "存進:" + money);  
  22.  
  23.     }  
  24.  
  25.     // 取錢  
  26.     public void subMoney(int money) {  
  27.         if (count.get() - money < 0) {  
  28.             System.out.println("余額不足");  
  29.             return;  
  30.         }  
  31.         count.set(count.get()- money);  
  32.         System.out.println(+System.currentTimeMillis() + "取出:" + money);  
  33.     }  
  34.  
  35.     // 查詢  
  36.     public void lookMoney() {  
  37.         System.out.println("賬戶余額:" + count.get());  
  38.     }  

運行效果:

余額不足 
賬戶余額:0

余額不足 
賬戶余額:0

1441794247939存進:100 
賬戶余額:100

余額不足 
1441794248940存進:100 
賬戶余額:0

賬戶余額:200

余額不足 
賬戶余額:0

1441794249941存進:100 
賬戶余額:300

看了運行效果,一開始一頭霧水,怎么只讓存,不讓取啊?看看ThreadLocal的原理:

如果使用ThreadLocal管理變量,則每一個使用該變量的線程都獲得該變量的副本,副本之間相互獨立,這樣每一個線程都可以隨意修改自己的變 量副本,而不會對其他線程產(chǎn)生影響?,F(xiàn)在明白了吧,原來每個線程運行的都是一個副本,也就是說存錢和取錢是兩個賬戶,知識名字相同而已。所以就會發(fā)生上面 的效果。

ThreadLocal與同步機制

a.ThreadLocal與同步機制都是為了解決多線程中相同變量的訪問沖突問題
b.前者采用以”空間換時間”的方法,后者采用以”時間換空間”的方式

現(xiàn)在都明白了吧。各有優(yōu)劣,各有適用場景。手工,吃飯去了。


分享名稱:Java 多線程同步的五種方法
文章源于:http://m.5511xx.com/article/cdidchh.html