java 两个线程同步_Java 多线程（二）—— 线程的同步
實(shí)現(xiàn)Runnable接口
public classTestThread2 {public static voidmain(String [] args){
Window window=newWindow();
Thread thread1=new Thread(window,"窗口一");
Thread thread2=new Thread(window,"窗口二");
Thread thread3=new Thread(window,"窗口三");
thread1.start();
thread2.start();
thread3.start();
}
}class Window implementsRunnable{int ticket=50;
@Overridepublic voidrun(){while (true){if(ticket > 0){try{
Thread.currentThread().sleep(100);//模擬賣票需要一定的時(shí)間
} catch(InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName()+"售票，票號(hào)為："+ticket--);
}else{break;
}
}
}
}
運(yùn)行結(jié)果：
窗口二售票，票號(hào)為：13窗口三售票，票號(hào)為：12窗口一售票，票號(hào)為：11窗口二售票，票號(hào)為：10窗口一售票，票號(hào)為：10窗口三售票，票號(hào)為：10窗口三售票，票號(hào)為：9窗口一售票，票號(hào)為：8窗口二售票，票號(hào)為：7窗口三售票，票號(hào)為：6窗口一售票，票號(hào)為：5窗口二售票，票號(hào)為：4窗口三售票，票號(hào)為：3窗口一售票，票號(hào)為：2窗口二售票，票號(hào)為：1窗口三售票，票號(hào)為：0窗口一售票，票號(hào)為：-1
結(jié)果分析：這里出現(xiàn)了票數(shù)為0和負(fù)數(shù)還有重票的情況，這在現(xiàn)實(shí)生活中肯定是不存在的，那么為什么會(huì)出現(xiàn)這樣的情況呢？
當(dāng)票號(hào)為10時(shí)：A線程、B線程、C線程同時(shí)進(jìn)入到if(ticket > 0)的代碼塊中，A線程已經(jīng)執(zhí)行了打印輸出語(yǔ)句，但是還沒(méi)有做ticket--操作；
這時(shí)B線程就開(kāi)始執(zhí)行了打印操作，那么就會(huì)出現(xiàn)兩個(gè)線程打印票數(shù)一樣，即賣的是同一張票
當(dāng)票號(hào)為1時(shí)：A線程、B線程，C線程同時(shí)進(jìn)入到if(ticket > 0)的代碼塊中，A線程執(zhí)行了打印語(yǔ)句，并且已經(jīng)做完了ticket--操作，則此時(shí)ticket=0；
B線程再打印時(shí)就出現(xiàn)了0的情況，同理C線程打印就會(huì)出現(xiàn)-1的情況。
解決辦法：即我們不能同時(shí)讓超過(guò)兩個(gè)以上的線程進(jìn)入到 if(ticket > 0)的代碼塊中，不然就會(huì)出現(xiàn)上述的錯(cuò)誤。必須讓一個(gè)線程操作共享數(shù)據(jù)完畢以后，其他線程才有機(jī)會(huì)參與共享數(shù)據(jù)的操作。我們可以通過(guò)以下兩個(gè)辦法來(lái)解決：
1、使用 同步代碼塊
2、使用 同步方法
使用 同步代碼塊
synchronized(同步監(jiān)視器){//需要被同步的代碼塊(即為操作共享數(shù)據(jù)的代碼)
}
同步監(jiān)視器：由任意一個(gè)類的對(duì)象來(lái)充當(dāng)，哪個(gè)線程獲取此監(jiān)視器，誰(shuí)就執(zhí)行大括號(hào)里被同步的代碼。俗稱：鎖
要求：1、所有的線程必須公用同一把鎖！不能相對(duì)于線程是變化的對(duì)象；
2、并且只需鎖住操作共享數(shù)據(jù)的代碼，鎖多了或少了都不行；
實(shí)例：
1、實(shí)現(xiàn)的方式
public classTestWindow {public static voidmain(String [] args){
Window1 window=newWindow1();
Thread thread1=new Thread(window,"窗口一");
Thread thread2=new Thread(window,"窗口二");
Thread thread3=new Thread(window,"窗口三");
thread1.start();
thread2.start();
thread3.start();
}
}class Window1 implementsRunnable{int ticket=100;//共享數(shù)據(jù)
@Overridepublic voidrun(){while (true){synchronized (this){//this表示當(dāng)前對(duì)象，此時(shí)表示創(chuàng)建的 window
if(ticket > 0){try{//模擬賣票需要一定的時(shí)間
Thread.sleep(100);
}catch(InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName()+"售票，票號(hào)為："+ticket--);
}
}
}
}
}
注意：在實(shí)現(xiàn)的方式中，考慮同步的話，可以使用this充當(dāng)鎖，但在繼承的方式中，會(huì)創(chuàng)建多個(gè)對(duì)象，慎用this
2、繼承的方式
public classTestWindow1 {public static voidmain(String [] args){
Window2 window1=newWindow2();
Window2 window2=newWindow2();
window1.start();
window2.start();
}
}class Window2 extendsThread{static int ticket=100;//共享數(shù)據(jù)；注意聲明為 static,表示幾個(gè)窗口共享
static Object object=new Object();//用static 可以表示唯一
@Overridepublic voidrun(){while (true){//synchronized (this){//this表示當(dāng)前對(duì)象，此時(shí)表示創(chuàng)建的 window1和window2
synchronized (object){//鎖必須是唯一，不能每個(gè)線程都使用自己的一把鎖
if(ticket > 0){try{
Thread.sleep(200);
}catch(InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName()+"售票，票號(hào)為："+ticket--);
}
}
}
}
}
注意：1、繼承的方式會(huì)創(chuàng)建多個(gè)實(shí)例，所以共享資源需要用static來(lái)修飾，表示共享
2、繼承的方式會(huì)創(chuàng)建多個(gè)實(shí)例，所以this?表示不同的實(shí)例對(duì)象，這里表示widow1和window2,所以不能使用this當(dāng)鎖，此時(shí)可以定義一個(gè)?static?修飾的對(duì)象當(dāng)鎖
使用 同步方法
語(yǔ)法：即用 ?synchronized ?關(guān)鍵字修飾方法
將操作共享數(shù)據(jù)的方法聲明為synchronized。即此方法為同步方法，能夠保證當(dāng)其中一個(gè)線程執(zhí)行此方法時(shí)，其他線程再外等待直至此線程執(zhí)行完此方法。注意：同步方法的鎖：this
實(shí)例：
1、實(shí)現(xiàn)的方式
public classTestWindow2 {public static voidmain(String [] args){
Window3 window=newWindow3();
Thread thread1=new Thread(window,"窗口一");
Thread thread2=new Thread(window,"窗口二");
Thread thread3=new Thread(window,"窗口三");
thread1.start();
thread2.start();
thread3.start();
}
}class Window3 implementsRunnable{int ticket=100;//共享數(shù)據(jù)
@Overridepublic voidrun(){while (true){
show();
}
}public synchronized void show(){//this充當(dāng)鎖，此時(shí)表示創(chuàng)建的 window；//如果用繼承的方式，使用同步方法，這里表示創(chuàng)建的 window1和window2，繼承的方式不要使用同步方法
if(ticket > 0){try{
Thread.currentThread().sleep(100);
}catch(InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName()+"售票，票號(hào)為："+ticket--);
}
}
}
注意：1、synchronized 的鎖為this，這里表示創(chuàng)建的對(duì)象實(shí)例window；
2、繼承的時(shí)候t this 表示創(chuàng)建的window1和window2，繼承的方式不要使用同步方法。
總結(jié)
以上是生活随笔為你收集整理的java 两个线程同步_Java 多线程（二）—— 线程的同步的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇： [云炬创业管理笔记]第二章成为创业者讨论
- 下一篇： java 共享软件 保护_【Java并发