java多線程同步1的簡單介紹

本文目錄一覽:

Java如何實現多線程同步?

//解決方案-1 設置3把鎖, 然後把鎖們應用到所有線程中 (涉及到synchronized wait notify等, 嫌麻煩. 略)

解決方案-2 設置3個全局共享的信號標記(信號燈) + 3子線程分別佔用標記1 2 3

+ 主線程輪詢/等待

(簡潔明快 推薦)

//解決方案-2 實現如下:

static boolean t1_done = false;

static boolean t2_done = false;

static boolean t3_done = false;

//t1——run() { ………… ; t1_done = true; }

//t2、 3: 同理,略

main () { ………….;

啟動t1;

啟動t2;

啟動t3;

//輪詢 or 等待

while ( true )

if ( t1_done t2_done t3_done) break;

else

Thread.yield () ;

// 或 Thread.sleep(xxxx) —-若子線程運行超過100ms以上,應予考慮

//輪詢結束,主線程繼續工作

} //main END

have fun

Java多線程同步的幾種方式

java中多線程的實現方法有兩種:1.直接繼承thread類;2.實現runnable接口;同步的實現方法有五種:1.同步方法;2.同步代碼塊;3.使用特殊域變量(volatile)實現線程同步;4.使用重入鎖實現線程同步;5.使用局部變量實現線程同步 。

其中多線程實現過程中需注意重寫或者覆蓋run()方法,而對於同步的實現方法中使用較常使用的是利用synchronized編寫同步方法和代碼塊。

謝謝採納!!

java多線程開發的同步機制有哪些

一段synchronized的代碼被一個線程執行之前,他要先拿到執行這段代碼的權限,在 java裡邊就是拿到某個同步對象的鎖(一個對象只有一把鎖); 如果這個時候同步對象的鎖被其他線程拿走了,他(這個線程)就只能等了(線程阻塞在鎖池 等待隊列中)。 取到鎖後,他就開始執行同步代碼(被synchronized修飾的代碼);線程執行完同步代碼後馬上就把鎖還給同步對象,其他在鎖池中 等待的某個線程就可以拿到鎖執行同步代碼了。這樣就保證了同步代碼在統一時刻只有一個線程在執行。

眾所周知,在Java多線程編程中,一個非常重要的方面就是線程的同步問題。

關於線程的同步,一般有以下解決方法:

1. 在需要同步的方法的方法簽名中加入synchronized關鍵字。

2. 使用synchronized塊對需要進行同步的代碼段進行同步。

3. 使用JDK 5中提供的java.util.concurrent.lock包中的Lock對象。

另外,為了解決多個線程對同一變量進行訪問時可能發生的安全性問題,我們不僅可以採用同步機制,更可以通過JDK 1.2中加入的ThreadLocal來保證更好的並發性。

Java 線程同步幾種方式

(1)同步方法:

即有synchronized關鍵字修飾的方法。 由於java的每個對象都有一個內置鎖,當用此關鍵字修飾方法時,內置鎖會保護整個方法。在調用該方法前,需要獲得內置鎖,否則就處於阻塞狀態。

(2)同步代碼塊

即有synchronized關鍵字修飾的語句塊。被該關鍵字修飾的語句塊會自動被加上內置鎖,從而實現同步

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

a.volatile關鍵字為域變量的訪問提供了一種免鎖機制

b.使用volatile修飾域相當於告訴虛擬機該域可能會被其他線程更新

c.因此每次使用該域就要重新計算,而不是使用寄存器中的值

d.volatile不會提供任何原子操作,它也不能用來修飾final類型的變量

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

在JavaSE5.0中新增了一個java.util.concurrent包來支持同步。ReentrantLock類是可重入、互斥、實現了Lock接口的鎖, 它與使用synchronized方法和快具有相同的基本行為和語義,並且擴展了其能力。

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

java多線程有幾種實現方法?線程之間如何同步

一、為什麼要線程同步

