臨界區(qū)
通常來(lái)說(shuō),臨界區(qū)是一個(gè)用以訪問(wèn)共享資源的代碼塊,這個(gè)代碼塊在同一時(shí)刻只允許被一個(gè)線程執(zhí)行
同步
- 當(dāng)一個(gè)線程試圖訪問(wèn)一個(gè)臨界區(qū)資源時(shí),它將使用一種同步機(jī)制來(lái)查看當(dāng)前不是是已經(jīng)有其他的線程進(jìn)入了臨界區(qū)。
- 如果臨界區(qū)沒(méi)有其他線程進(jìn)入,則這個(gè)線程可以直接進(jìn)入臨界區(qū);如果當(dāng)前已經(jīng)有線程進(jìn)入了臨界區(qū),則它就會(huì)被同步機(jī)制掛起,直到進(jìn)入的線程離開(kāi)這個(gè)臨界區(qū)
- 如果在等待進(jìn)入臨界區(qū)的線程不止一個(gè),JVM就會(huì)選擇其中一個(gè),其他的線程繼續(xù)等待
java中采用的兩種基本的同步機(jī)制
1. synchronized關(guān)鍵字同步
2. Lock接口及其接口實(shí)現(xiàn)類(lèi)
通常,synchronized關(guān)鍵字有以下三種使用方式:
1. 同步普通方法,鎖的是當(dāng)前對(duì)象。
2. 同步靜態(tài)方法,鎖的是當(dāng)前 Class 對(duì)象。
3. 同步塊,鎖的是 {} 中的對(duì)象。
package com.feizi.java.concurrency.synchronsize;
/**
* Created by feizi on 2018/5/17.
*/
public class AccountingSync implements Runnable {
private static AccountingSync instance = new AccountingSync();
/*共享資源(臨界資源)*/
static int i = 0;
/**
* 作用于靜態(tài)方法,鎖是當(dāng)前class對(duì)象,也就是AccountingSync來(lái)所對(duì)應(yīng)的class對(duì)象
* 即無(wú)論傳入多少個(gè)實(shí)例,使用的都是同一把鎖,會(huì)發(fā)生互斥
*/
public static synchronized void increaseStatic(){
i++;
}
/**
* 非靜態(tài)方法,訪問(wèn)時(shí)鎖(實(shí)例)不一樣不會(huì)發(fā)生互斥(即如果傳入的是同一個(gè)實(shí)例會(huì)發(fā)生互斥,不會(huì)產(chǎn)生線程安全問(wèn)題,否則
* 如果傳入的是不同的實(shí)例,則不會(huì)發(fā)生互斥)
*/
public synchronized void increaseNostatic(){
i++;
}
/**
* 使用this作為對(duì)象鎖,鎖住的是當(dāng)前傳入的實(shí)例對(duì)象,如果傳入的是同一個(gè)實(shí)例,則不會(huì)有線程安全問(wèn)題,否則會(huì)有線程安全問(wèn)題
*/
public void increaseThis(){
//this,當(dāng)前實(shí)例對(duì)象鎖
synchronized (this){
i++;
}
}
/**
* 靜態(tài)實(shí)例對(duì)象鎖, 這種寫(xiě)法一般比較推薦,因?yàn)殪o態(tài)實(shí)例是屬于類(lèi)的,在JVM啟動(dòng)的時(shí)候就已經(jīng)被加載了,
* 所以無(wú)論傳入多少個(gè)實(shí)例,使用的都是同一把對(duì)象鎖
*/
public void increaseStaticInstance(){
synchronized (instance){
i++;
}
}
/**
* class對(duì)象鎖, 鎖住的是當(dāng)前的class對(duì)象, 這種方式同上面的靜態(tài)實(shí)例對(duì)象鎖的方式,無(wú)論傳入多少個(gè)實(shí)例,使用的
* 都是同一把對(duì)象鎖
*/
public void increaseClass(){
synchronized (AccountingSync.class){
i++;
}
}
@Override
public void run() {
for (int j = 0; j < 2000000; j++){
increaseStatic();
// increaseNostatic();
// increaseThis();
// increaseStaticInstance();
// increaseClass();
}
}
public static void main(String[] args) throws InterruptedException {
/*AccountingSync increase = new AccountingSync();
Thread t1 = new Thread(increase);
Thread t2 = new Thread(increase);
t1.start();
t2.start();
t1.join();
t2.join();
System.out.println("結(jié)果i=" + i);*/
Thread t1 = new Thread(new AccountingSync());
Thread t2 = new Thread(new AccountingSync());
t1.start();
t2.start();
t1.join();
t2.join();
System.out.println("結(jié)果i=" + i);
}
}
控制臺(tái)輸出結(jié)果:
結(jié)果i=4000000
Process finished with exit code 0
試了幾種不同的同步方式,結(jié)論如下:
作用于靜態(tài)方法
鎖是當(dāng)前class對(duì)象,也就是AccountingSync來(lái)所對(duì)應(yīng)的class對(duì)象,即無(wú)論傳入多少個(gè)實(shí)例,使用的都是同一把鎖,會(huì)發(fā)生互斥。作用于非靜態(tài)(普通)方法
訪問(wèn)時(shí)鎖(實(shí)例)不一樣不會(huì)發(fā)生互斥,即如果傳入的是同一個(gè)實(shí)例會(huì)發(fā)生互斥,不會(huì)產(chǎn)生線程安全問(wèn)題,否則如果傳入的是不同的實(shí)例,則不會(huì)發(fā)生互斥。使用this作為對(duì)象鎖
鎖住的是當(dāng)前傳入的實(shí)例對(duì)象,如果傳入的是同一個(gè)實(shí)例,則不會(huì)有線程安全問(wèn)題,否則會(huì)有線程安全問(wèn)題使用靜態(tài)實(shí)例作為對(duì)象鎖
這種寫(xiě)法一般比較推薦,因?yàn)殪o態(tài)實(shí)例是屬于類(lèi)的,在JVM啟動(dòng)的時(shí)候就已經(jīng)被加載了,所以無(wú)論傳入多少個(gè)實(shí)例,使用的都是同一把對(duì)象鎖使用class對(duì)象鎖
鎖住的是當(dāng)前的class對(duì)象, 這種方式同上面的靜態(tài)實(shí)例對(duì)象鎖的方式,無(wú)論傳入多少個(gè)實(shí)例,使用的都是同一把對(duì)象鎖