不太好的方法:用synchronized實(shí)現(xiàn)
當(dāng)其中一個(gè)線程一直持有鎖時(shí),會(huì)重復(fù)執(zhí)行 if 判斷,做無(wú)用功!
/**
* 兩個(gè)線程交替打印0-100的奇偶數(shù),
* 用synchronized關(guān)鍵字實(shí)現(xiàn)
*/
public class WaitNotifyPrintOddEvenSyn {
// 新建2個(gè)線程
// 1個(gè)只處理偶數(shù),第二個(gè)只處理奇數(shù)(用位運(yùn)算)
// 用synchronized來(lái)通信
private static int count;
private static final Object lock = new Object();
public static void main(String[] args) {
new Thread(new Runnable() {
@Override
public void run() {
while (count < 100) {
synchronized (lock) {
if ((count & 1) == 0) {
System.out.println(Thread.currentThread().getName() + ":" + count++);
}
}
}
}
}, "偶數(shù)線程").start();
new Thread(new Runnable() {
@Override
public void run() {
while (count < 100) {
synchronized (lock) {
if ((count & 1) == 1) {
System.out.println(Thread.currentThread().getName() + ":" + count++);
}
}
}
}
}, "奇數(shù)線程").start();
}
}
更好的實(shí)現(xiàn)方法:用wait和notify實(shí)現(xiàn)
/**
* 兩個(gè)線程交替打印0-100的奇偶數(shù),
* 用wait和notify實(shí)現(xiàn)
*/
public class WaitNotifyPrintOddEvenWait {
// 1.拿到鎖,就打印
// 2.打印完,喚醒其它線程,自己休眠
private static int count = 0;
private static final Object lock = new Object();
static class TurningRunner implements Runnable {
@Override
public void run() {
while (count <= 100) {
synchronized (lock) {
System.out.println(Thread.currentThread().getName() + ":" + count++);
lock.notify();
if (count <= 100) {
try {
lock.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
}
}
public static void main(String[] args) {
new Thread(new TurningRunner(), "偶數(shù)線程").start();
new Thread(new TurningRunner(), "奇數(shù)線程").start();
}
}
最后編輯于 :
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡(jiǎn)書(shū)系信息發(fā)布平臺(tái),僅提供信息存儲(chǔ)服務(wù)。