因為當我們有多個線程要同時訪問一個變量或對象時,如果這些線程中既有讀又有寫操作時,就會導致變量值或對象的狀態出現混亂,從而導致程序異常。舉個例子,如果一個銀行賬戶同時被兩個線程操作,一個取100塊,一個存錢100塊。假設賬戶原本有0塊,如果取錢線程和存錢線程同時發生,會出現什麼結果呢?取錢不成功,賬戶餘額是100.取錢成功了,賬戶餘額是0.那到底是哪個呢?很難說清楚。因此多線程同步就是要解決這個問題。

二、不同步時的代碼

Bank.Java

package threadTest;

/**

 * @author ww

 *

 */

public class Bank {

private int count =0;//賬戶餘額

//存錢

public  void addMoney(int money){

count +=money;

System.out.println(System.currentTimeMillis()+”存進:”+money);

}

//取錢

public  void subMoney(int money){

if(count-money  0){

System.out.println(“餘額不足”);

return;

}

count -=money;

System.out.println(+System.currentTimeMillis()+”取出:”+money);

}

//查詢

public void lookMoney(){

System.out.println(“賬戶餘額:”+count);

}

}

SyncThreadTest.java

package threadTest;

public class SyncThreadTest {

public static void main(String args[]){

final Bank bank=new Bank();

Thread tadd=new Thread(new Runnable() {

@Override

public void run() {

// TODO Auto-generated method stub

while(true){

try {

Thread.sleep(1000);

} catch (InterruptedException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

bank.addMoney(100);

bank.lookMoney();

System.out.println(“\n”);

}

}

});

Thread tsub = new Thread(new Runnable() {

@Override

public void run() {

// TODO Auto-generated method stub

while(true){

bank.subMoney(100);

bank.lookMoney();

System.out.println(“\n”);

try {

Thread.sleep(1000);

} catch (InterruptedException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

}

});

tsub.start();

tadd.start();

}

}

餘額不足

賬戶餘額:0

餘額不足

賬戶餘額:100

1441790503354存進:100

賬戶餘額:100

1441790504354存進:100

賬戶餘額:100

1441790504354取出:100

賬戶餘額:100

1441790505355存進:100

賬戶餘額:100

1441790505355取出:100

賬戶餘額:100

三、使用同步時的代碼

(1)同步方法:

即有synchronized關鍵字修飾的方法。 由於java的每個對象都有一個內置鎖,當用此關鍵字修飾方法時,內置鎖會保護整個方法。在調用該方法前,需要獲得內置鎖,否則就處於阻塞狀態。

修改後的Bank.java

package threadTest;

/**

 * @author ww

 *

 */

public class Bank {

private int count =0;//賬戶餘額

//存錢

public  synchronized void addMoney(int money){

count +=money;

System.out.println(System.currentTimeMillis()+”存進:”+money);

}

//取錢

public  synchronized void subMoney(int money){

if(count-money  0){

System.out.println(“餘額不足”);

return;

}

count -=money;

System.out.println(+System.currentTimeMillis()+”取出:”+money);

}

//查詢

public void lookMoney(){

System.out.println(“賬戶餘額:”+count);

}

}

再看看運行結果:

餘額不足

賬戶餘額:0

餘額不足

賬戶餘額:0

1441790837380存進:100

賬戶餘額:100

1441790838380取出:100

賬戶餘額:0

1441790838380存進:100

賬戶餘額:100

1441790839381取出:100

賬戶餘額:0

瞬間感覺可以理解了吧。

註: synchronized關鍵字也可以修飾靜態方法,此時如果調用該靜態方法,將會鎖住整個類

(2)同步代碼塊

即有synchronized關鍵字修飾的語句塊。被該關鍵字修飾的語句塊會自動被加上內置鎖,從而實現同步

Bank.java代碼如下:

package threadTest;

/**

 * @author ww

 *

 */

public class Bank {

private int count =0;//賬戶餘額

//存錢

public   void addMoney(int money){

synchronized (this) {

count +=money;

}

System.out.println(System.currentTimeMillis()+”存進:”+money);

}

//取錢

public   void subMoney(int money){

synchronized (this) {

if(count-money  0){

System.out.println(“餘額不足”);

return;

}

count -=money;

}

System.out.println(+System.currentTimeMillis()+”取出:”+money);

}

//查詢

public void lookMoney(){

System.out.println(“賬戶餘額:”+count);

}

}

運行結果如下:

餘額不足  

賬戶餘額:0  

  

  

1441791806699存進:100  

賬戶餘額:100  

  

  

1441791806700取出:100  

賬戶餘額:0  

  

  

1441791807699存進:100  

賬戶餘額:100

效果和方法一差不多。

註:同步是一種高開銷的操作,因此應該盡量減少同步的內容。通常沒有必要同步整個方法,使用synchronized代碼塊同步關鍵代碼即可。

(3)使用特殊域變量(volatile)實現線程同步

a.volatile關鍵字為域變量的訪問提供了一種免鎖機制

b.使用volatile修飾域相當於告訴虛擬機該域可能會被其他線程更新

c.因此每次使用該域就要重新計算,而不是使用寄存器中的值

d.volatile不會提供任何原子操作,它也不能用來修飾final類型的變量

Bank.java代碼如下:

package threadTest;

/**

 * @author ww

 *

 */

public class Bank {

private volatile int count = 0;// 賬戶餘額

// 存錢

public void addMoney(int money) {

count += money;

System.out.println(System.currentTimeMillis() + “存進:” + money);

}

// 取錢

public void subMoney(int money) {

if (count – money  0) {

System.out.println(“餘額不足”);

return;

}

count -= money;

System.out.println(+System.currentTimeMillis() + “取出:” + money);

}

// 查詢

public void lookMoney() {

System.out.println(“賬戶餘額:” + count);

}

}

運行效果怎樣呢?

餘額不足

賬戶餘額:0

餘額不足

賬戶餘額:100

1441792010959存進:100

賬戶餘額:100

1441792011960取出:100

賬戶餘額:0

1441792011961存進:100

賬戶餘額:100

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

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

在JavaSE5.0中新增了一個java.util.concurrent包來支持同步。ReentrantLock類是可重入、互斥、實現了Lock接口的鎖, 它與使用synchronized方法和快具有相同的基本行為和語義,並且擴展了其能力。

ReenreantLock類的常用方法有:

ReentrantLock() : 創建一個ReentrantLock實例

lock() : 獲得鎖

unlock() : 釋放鎖

註:ReentrantLock()還有一個可以創建公平鎖的構造方法,但由於能大幅度降低程序運行效率,不推薦使用 

Bank.java代碼修改如下:

package threadTest;

import java.util.concurrent.locks.Lock;

import java.util.concurrent.locks.ReentrantLock;

/**

 * @author ww

 *

 */

public class Bank {

private  int count = 0;// 賬戶餘額

//需要聲明這個鎖

    private Lock lock = new ReentrantLock();

// 存錢

public void addMoney(int money) {

lock.lock();//上鎖

try{

count += money;

System.out.println(System.currentTimeMillis() + “存進:” + money);

}finally{

lock.unlock();//解鎖

}

}

// 取錢

public void subMoney(int money) {

lock.lock();

try{

if (count – money  0) {

System.out.println(“餘額不足”);

return;

}

count -= money;

System.out.println(+System.currentTimeMillis() + “取出:” + money);

}finally{

lock.unlock();

}

}

// 查詢

public void lookMoney() {

System.out.println(“賬戶餘額:” + count);

}

}

運行效果怎麼樣呢?

餘額不足

賬戶餘額:0

餘額不足

賬戶餘額:0

1441792891934存進:100

賬戶餘額:100

1441792892935存進:100

賬戶餘額:200

1441792892954取出:100

賬戶餘額:100

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

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

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

Bank.java代碼如下:

package threadTest;

/**

 * @author ww

 *

 */

public class Bank {

private static ThreadLocalInteger count = new ThreadLocalInteger(){

@Override

protected Integer initialValue() {

// TODO Auto-generated method stub

return 0;

}

};

// 存錢

public void addMoney(int money) {

count.set(count.get()+money);

System.out.println(System.currentTimeMillis() + “存進:” + money);

}

// 取錢

public void subMoney(int money) {

if (count.get() – money  0) {

System.out.println(“餘額不足”);

return;

}

count.set(count.get()- money);

System.out.println(+System.currentTimeMillis() + “取出:” + money);

}

// 查詢

public void lookMoney() {

System.out.println(“賬戶餘額:” + count.get());

}

}

運行效果:

餘額不足

賬戶餘額:0

餘額不足

賬戶餘額:0

1441794247939存進:100

賬戶餘額:100

餘額不足

1441794248940存進:100

賬戶餘額:0

賬戶餘額:200

餘額不足

賬戶餘額:0

1441794249941存進:100

賬戶餘額:300

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

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

ThreadLocal與同步機制 

a.ThreadLocal與同步機制都是為了解決多線程中相同變量的訪問衝突問題

b.前者採用以”空間換時間”的方法,後者採用以”時間換空間”的方式

原創文章,作者:NOLEA,如若轉載,請註明出處:https://www.506064.com/zh-hk/n/324420.html

(0)
打賞 微信掃一掃 微信掃一掃 支付寶掃一掃 支付寶掃一掃
NOLEA的頭像NOLEA
上一篇 2025-01-13 13:22
下一篇 2025-01-13 13:23

相關推薦

  • Java JsonPath 效率優化指南

    本篇文章將深入探討Java JsonPath的效率問題,並提供一些優化方案。 一、JsonPath 簡介 JsonPath是一個可用於從JSON數據中獲取信息的庫。它提供了一種DS…

    編程 2025-04-29
  • java client.getacsresponse 編譯報錯解決方法

    java client.getacsresponse 編譯報錯是Java編程過程中常見的錯誤,常見的原因是代碼的語法錯誤、類庫依賴問題和編譯環境的配置問題。下面將從多個方面進行分析…

    編程 2025-04-29
  • Java騰訊雲音視頻對接

    本文旨在從多個方面詳細闡述Java騰訊雲音視頻對接,提供完整的代碼示例。 一、騰訊雲音視頻介紹 騰訊雲音視頻服務(Cloud Tencent Real-Time Communica…

    編程 2025-04-29
  • Java Bean加載過程

    Java Bean加載過程涉及到類加載器、反射機制和Java虛擬機的執行過程。在本文中,將從這三個方面詳細闡述Java Bean加載的過程。 一、類加載器 類加載器是Java虛擬機…

    編程 2025-04-29
  • Java Milvus SearchParam withoutFields用法介紹

    本文將詳細介紹Java Milvus SearchParam withoutFields的相關知識和用法。 一、什麼是Java Milvus SearchParam without…

    編程 2025-04-29
  • Java 8中某一周的周一

    Java 8是Java語言中的一個版本,於2014年3月18日發佈。本文將從多個方面對Java 8中某一周的周一進行詳細的闡述。 一、數組處理 Java 8新特性之一是Stream…

    編程 2025-04-29
  • Python簡單數學計算

    本文將從多個方面介紹Python的簡單數學計算,包括基礎運算符、函數、庫以及實際應用場景。 一、基礎運算符 Python提供了基礎的算術運算符,包括加(+)、減(-)、乘(*)、除…

    編程 2025-04-29
  • Java判斷字符串是否存在多個

    本文將從以下幾個方面詳細闡述如何使用Java判斷一個字符串中是否存在多個指定字符: 一、字符串遍歷 字符串是Java編程中非常重要的一種數據類型。要判斷字符串中是否存在多個指定字符…

    編程 2025-04-29
  • Python滿天星代碼:讓編程變得更加簡單

    本文將從多個方面詳細闡述Python滿天星代碼,為大家介紹它的優點以及如何在編程中使用。無論是剛剛接觸編程還是資深程序員,都能從中獲得一定的收穫。 一、簡介 Python滿天星代碼…

    編程 2025-04-29
  • VSCode為什麼無法運行Java

    解答:VSCode無法運行Java是因為默認情況下,VSCode並沒有集成Java運行環境,需要手動添加Java運行環境或安裝相關插件才能實現Java代碼的編寫、調試和運行。 一、…

    編程 2025-04-29

發表回復

登錄後才能評論