??????多線程的同步依靠的是對(duì)象鎖機(jī)制，synchronized關(guān)鍵字的背后就是利用了封鎖來實(shí)現(xiàn)對(duì)共享資源的互斥訪問。
??????下面以一個(gè)簡(jiǎn)單的實(shí)例來進(jìn)行對(duì)比分析。實(shí)例要完成的工作非常簡(jiǎn)單，就是創(chuàng)建10個(gè)線程，每個(gè)線程都打印從0到99這100個(gè)數(shù)字，我們希望線程之間不會(huì)出現(xiàn)交叉亂序打印，而是順序地打印。
??????先來看第一段代碼，這里我們?cè)?/span>run()方法中加入了synchronized關(guān)鍵字，希望能對(duì)run方法進(jìn)行互斥訪問，但結(jié)果并不如我們希望那樣，這是因?yàn)檫@里synchronized鎖住的是this對(duì)象，即當(dāng)前運(yùn)行線程對(duì)象本身。代碼中創(chuàng)建了10個(gè)線程，而每個(gè)線程都持有this對(duì)象的對(duì)象鎖，這不能實(shí)現(xiàn)線程的同步。
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);
???????}
???}
}
??????從上述代碼段可以得知，要想實(shí)現(xiàn)線程的同步，則這些線程必須去競(jìng)爭(zhēng)一個(gè)唯一的共享的對(duì)象鎖。
??????基于這種思想，我們將第一段代碼修改如下所示，在創(chuàng)建啟動(dòng)線程之前，先創(chuàng)建一個(gè)線程之間競(jìng)爭(zhēng)使用的Object對(duì)象，然后將這個(gè)Object對(duì)象的引用傳遞給每一個(gè)線程對(duì)象的lock成員變量。這樣一來，每個(gè)線程的lock成員都指向同一個(gè)Object對(duì)象。我們?cè)?/span>run方法中，對(duì)lock對(duì)象使用synchronzied塊進(jìn)行局部封鎖，這樣就可以讓線程去競(jìng)爭(zhēng)這個(gè)唯一的共享的對(duì)象鎖，從而實(shí)現(xiàn)同步。
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);
???????}
???}
}
??????從第二段代碼可知，同步的關(guān)鍵是多個(gè)線程對(duì)象競(jìng)爭(zhēng)同一個(gè)共享資源即可，上面的代碼中是通過外部創(chuàng)建共享資源，然后傳遞到線程中來實(shí)現(xiàn)。我們也可以利用類成員變量被所有類的實(shí)例所共享這一特性，因此可以將lock用靜態(tài)成員對(duì)象來實(shí)現(xiàn)，代碼如下所示：
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);
???????}
???}
}
??????再來看第一段代碼，實(shí)例方法中加入sychronized關(guān)鍵字封鎖的是this對(duì)象本身，而在靜態(tài)方法中加入sychronized關(guān)鍵字封鎖的就是類本身。靜態(tài)方法是所有類實(shí)例對(duì)象所共享的，因此線程對(duì)象在訪問此靜態(tài)方法時(shí)是互斥訪問的，從而可以實(shí)現(xiàn)線程的同步，代碼如下所示：
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線程同步總結(jié)：
1、線程同步的目的是為了保護(hù)多個(gè)線程反問一個(gè)資源時(shí)對(duì)資源的破壞。
2、線程同步方法是通過鎖來實(shí)現(xiàn)，每個(gè)對(duì)象都有且僅有一個(gè)鎖，這個(gè)鎖與一個(gè)特定的對(duì)象關(guān)聯(lián)，線程一旦獲取了對(duì)象鎖，其他訪問該對(duì)象的線程就無法再訪問該對(duì)象的其他非同步方法。
3、對(duì)于靜態(tài)同步方法，鎖是針對(duì)這個(gè)類的，鎖對(duì)象是該類的Class對(duì)象。靜態(tài)和非靜態(tài)方法的鎖互不干預(yù)。一個(gè)線程獲得鎖，當(dāng)在一個(gè)同步方法中訪問另外對(duì)象上的同步方法時(shí)，會(huì)獲取這兩個(gè)對(duì)象鎖。
4、對(duì)于同步，要時(shí)刻清醒在哪個(gè)對(duì)象上同步，這是關(guān)鍵。
5、編寫線程安全的類，需要時(shí)刻注意對(duì)多個(gè)線程競(jìng)爭(zhēng)訪問資源的邏輯和安全做出正確的判斷，對(duì)“原子”操作做出分析，并保證原子操作期間別的線程無法訪問競(jìng)爭(zhēng)資源。
6、當(dāng)多個(gè)線程等待一個(gè)對(duì)象鎖時(shí)，沒有獲取到鎖的線程將發(fā)生阻塞。
7、死鎖是線程間相互等待鎖鎖造成的，在實(shí)際中發(fā)生的概率非常的小。真讓你寫個(gè)死鎖程序，不一定好使，呵呵。但是，一旦程序發(fā)生死鎖，程序?qū)⑺赖簟?/span>
posted on 2010-03-18 01:43
jadmin 閱讀(364)
評(píng)論(1) 編輯 收藏