Java多線程同步問題

Java多線程的同步依靠的是對象鎖機制，synchronized關鍵字的背後就是利用了封鎖來實現對共享資源的互斥訪問。

下面以一個簡單的實例來進行對比分析。實例要完成的工作非常簡單，就是創建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);

}

}

}