當前位置:才華齋>IT認證>JAVA認證>

Java多執行緒同步問題

JAVA認證 閱讀(1.78W)

Java多執行緒的同步依靠的是物件鎖機制,synchronized關鍵字的背後就是利用了封鎖來實現對共享資源的互斥訪問。

Java多執行緒同步問題

下面以一個簡單的例項來進行對比分析。例項要完成的工作非常簡單,就是建立10個執行緒,每個執行緒都列印從0到99這100個數字,我們希望執行緒之間不會出現交叉亂序列印,而是順序地列印。

先來看第一段程式碼,這裡我們在run()方法中加入了synchronized關鍵字,希望能對run方法進行互斥訪問,但結果並不如我們希望那樣,這是因為這裡synchronized鎖住的是this物件,即當前執行執行緒物件本身。程式碼中建立了10個執行緒,而每個執行緒都持有this物件的物件鎖,這不能實現執行緒的同步。

程式碼

package a;

class MyThread implements able {

private int threadId;

public MyThread(int id) {

adId = id;

}

@Override

public synchronized void run() {

for (int i = 0; i 《 100; ++i) {

tln(“Thread ID: ” + adId + “ : ” + i);

}

}

}

public class ThreadDemo {

/**

* @param args

* @throws InterruptedException

*/

public static void main(String[] args) throws InterruptedException {

for (int i = 0; i 《 10; ++i) {

new Thread(new MyThread(i))。start();

p(1);

}

}

}

從上述程式碼段可以得知,要想實現執行緒的同步,則這些執行緒必須去競爭一個唯一的共享的物件鎖。

基於這種思想,我們將第一段程式碼修改如下所示,在建立啟動執行緒之前,先建立一個執行緒之間競爭使用的'Object物件,然後將這個Object物件的引用傳遞給每一個執行緒物件的lock成員變數。這樣一來,每個執行緒的lock成員都指向同一個Object物件。我們在run方法中,對lock物件使用synchronzied塊進行區域性封鎖,這樣就可以讓執行緒去競爭這個唯一的共享的物件鎖,從而實現同步。

程式碼

package a;

class MyThread implements able {

private int threadId;

private Object lock;

public MyThread(int id, Object obj) {

adId = id;

= obj;

}

@Override

public void run() {

synchronized (lock) {

for (int i = 0; i 《 100; ++i) {

tln(“Thread ID: ” + adId + “ : ” + i);

}

}

}

}

public class ThreadDemo {

/**

* @param args

* @throws InterruptedException

*/

public static void main(String[] args) throws InterruptedException {

Object obj = new Object();

for (int i = 0; i 《 10; ++i) {

new Thread(new MyThread(i, obj))。start();

p(1);

}

}

}