??????多線程的同步依靠的是對象鎖機制，synchronized關鍵字的背后就是利用了封鎖來實現對共享資源的互斥訪問。
??????下面以一個簡單的實例來進行對比分析。實例要完成的工作非常簡單，就是創建10個線程，每個線程都打印從0到99這100個數字，我們希望線程之間不會出現交叉亂序打印，而是順序地打印。
??????先來看第一段代碼，這里我們在run()方法中加入了synchronized關鍵字，希望能對run方法進行互斥訪問，但結果并不如我們希望那樣，這是因為這里synchronized鎖住的是this對象，即當前運行線程對象本身。代碼中創建了10個線程，而每個線程都持有this對象的對象鎖，這不能實現線程的同步。
class MyThread implements java.lang.Runnable
{
???private int threadId;
???public MyThread(int id)
???{
???????this.threadId = id;
???}
???
???public synchronized void run()
???{
???????for (int i = 0; i < 100; ++i)
???????{
???????????System.out.println("Thread ID: " + this.threadId + " : " + i);
???????}
???}
}
public class ThreadDemo
{
???public static void main(String[] args) throws InterruptedException
???{
???????for (int i = 0; i < 10; ++i)
???????{
???????????new Thread(new MyThread(i)).start();
???????????Thread.sleep(1);
???????}
???}
}
??????從上述代碼段可以得知，要想實現線程的同步，則這些線程必須去競爭一個唯一的共享的對象鎖。
??????基于這種思想，我們將第一段代碼修改如下所示，在創建啟動線程之前，先創建一個線程之間競爭使用的Object對象，然后將這個Object對象的引用傳遞給每一個線程對象的lock成員變量。這樣一來，每個線程的lock成員都指向同一個Object對象。我們在run方法中，對lock對象使用synchronzied塊進行局部封鎖，這樣就可以讓線程去競爭這個唯一的共享的對象鎖，從而實現同步。
class MyThread implements java.lang.Runnable
{
???private int threadId;
???private Object lock;
???public MyThread(int id, Object obj)
???{
???????this.threadId = id;
???????this.lock = obj;
???}
???
???publicvoid run()
???{
???????synchronized(lock)
???????{
???????????for (int i = 0; i < 100; ++i)
???????????{
???????????????System.out.println("Thread ID: " + this.threadId + " : " + i);
???????????}
???????}
???}
}
public class ThreadDemo
{
???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();
???????????Thread.sleep(1);
???????}
???}
}
??????從第二段代碼可知，同步的關鍵是多個線程對象競爭同一個共享資源即可，上面的代碼中是通過外部創建共享資源，然后傳遞到線程中來實現。我們也可以利用類成員變量被所有類的實例所共享這一特性，因此可以將lock用靜態成員對象來實現，代碼如下所示：
class MyThread implements java.lang.Runnable
{
???private int threadId;
???private static Object lock = new Object();
???public MyThread(int id)
???{
???????this.threadId = id;
??}
???publicvoid run()
???{
???????synchronized(lock)
???????{
???????????for (int i = 0; i < 100; ++i)
???????????{
???????????????System.out.println("Thread ID: " + this.threadId + " : " + i);
???????????}
???????}
???}
}
public class ThreadDemo
{
???public static void main(String[] args) throws InterruptedException
???{
???????for (int i = 0; i < 10; ++i)
???????{
???????????new Thread(new MyThread(i)).start();
???????????Thread.sleep(1);
???????}
???}
}
??????再來看第一段代碼，實例方法中加入sychronized關鍵字封鎖的是this對象本身，而在靜態方法中加入sychronized關鍵字封鎖的就是類本身。靜態方法是所有類實例對象所共享的，因此線程對象在訪問此靜態方法時是互斥訪問的，從而可以實現線程的同步，代碼如下所示：
class MyThread implements java.lang.Runnable
{
???private int threadId;
???
???public MyThread(int id)
???{
???????this.threadId = id;
???}
???
???publicvoid run()
???{
???????taskHandler(this.threadId);
???}
???private static synchronized void taskHandler(int threadId)
???{
???????for (int i = 0; i < 100; ++i)
???????{
???????????System.out.println("Thread ID: " + threadId + " : " + i);
???????}
???}
}
public class ThreadDemo
{
???public static void main(String[] args) throws InterruptedException
???{
???????for (int i = 0; i < 10; ++i)
???????{
???????????new Thread(new MyThread(i)).start();
???????????Thread.sleep(1);
???????}
???}
}
Java線程同步總結：
1、線程同步的目的是為了保護多個線程反問一個資源時對資源的破壞。
2、線程同步方法是通過鎖來實現，每個對象都有且僅有一個鎖，這個鎖與一個特定的對象關聯，線程一旦獲取了對象鎖，其他訪問該對象的線程就無法再訪問該對象的其他非同步方法。
3、對于靜態同步方法，鎖是針對這個類的，鎖對象是該類的Class對象。靜態和非靜態方法的鎖互不干預。一個線程獲得鎖，當在一個同步方法中訪問另外對象上的同步方法時，會獲取這兩個對象鎖。
4、對于同步，要時刻清醒在哪個對象上同步，這是關鍵。
5、編寫線程安全的類，需要時刻注意對多個線程競爭訪問資源的邏輯和安全做出正確的判斷，對“原子”操作做出分析，并保證原子操作期間別的線程無法訪問競爭資源。
6、當多個線程等待一個對象鎖時，沒有獲取到鎖的線程將發生阻塞。
7、死鎖是線程間相互等待鎖鎖造成的，在實際中發生的概率非常的小。真讓你寫個死鎖程序，不一定好使，呵呵。但是，一旦程序發生死鎖，程序將死掉。
posted on 2010-03-18 01:43
jadmin 閱讀(364)
評論(1) 編輯 收藏