3 回答

TA貢獻(xiàn)1802條經(jīng)驗(yàn) 獲得超4個(gè)贊
問(wèn)題在public synchronized void run() { 相當(dāng)于 synchronized(this),而 main中
new Thread(new Test16(0,2,100)).start();
new Thread(new Test16(1,2,100)).start();
這樣是2個(gè)不同的test16對(duì)象,因而是2個(gè)不同的鎖,2個(gè)鎖都在等待自己的資源(2個(gè)線程都停止了),所以不可能被喚醒。其實(shí)樓主想鎖定的是共享的counter,counter的是static的,屬于類對(duì)象,所以要在類上加鎖才行。
代碼修改如下:
public void run() {
synchronized (Test16.class) {
while (counter < sum) {
while (turn != counter % num) {
try {
Test16.class.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
counter++;
System.out.println(counter + " turn : " + turn);
Test16.class.notifyAll();
}
}
}

TA貢獻(xiàn)1856條經(jīng)驗(yàn) 獲得超17個(gè)贊
樓主,根本原因是你這里用了兩個(gè)不同的對(duì)象,是不會(huì)實(shí)現(xiàn)互斥效果的
引用
new Thread(new Test16(0,2,100)).start();
new Thread(new Test16(1,2,100)).start();
這里兩個(gè)Test16的對(duì)象,每個(gè)對(duì)象都可以進(jìn)入你synchronized 的run方法。
這了互斥可以用類似生產(chǎn)者消費(fèi)者李模式這種概念,或者直接使用阻塞隊(duì)列,開(kāi)始時(shí)隊(duì)列只存放一個(gè)1,兩個(gè)線程輪流每次在隊(duì)列里取,取到消費(fèi)后,將加1的結(jié)果再放入隊(duì)列,此時(shí)notifyAll,另一個(gè)線程就可以取到數(shù)據(jù)。當(dāng)前線程就會(huì)阻塞,以此可以實(shí)現(xiàn)你要的效果。

TA貢獻(xiàn)1811條經(jīng)驗(yàn) 獲得超4個(gè)贊
while(turn!=counter%num){
try {
wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
turn不等于的時(shí)候,然后就wait,
線程調(diào)用了wait,就會(huì)進(jìn)入休眠狀態(tài)并且釋放鎖,直到其他線程調(diào)用相同對(duì)象的notify或者notifyAll,這個(gè)線程才會(huì)(notify的話只是有可能會(huì))重新進(jìn)入執(zhí)行隊(duì)列。當(dāng)這個(gè)線程開(kāi)始執(zhí)行的時(shí)候它會(huì)再次接管鎖并執(zhí)行wait后面的內(nèi)容(接管鎖這個(gè)動(dòng)作會(huì)等待鎖被其他線程釋放)。
添加回答
舉報(bào)