一、synchronized 內(nèi)置鎖

java 關(guān)鍵字synchronized 用于保證線程對(duì)變量訪問的可見性與排他性，又可以稱之為內(nèi)置鎖機(jī)制。

synchronized 可以修飾方法跟同步塊上來進(jìn)行使用，確保多個(gè)線程只有一個(gè)線程處于方法或者同步塊中。

同步方法與同步塊

使用 前面學(xué)習(xí)過的CountDownLatch 做并發(fā)測(cè)試

import java.util.concurrent.CountDownLatch;/*** 演示synchronized 同步方法，同步塊基本使用方法* * @author ckj**/ public class SynchronizedTest {static CountDownLatch latch = new CountDownLatch(10);private Object obj = new Object();private int num = 0;/*** 同步方法加鎖*/public synchronized void synIncNum() {num++;}/*** 同步塊加鎖*/public void synIncNum2() {synchronized(this) {num++;}//也可以寫成這樣 // synchronized(obj) { // num++; // }}public void incNum() {num++;}static class MyThread extends Thread {private SynchronizedTest syn;public MyThread(SynchronizedTest syn) {this.syn = syn;}public void run() {for (int i = 0; i < 10000; i++) {//幾個(gè)測(cè)試方法自己手動(dòng)去切換測(cè)試syn.incNum();//syn.synIncNum();//syn.synIncNum2();}latch.countDown();};}public static void main(String[] args) throws InterruptedException {SynchronizedTest syn = new SynchronizedTest();//啟動(dòng)10個(gè)線程滿足latch 計(jì)數(shù)器for(int i =0 ;i<10;i++) {new MyThread(syn).start();}latch.await();System.out.println(syn.num); //理想值應(yīng)該是100000}}

從測(cè)試類的測(cè)試結(jié)果可以看的出來，如果沒有加同步機(jī)制在多線程的情況下會(huì)出現(xiàn)并發(fā)問題。

那么synchronized 到底鎖的是什么呢。 從上面的例子看來synchronized 鎖的是其實(shí)就是對(duì)象

其實(shí)你可以認(rèn)為在方法上使用synchronized關(guān)鍵字其實(shí)他的含義就是synchronized(this) 。從這個(gè)方向去理解synchronized鎖的話那么synchronized鎖不同對(duì)象的話那么線程就可以并行了。

對(duì)象鎖

/*** 演示鎖的對(duì)象不同線程并行* * @author ckj**/ public class InstanceSynTest {static class MyThread implements Runnable {private InstanceSynTest syn;public MyThread(InstanceSynTest syn) {this.syn = syn;}public void run() {System.out.println("開始執(zhí)行MyThread" + Thread.currentThread().getName());syn.syncInstance1();}}static class MyThread2 implements Runnable {private InstanceSynTest syn;public MyThread2(InstanceSynTest syn) {this.syn = syn;}public void run() {System.out.println("開始執(zhí)行MyThread2" + Thread.currentThread().getName());syn.syncInstance2();}}public synchronized void syncInstance1() {try {Thread.sleep(2000);System.out.println("syncInstance1 開始執(zhí)行..." + this.toString());Thread.sleep(2000);System.out.println("syncInstance1 結(jié)束執(zhí)行 " + this.toString());} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}}public synchronized void syncInstance2() {try {Thread.sleep(2000);System.out.println("synInstance2 開始執(zhí)行..." + this.toString());Thread.sleep(2000);System.out.println("synInstance2 結(jié)束執(zhí)行 " + this.toString());} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}}public static void main(String[] args) throws InterruptedException {InstanceSynTest ins1 = new InstanceSynTest();InstanceSynTest ins2 = new InstanceSynTest();Thread thread1 = new Thread(new MyThread(ins1));Thread thread2 = new Thread(new MyThread2(ins2)); // 由于傳入的對(duì)象是不同對(duì)象，線程執(zhí)行的順序是并行的//Thread thread2 = new Thread(new MyThread2(ins1)); // 修改為同一對(duì)象的話那么，線程執(zhí)行變?yōu)榇衪hread1.start();thread2.start();Thread.sleep(6000);} }

如果我我們把鎖加在static 方法上面呢，那么又會(huì)是說明結(jié)果。我們知道類的對(duì)象可以有許多，但是類只有一個(gè)class 對(duì)象只有一個(gè)，所以不同對(duì)象實(shí)例的對(duì)象鎖是是互不干擾的，但是每個(gè)類都只有一個(gè)類鎖。但是有一點(diǎn)類鎖只是概念上的東西。

類鎖

稍微修改上面測(cè)試類

/*** 演示實(shí)例鎖和類鎖的不同，可以并行開始 * * @author ckj**/ public class InstanceClassSynTest {static class MyThread implements Runnable {private InstanceClassSynTest syn;public MyThread(InstanceClassSynTest syn) {this.syn = syn;}public void run() {System.out.println("開始執(zhí)行MyThread" + Thread.currentThread().getName());syn.syncInstance1();}}static class MyThread2 implements Runnable {public void run() {System.out.println("開始執(zhí)行MyThread2" + Thread.currentThread().getName());syncInstance2();}}public synchronized void syncInstance1() {try {Thread.sleep(2000);System.out.println("syncInstance1 開始執(zhí)行..." + this.toString());Thread.sleep(2000);System.out.println("syncInstance1 結(jié)束執(zhí)行 " + this.toString());} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}}public static synchronized void syncInstance2() {try {Thread.sleep(2000);System.out.println("synInstance2 開始執(zhí)行...");Thread.sleep(2000);System.out.println("synInstance2 結(jié)束執(zhí)行 " );} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}}public static void main(String[] args) throws InterruptedException {InstanceClassSynTest ins1 = new InstanceClassSynTest();Thread thread1 = new Thread(new MyThread(ins1));Thread thread2 = new Thread(new MyThread2()); // 由于傳入的對(duì)象是不同對(duì)象，線程執(zhí)行的順序是并行的thread1.start();thread2.start();Thread.sleep(6000);} }

下面演示一個(gè)比較經(jīng)典的錯(cuò)誤加鎖的案例

/*** 演示錯(cuò)誤加鎖* * @author ckj**/ public class IntegerSynTest {static class MyThread implements Runnable {private Integer i;public MyThread(Integer i) {this.i = i;}public void run() {synchronized (i) {Thread thread = Thread.currentThread();i++;System.out.println(i);try {thread.sleep(1000);} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}}}}public static void main(String[] args) {MyThread myThread = new MyThread(1);for(int i = 0;i<5;i++) {new Thread(myThread).start();}}}

按照我們預(yù)期結(jié)果的話輸入應(yīng)該是

2
3
4
5
6

結(jié)果應(yīng)該如上是2->3->4->5->6

實(shí)際結(jié)果是：

4
6
5
4
4
那哪里出問題了呢

增加日記打印

public void run() {synchronized (i) {Thread thread = Thread.currentThread();i++;System.out.println(thread.getName()+"-------"+i+"-@"+System.identityHashCode(i)+"----------"+"-@"+System.identityHashCode(this));try {thread.sleep(1000);} catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();}}}

