Java多線程的同步示例及對象鎖機制

　　
代碼

　　
package comvista

　　
class MyThread implements javalangRunnable

　　
{

　　
private int threadId

　　
public MyThread(int id)

　　
{

　　
thisthreadId = id

　　
}

　　
@Override

　　
public synchronized void run()

　　
{

　　
for (int i = i < ++i)

　　
{

　　
Systemoutprintln(“Thread ID ” + thisthreadId + “ ” + i)

　　
}

　　
}

　　
}

　　
public class ThreadDemo

　　
{

　　
/**

　　
* @param args

　　
* @throws InterruptedException

　　
*/

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

　　
{

　　
for (int i = i < ++i)

　　
{

　　
new Thread(new MyThread(i))start()

　　
Threadsleep()

　　
}

　　
}

　　
}

　　
從上述代碼段可以得知要想實現線程的同步則這些線程必須去競爭一個唯一的共享的對象鎖

　　
基於這種思想我們將第一段代碼修改如下所示在創建啟動線程之前先創建一個線程之間競爭使用的Object對象然後將這個Object對象的引用 傳遞給每一個線程對象的lock成員變量這樣一來每個線程的lock成員都指向同一個Object對象我們在run方法中對lock對象使用 synchronzied塊進行局部封鎖這樣就可以讓線程去競爭這個唯一的共享的對象鎖從而實現同步

　　
代碼

　　
package comvista

　　
class MyThread implements javalangRunnable

　　
{

　　
private int threadId

　　
private Object lock

　　
public MyThread(int id Object obj)

　　
{

　　
thisthreadId = id

　　
thislock = obj

　　
}

　　
@Override

　　
public void run()

　　
{

　　
synchronized(lock)

　　
{

　　
for (int i = i < ++i)

　　
{

　　
Systemoutprintln(“Thread ID ” + thisthreadId + “ ” + i)

　　
}

　　
}

　　
}

　　
}

　　
public class ThreadDemo

　　
{

　　
/**

　　
* @param args

　　
* @throws InterruptedException

　　
*/

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

　　
{

　　
Object obj = new Object()

　　
for (int i = i < ++i)

　　
{

　　
new Thread(new MyThread(i obj))start()

　　
Threadsleep()

　　
}

　　
}

　　
}

　　
從第二段代碼可知同步的關鍵是多個線程對象競爭同一個共享資源即可上面的代碼中是通過外部創建共享資源然後傳遞到線程中來實現我們也可以利用類成員變量被所有類的實例所共享這一特性因此可以將lock用靜態成員對象來實現代碼如下所示

　　
代碼

　　
package comvista

　　
class MyThread implements javalangRunnable

　　
{

　　
private int threadId

　　
private static Object lock = new Object()

　　
public MyThread(int id)

　　
{

　　
thisthreadId = id

　　
}

　　
@Override

　　
public void run()

　　
{

　　
synchronized(lock)

　　
{

　　
for (int i = i < ++i)

　　
{

　　
Systemoutprintln(“Thread ID ” + thisthreadId + “ ” + i)

　　
}

　　
}

　　
}

　　
}

　　
public class ThreadDemo

　　
{

　　
/**

　　
* @param args

　　
* @throws InterruptedException

　　
*/

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

　　
{

　　
for (int i = i < ++i)

　　
{

　　
new Thread(new MyThread(i))start()

　　
Threadsleep()

　　
}

　　
}

　　
}

　　
再來看第一段代碼實例方法中加入sychronized關鍵字封鎖的是this對象本身而在靜態方法中加入sychronized關鍵字封鎖的就是 類本身靜態方法是所有類實例對象所共享的因此線程對象在訪問此靜態方法時是互斥訪問的從而可以實現線程的同步代碼如下所示

　　
代碼

　　
package comvista

　　
class MyThread implements javalangRunnable

　　
{

　　
private int threadId

　　
public MyThread(int id)

　　
{

　　
thisthreadId = id

　　
}

　　
@Override

　　
public void run()

　　
{

　　
taskHandler(thisthreadId)

　　
}

　　
private static synchronized void taskHandler(int threadId)

　　
{

　　
for (int i = i < ++i)

　　
{

　　
Systemoutprintln(“Thread ID ” + threadId + “ ” + i)

　　
}

　　
}

　　
}

　　
public class ThreadDemo

　　
{

　　
/**

　　
* @param args

　　
* @throws InterruptedException

　　
*/

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

　　
{

　　
for (int i = i < ++i)

　　
{

　　
new Thread(new MyThread(i))start()

　　
Threadsleep()

　　
}

　　
}