更新時間:2020-11-09 17:57:54 來源:動力節(jié)點 瀏覽1481次
同步(Synchronization)在計算機語言中是指對在一個系統(tǒng)中所發(fā)生的事件之間進(jìn)行協(xié)調(diào),在時間上出現(xiàn)一致性與統(tǒng)一化的現(xiàn)象。而Java語言是允許多線程并發(fā)控制的,當(dāng)多個線程同時操作一個可共享的資源變量時(如數(shù)據(jù)的增刪改查),將會導(dǎo)致數(shù)據(jù)不準(zhǔn)確,相互之間產(chǎn)生沖突,因此加入同步鎖以避免在該線程沒有完成操作之前,被其他線程的調(diào)用,從而保證了該變量的唯一性和準(zhǔn)確性。本文我們就來和大家講講線程同步的相關(guān)知識。
1、線程同步方法
即有synchronized關(guān)鍵字修飾的方法。由于java的每個對象都有一個內(nèi)置鎖,當(dāng)用此關(guān)鍵字修飾方法時,內(nèi)置鎖會保護(hù)整個方法。在調(diào)用該方法前,需要獲得內(nèi)置鎖,否則就處于阻塞狀態(tài)。
public synchronized void save(){}
注: synchronized關(guān)鍵字也可以修飾靜態(tài)方法,此時如果調(diào)用該靜態(tài)方法,將會鎖住整個類
2、線程同步代碼塊
即有synchronized關(guān)鍵字修飾的語句塊。被該關(guān)鍵字修飾的語句塊會自動被加上內(nèi)置鎖,從而實現(xiàn)同步。
public class Bank {
private int count =0;//賬戶余額
//存錢
public void addMoney(int money){
synchronized (this) {
count +=money;
}
System.out.println(System.currentTimeMillis()+"存進(jìn):"+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);
}
}
事實上,同步是一種高開銷的操作,因此應(yīng)該盡量減少同步的內(nèi)容。通常沒有必要同步整個方法,使用synchronized代碼塊同步關(guān)鍵代碼即可。
3、使用特殊域變量(volatile)實現(xiàn)線程同步
1)volatile關(guān)鍵字為域變量的訪問提供了一種免鎖機制;
2)使用volatile修飾域相當(dāng)于告訴虛擬機該域可能會被其他線程更新;
3)因此每次使用該域就要重新計算,而不是使用寄存器中的值;
4)volatile不會提供任何原子操作,它也不能用來修飾final類型的變量。
public class SynchronizedThread {
class Bank {
private volatile int account = 100;
public int getAccount() {
return account;
}
/**
* 用同步方法實現(xiàn)
*
* @param money
*/
public synchronized void save(int money) {
account += money;
}
/**
* 用同步代碼塊實現(xiàn)
*
* @param money
*/
public void save1(int money) {
synchronized (this) {
account += money;
}
}
}
class NewThread implements Runnable {
private Bank bank;
public NewThread(Bank bank) {
this.bank = bank;
}
@Override
public void run() {
for (int i = 0; i < 10; i++) {
// bank.save1(10);
bank.save(10);
System.out.println(i + "賬戶余額為:" +bank.getAccount());
}
}
}
/**
* 建立線程,調(diào)用內(nèi)部類
*/
public void useThread() {
Bank bank = new Bank();
NewThread new_thread = new NewThread(bank);
System.out.println("線程1");
Thread thread1 = new Thread(new_thread);
thread1.start();
System.out.println("線程2");
Thread thread2 = new Thread(new_thread);
thread2.start();
}
public static void main(String[] args) {
SynchronizedThread st = new SynchronizedThread();
st.useThread();
}
多線程中的非同步問題主要出現(xiàn)在對域的讀寫上,如果讓域自身避免這個問題,則就不需要修改操作該域的方法。用final域,有鎖保護(hù)的域和volatile域可以避免非同步的問題。
4、使用重入鎖(Lock)實現(xiàn)線程同步
在JavaSE5.0中新增了一個java.util.concurrent包來支持同步。ReentrantLock類是可重入、互斥、實現(xiàn)了Lock接口的鎖,它與使用synchronized方法和快具有相同的基本行為和語義,并且擴(kuò)展了其能力。ReenreantLock類的常用方法有:
ReentrantLock() : 創(chuàng)建一個ReentrantLock實例
lock() : 獲得鎖
unlock() : 釋放鎖
注:ReentrantLock()還有一個可以創(chuàng)建公平鎖的構(gòu)造方法,但由于能大幅度降低程序運行效率,不推薦使用
//只給出要修改的代碼,其余代碼與上同
class Bank {
private int account = 100;
//需要聲明這個鎖
private Lock lock = new ReentrantLock();
public int getAccount() {
return account;
}
//這里不再需要synchronized
public void save(int money) {
lock.lock();
try{
account += money;
}finally{
lock.unlock();
}
}
}
以上就是對線程同步的詳細(xì)講解,簡而言之,線程同步就是為了防止多個線程同時訪問同一個數(shù)據(jù)對象時,對數(shù)據(jù)造成破壞,也是保證多線程安全訪問資源的一種保障。當(dāng)然,線程同步也只是多線程知識里面的滄海一粟,想要學(xué)好多線程,學(xué)好Java,快來觀看本站的Java基礎(chǔ)教程吧!
初級 202925
初級 203221
初級 202629
初級 203743