System.identityHashCode 方法打印出原生Object 的hashCode 可以認(rèn)為他是內(nèi)存地址

Thread-1-------3-@1073512853-----------@825980954
Thread-2-------4-@923214033-----------@825980954
Thread-3-------5-@1428845299-----------@825980954
Thread-4-------6-@1534375319-----------@825980954
Thread-0-------3-@1073512853-----------@825980954
發(fā)現(xiàn)了原來 i 的對(duì)象一直在變，每次鎖的對(duì)象都發(fā)生的變化當(dāng)然得不到預(yù)期結(jié)果咯，那么為什么會(huì)這樣呢。通過反編譯工具打開class 類

public void run(){synchronized (this.i){Thread thread = Thread.currentThread();this.i = Integer.valueOf(this.i.intValue() + 1);System.out.println(thread.getName() + "-------" + this.i + "-@" + System.identityHashCode(this.i) + "----------" + "-@" + System.identityHashCode(this));try{Thread.sleep(1000L);}catch (Exception e){e.printStackTrace();}}}}

發(fā)現(xiàn)他調(diào)用了Integer.valueof 方法，查看一下

public static Integer valueOf(String s, int radix) throws NumberFormatException {return Integer.valueOf(parseInt(s,radix));}public static Integer valueOf(int i) {if (i >= IntegerCache.low && i <= IntegerCache.high)return IntegerCache.cache[i + (-IntegerCache.low)];return new Integer(i);}

他重新new 了一個(gè)出來，所以鎖不住了。

那我們?cè)趺刺幚砟?#xff1f;上面打印結(jié)果就可以看出了，我們直接鎖this 對(duì)象就可以解決問題了。

public void run() {synchronized (this) {Thread thread = Thread.currentThread();i++;System.out.println(thread.getName()+"-------"+i+"-@"+System.identityHashCode(i)+"----------"+"-@"+System.identityHashCode(this));try {thread.sleep(1000);} catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();}}}

?

總結(jié)

以上是生活随笔為你收集整理的并发编程-同步机制（一）的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。