Java線程同步Lock同步鎖代碼示例
java線程同步原理
java會(huì)為每個(gè)object對(duì)象分配一個(gè)monitor,當(dāng)某個(gè)對(duì)象的同步方法(synchronizedmethods)被多個(gè)線程調(diào)用時(shí),該對(duì)象的monitor將負(fù)責(zé)處理這些訪問(wèn)的并發(fā)獨(dú)占要求。
當(dāng)一個(gè)線程調(diào)用一個(gè)對(duì)象的同步方法時(shí),JVM會(huì)檢查該對(duì)象的monitor。如果monitor沒(méi)有被占用,那么這個(gè)線程就得到了monitor的占有權(quán),可以繼續(xù)執(zhí)行該對(duì)象的同步方法;如果monitor被其他線程所占用,那么該線程將被掛起,直到monitor被釋放。
當(dāng)線程退出同步方法調(diào)用時(shí),該線程會(huì)釋放monitor,這將允許其他等待的線程獲得monitor以使對(duì)同步方法的調(diào)用執(zhí)行下去。
注意:Java對(duì)象的monitor機(jī)制和傳統(tǒng)的臨界檢查代碼區(qū)技術(shù)不一樣。java的一個(gè)同步方法并不意味著同時(shí)只有一個(gè)線程獨(dú)占執(zhí)行,但臨界檢查代碼區(qū)技術(shù)確實(shí)會(huì)保證同步方法在一個(gè)時(shí)刻只被一個(gè)線程獨(dú)占執(zhí)行。Java的monitor機(jī)制的準(zhǔn)確含義是:任何時(shí)刻,對(duì)一個(gè)指定object對(duì)象的某同步方法只能由一個(gè)線程來(lái)調(diào)用。
java對(duì)象的monitor是跟隨object實(shí)例來(lái)使用的,而不是跟隨程序代碼。兩個(gè)線程可以同時(shí)執(zhí)行相同的同步方法,比如:一個(gè)類(lèi)的同步方法是xMethod(),有a,b兩個(gè)對(duì)象實(shí)例,一個(gè)線程執(zhí)行a.xMethod(),另一個(gè)線程執(zhí)行b.xMethod().互不沖突。
Lock-同步鎖
Lock是java5提供的一個(gè)強(qiáng)大的線程同步機(jī)制--通過(guò)顯示定義同步鎖對(duì)象來(lái)實(shí)現(xiàn)同步。Lock可以顯示的加鎖、解鎖。每次只能有一個(gè)線程對(duì)lock對(duì)象加鎖。
Lock有ReadLock、WriteLock、ReentrantLock(可重入鎖)
常用的就是ReentrantLock。代碼如下:
代碼邏輯:Account賬戶類(lèi),實(shí)現(xiàn)取錢(qián)的同步方法、DrawThread取錢(qián)的線程
Account:
package lock.reentrantlock2;
import java.util.concurrent.locks.*;
/**
*賬戶類(lèi),需保持同步
*/
public class Account
{
//定義鎖對(duì)象
private final ReentrantLock lock = new ReentrantLock();
private String accountNo;
private double balance;
public Account(){}
public Account(String accountNo , double balance)
{
this.accountNo = accountNo;
this.balance = balance;
}
public void setAccountNo(String accountNo)
{
this.accountNo = accountNo;
}
public String getAccountNo()
{
return this.accountNo;
}
public double getBalance()
{
return this.balance;
}
public void draw(double drawAmount)
{
lock.lock();
try
{
//賬戶余額大于取錢(qián)數(shù)目
if (balance >= drawAmount)
{
//吐出鈔票
System.out.println(Thread.currentThread().getName() +
"取錢(qián)成功!吐出鈔票:" + drawAmount);
try
{
Thread.sleep(1);
}
catch (InterruptedException ex)
{
ex.printStackTrace();
}
//修改余額
balance -= drawAmount;
System.out.println("\t余額為: " + balance);
}
else
{
System.out.println(Thread.currentThread().getName() +
"取錢(qián)失敗!余額不足!");
}
}
finally
{
lock.unlock();
}
}
public int hashCode()
{
return accountNo.hashCode();
}
public boolean equals(Object obj)
{
if (obj != null && obj.getClass() == Account.class)
{
Account target = (Account)obj;
return target.getAccountNo().equals(accountNo);
}
return false;
}
}
DrawThread:
package lock.reentrantlock2;
/**
* 調(diào)用account取錢(qián)
*
*/
public class DrawThread extends Thread
{
//模擬用戶賬戶
private Account account;
//當(dāng)前取錢(qián)線程所希望取的錢(qián)數(shù)
private double drawAmount;
public DrawThread(String name , Account account ,
double drawAmount)
{
super(name);
this.account = account;
this.drawAmount = drawAmount;
}
//當(dāng)多條線程修改同一個(gè)共享數(shù)據(jù)時(shí),將涉及到數(shù)據(jù)安全問(wèn)題。
public void run()
{
account.draw(drawAmount);
}
}
TestDraw:
package lock.reentrantlock2;
/**
*/
public class TestDraw
{
public static void main(String[] args)
{
//創(chuàng)建一個(gè)賬戶
Account acct = new Account("1234567" , 1000);
//模擬兩個(gè)線程對(duì)同一個(gè)賬戶取錢(qián)
new DrawThread("甲" , acct , 800).start();
new DrawThread("乙" , acct , 800).start();
}
}
運(yùn)行結(jié)果:
甲取錢(qián)成功!吐出鈔票:800.0
余額為:200.0
乙取錢(qián)失??!余額不足!
使用Lock同步與同步方法很相似,都是“加鎖--修改公共變量--釋放鎖”的模式,代碼很容易看懂。兩個(gè)線程對(duì)應(yīng)一個(gè)Account對(duì)象,保證了兩個(gè)線程對(duì)應(yīng)一個(gè)lock對(duì)象,保證了同一時(shí)刻只有一個(gè)線程進(jìn)入臨界區(qū)。Lock還包含太容易Lock(),以及試圖獲取可中斷鎖的lockInterruptibly(),獲取超時(shí)失效鎖的tryLock(long,TimeUnit)等方法。
ReentrantLock鎖具有可重入性可以對(duì)已被加鎖的ReentrantLock鎖再次加鎖,線程每次調(diào)用lock()加鎖后,必須顯示的調(diào)用unlock來(lái)釋放鎖,有幾個(gè)lock就對(duì)應(yīng)幾個(gè)unlock。還有把unlock放在finally代碼塊中,Lock在發(fā)生異常時(shí)也是不釋放鎖的,所以在finally中釋放更安全。
總結(jié)
以上就是本文關(guān)于Java線程同步Lock同步鎖代碼示例的全部?jī)?nèi)容,希望對(duì)大家有所幫助。感興趣的朋友可以繼續(xù)參閱本站:
創(chuàng)建并運(yùn)行一個(gè)java線程方法介紹
Java編程之多線程死鎖與線程間通信簡(jiǎn)單實(shí)現(xiàn)代碼
Java多線程編程小實(shí)例模擬停車(chē)場(chǎng)系統(tǒng)
有什么問(wèn)題可以隨時(shí)留言,小編會(huì)及時(shí)回復(fù)大家的。感謝朋友們對(duì)本站的支持!
相關(guān)文章
Java輸入數(shù)據(jù)的知識(shí)點(diǎn)整理
在本篇文章里小編給大家整理的是關(guān)于Java如何輸入數(shù)據(jù)的相關(guān)知識(shí)點(diǎn)內(nèi)容,有興趣的朋友們學(xué)習(xí)參考下。2020-01-01
Java基礎(chǔ)之刪除文本文件中特定行的內(nèi)容
這篇文章主要介紹了Java基礎(chǔ)之刪除文本文件中特定行的內(nèi)容,文中有非常詳細(xì)的代碼示例,對(duì)正在學(xué)習(xí)java基礎(chǔ)的小伙伴們有非常好的幫助,需要的朋友可以參考下2021-04-04
spring boot2結(jié)合mybatis增刪改查的實(shí)現(xiàn)
這篇文章主要給大家介紹了關(guān)于spring boot2結(jié)合mybatis增刪改查的相關(guān)資料,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家學(xué)習(xí)或者使用spring boot2具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2019-09-09
Java MongoDB數(shù)據(jù)庫(kù)連接方法梳理
MongoDB作為一種介于關(guān)系型數(shù)據(jù)庫(kù)和非關(guān)系型數(shù)據(jù)庫(kù)之間的產(chǎn)品,它可以提供可擴(kuò)展的高性能的數(shù)據(jù)存儲(chǔ)解決方案,近些年來(lái)受到了開(kāi)發(fā)者的喜愛(ài)2022-08-08
SpringBoot如何啟動(dòng)自動(dòng)加載自定義模塊yml文件(PropertySourceFactory)
這篇文章主要介紹了SpringBoot如何啟動(dòng)自動(dòng)加載自定義模塊yml文件(PropertySourceFactory),具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2024-07-07

