Java線程同步問題--哲學(xué)家就餐
更新時(shí)間：2022年02月14日 14:27:11 作者：小黑說Java
這篇文章主要介紹了Java線程同步問題,線程的同步是保證多線程安全訪問競(jìng)爭(zhēng)資源的一種手段。線程的同步是Java多線程編程的難點(diǎn),下面文章舉例的方式講解Java線程同步，具有一定的參考價(jià)值,需要的朋友可以參考下
1.場(chǎng)景
有五位沉默的哲學(xué)家圍坐在一張圓桌旁，他們一生都在吃東西和思考。
有五只筷子供他們使用，哲學(xué)家需要雙手拿到一雙筷子之后才能吃飯；吃完后會(huì)將筷子放下繼續(xù)思考。
那么現(xiàn)在有一個(gè)問題，我們需要想出一種方案，如何保證哲學(xué)家們可以交替吃飯和思考，而不會(huì)被餓死。
上面這個(gè)問題是由Dijkstra提出的一個(gè)經(jīng)典的線程同步問題。
2.解決方案
我們?cè)陂_始想如何解決問題之前，可以先將這個(gè)場(chǎng)景通過代碼還原，在程序中進(jìn)行建模。
每一只筷子可以看做是一個(gè)資源數(shù)據(jù)，都可以被它兩邊的哲學(xué)家嘗試去獲取，并且同一時(shí)間只能由其中一人持有，這可以通過我們JUC包中的信號(hào)量Semaphore來表示。
然后，每個(gè)哲學(xué)家可以看做是一個(gè)線程，每個(gè)線程中的run方法內(nèi)容都是先進(jìn)行思考，然后試圖獲取左右兩邊的筷子吃飯，吃完飯后繼續(xù)思考。
通過上面的分析，我們的代碼實(shí)現(xiàn)如下：
/**
?* @author 小黑說Java
?* @ClassName DiningPhilosophers
?* @Description 哲學(xué)家就餐問題
?* @date 2022/2/6
?**/
@Slf4j
public class DiningPhilosophers implements Runnable {
? ? private final int id;
? ? public DiningPhilosophers(int id) {
? ? ? ? this.id = id;
? ? }
? ? private static final Random random = new Random(System.currentTimeMillis());
? ? private static final Semaphore[] forks = new Semaphore[5];
? ? // 初始化信號(hào)量,每個(gè)信號(hào)量為1，代表1只筷子
? ? static {
? ? ? ? forks[0] = new Semaphore(1);
? ? ? ? forks[1] = new Semaphore(1);
? ? ? ? forks[2] = new Semaphore(1);
? ? ? ? forks[3] = new Semaphore(1);
? ? ? ? forks[4] = new Semaphore(1);
? ? }
? ? @Override
? ? public void run() {
? ? ? ? try {
? ? ? ? ? ? while (true) {
? ? ? ? ? ? ? ? think();
? ? ? ? ? ? ? ? eat(id);
? ? ? ? ? ? }
? ? ? ? } catch (InterruptedException e) {
? ? ? ? ? ? log.error("異常中斷", e);
? ? ? ? }
? ? }
? ? /**
? ? ?* 哲學(xué)家思考隨機(jī)時(shí)間
? ? ?*/
? ? private void think() throws InterruptedException {
? ? ? ? TimeUnit.MILLISECONDS.sleep(random.nextInt(100));
? ? }
? ? private void eat(int id) {
? ? ? ? // TODO
? ? }
}接下來，我們思考一下，如何實(shí)現(xiàn)哲學(xué)家吃飯的邏輯。
當(dāng)一個(gè)哲學(xué)家需要吃飯時(shí)，他要拿起左右兩邊的筷子。
所以：
- 哲學(xué)家 A(0) 需要筷子0 和 4
- 哲學(xué)家 B(1) 需要筷子 1 和 0
- 哲學(xué)家 C(2) 需要筷子 2 和 1
- 哲學(xué)家 D(3) 需要筷子 3 和 2
- 哲學(xué)家 E(4) 需要筷子 4 和 3
所以每個(gè)哲學(xué)家線程都應(yīng)該有個(gè)編號(hào)，所以我在DiningPhilosophers中定義了屬性id表示哲學(xué)家的編號(hào)。
在吃飯方法中，需要根據(jù)id來決定獲取哪只筷子。
左手邊的筷子可以有用fork[id]表示；
右手邊的筷子用fork[(id+4)%5]表示。
那么我們的eat方法的實(shí)現(xiàn)如下：
private void eat(int id) throws InterruptedException {
? ? // 先拿左邊的筷子
? ? forks[id].acquire();
? ? // 然后拿右邊的筷子
? ? forks[(id + 4) % 5].acquire();
? ? // 吃一口飯
? ? log.info("哲學(xué)家{}正在吃飯~", id);
? ? // 依次放下左邊的筷子和右邊的筷子
? ? forks[id].release();
? ? forks[(id + 4) % 5].release();
}我們接著來測(cè)試我們的完整代碼。
/**
?* @author 小黑說Java
?* @ClassName DiningPhilosophers
?* @Description 哲學(xué)家就餐問題
?* @date 2022/2/6
?**/
@Slf4j
public class DiningPhilosophers implements Runnable {
? ? private final int id;
? ? public DiningPhilosophers(int id) {
? ? ? ? this.id = id;
? ? }
? ? private static final Random random = new Random(System.currentTimeMillis());
? ? private static final Semaphore[] forks = new Semaphore[5];
? ? // 初始化信號(hào)量,每個(gè)信號(hào)量為1，代表1只筷子
? ? static {
? ? ? ? forks[0] = new Semaphore(1);
? ? ? ? forks[1] = new Semaphore(1);
? ? ? ? forks[2] = new Semaphore(1);
? ? ? ? forks[3] = new Semaphore(1);
? ? ? ? forks[4] = new Semaphore(1);
? ? }
? ? @Override
? ? public void run() {
? ? ? ? try {
? ? ? ? ? ? while (true) {
? ? ? ? ? ? ? ? think();
? ? ? ? ? ? ? ? eat(id);
? ? ? ? ? ? }
? ? ? ? } catch (InterruptedException e) {
? ? ? ? ? ? log.error("異常中斷", e);
? ? ? ? }
? ? }
? ? /**
? ? ?* 哲學(xué)家思考隨機(jī)時(shí)間
? ? ?*/
? ? private void think() throws InterruptedException {
? ? ? ? TimeUnit.MILLISECONDS.sleep(random.nextInt(100));
? ? }
? ? private void eat(int id) throws InterruptedException {
? ? ? ? // 先拿左邊的筷子
? ? ? ? forks[id].acquire();
? ? ? ? // 然后拿右邊的筷子
? ? ? ? forks[(id + 4) % 5].acquire();
? ? ? ? // 吃一口飯
? ? ? ? log.info("哲學(xué)家{}正在吃飯~", id);
? ? ? ? // 依次放下左邊的筷子和右邊的筷子
? ? ? ? forks[id].release();
? ? ? ? forks[(id + 4) % 5].release();
? ? }
? ? public static void main(String[] args) {
? ? ? ? for (int i = 0; i < 5; i++) {
? ? ? ? ? ? new Thread(new DiningPhilosophers(i)).start();
? ? ? ? }
? ? }
}運(yùn)行上面的代碼后，會(huì)發(fā)現(xiàn)程序在運(yùn)行一段時(shí)間后會(huì)進(jìn)入死鎖狀態(tài)。
這種情況是因?yàn)?，在某一時(shí)刻，所有的哲學(xué)家都獲取到了左手邊的筷子，而無(wú)法獲取到右手邊的筷子，導(dǎo)致沒有人可以到東西，陷入僵局。
該如何避免出現(xiàn)這種死鎖問題呢？
方法一：限制吃飯的哲學(xué)家人數(shù)
很簡(jiǎn)單的一種方法，就是在一個(gè)時(shí)間點(diǎn)，只能有最多4個(gè)哲學(xué)家開始吃飯。4個(gè)哲學(xué)家分5只筷子，則永遠(yuǎn)不會(huì)發(fā)生死鎖。
要實(shí)現(xiàn)這種方法，我們可以再定義一個(gè)許可數(shù)為4的信號(hào)量Semaphore，表示剩余可以吃飯的哲學(xué)家名額。
代碼實(shí)現(xiàn)如下：
/**
?* @author 小黑說Java
?* @ClassName DiningPhilosophers
?* @Description 哲學(xué)家就餐問題
?* @date 2022/2/6
?**/
@Slf4j
public class DiningPhilosophers implements Runnable {
? ? private final int id;
? ? public DiningPhilosophers(int id) {
? ? ? ? this.id = id;
? ? }
? ? private static final Random random = new Random(System.currentTimeMillis());
? ? private static final Semaphore[] forks = new Semaphore[5];
? ? private static final Semaphore maxDiners = new Semaphore(4);
? ? // 初始化信號(hào)量,每個(gè)信號(hào)量為1，代表1只筷子
? ? static {
? ? ? ? forks[0] = new Semaphore(1);
? ? ? ? forks[1] = new Semaphore(1);
? ? ? ? forks[2] = new Semaphore(1);
? ? ? ? forks[3] = new Semaphore(1);
? ? ? ? forks[4] = new Semaphore(1);
? ? }
? ? @Override
? ? public void run() {
? ? ? ? try {
? ? ? ? ? ? while (true) {
? ? ? ? ? ? ? ? think();
? ? ? ? ? ? ? ? eat(id);
? ? ? ? ? ? }
? ? ? ? } catch (InterruptedException e) {
? ? ? ? ? ? log.error("異常中斷", e);
? ? ? ? }
? ? }
? ? /**
? ? ?* 哲學(xué)家思考隨機(jī)時(shí)間
? ? ?*/
? ? private void think() throws InterruptedException {
? ? ? ? TimeUnit.MILLISECONDS.sleep(random.nextInt(100));
? ? }
? ? private void eat(int id) throws InterruptedException {
? ? ? ? // 先獲得吃飯名額
? ? ? ? maxDiners.acquire();
? ? ? ? // 先拿左邊的筷子
? ? ? ? forks[id].acquire();
? ? ? ? // 然后拿右邊的筷子
? ? ? ? forks[(id + 4) % 5].acquire();
? ? ? ? // 吃一口飯
? ? ? ? log.info("哲學(xué)家{}正在吃飯~", id);
? ? ? ? // 依次放下左邊的筷子和右邊的筷子
? ? ? ? forks[id].release();
? ? ? ? forks[(id + 4) % 5].release();
? ? ? ? // 吃完之后歸還吃飯名額
? ? ? ? maxDiners.release();
? ? }
? ? public static void main(String[] args) {
? ? ? ? for (int i = 0; i < 5; i++) {
? ? ? ? ? ? new Thread(new DiningPhilosophers(i)).start();
? ? ? ? }
? ? }
}方法二：找到一個(gè)左撇子哲學(xué)家
這種方法是讓其中一個(gè)哲學(xué)家和其他哲學(xué)家拿筷子的順序和其他哲學(xué)家不一樣。
比如其他人都是先拿右手邊再拿左手邊，而這個(gè)左撇子哲學(xué)家則先拿左手邊再拿右手邊。
而哪一位哲學(xué)家被選為左撇子并不重要，因?yàn)樽雷邮菆A的，所以我們就選擇0號(hào)哲學(xué)家為左撇子。
代碼實(shí)現(xiàn)如下：
/**
?* @ClassName DiningPhilosophers
?* @Description 哲學(xué)家就餐問題
?* @date 2022/2/6
?**/
@Slf4j
public class DiningPhilosophers implements Runnable {
? ? private final int id;
? ? public DiningPhilosophers(int id) {
? ? ? ? this.id = id;
? ? }
? ? private static final Random random = new Random(System.currentTimeMillis());
? ? private static final Semaphore[] forks = new Semaphore[5];
? ? // 初始化信號(hào)量,每個(gè)信號(hào)量為1，代表1只筷子
? ? static {
? ? ? ? forks[0] = new Semaphore(1);
? ? ? ? forks[1] = new Semaphore(1);
? ? ? ? forks[2] = new Semaphore(1);
? ? ? ? forks[3] = new Semaphore(1);
? ? ? ? forks[4] = new Semaphore(1);
? ? }
? ? @Override
? ? public void run() {
? ? ? ? try {
? ? ? ? ? ? while (true) {
? ? ? ? ? ? ? ? think();
? ? ? ? ? ? ? ? eat(id);
? ? ? ? ? ? }
? ? ? ? } catch (InterruptedException e) {
? ? ? ? ? ? log.error("異常中斷", e);
? ? ? ? }
? ? }
? ? /**
? ? ?* 哲學(xué)家思考隨機(jī)時(shí)間
? ? ?*/
? ? private void think() throws InterruptedException {
? ? ? ? TimeUnit.MILLISECONDS.sleep(random.nextInt(100));
? ? }
? ? private void eat(int id) throws InterruptedException {
? ? ? ? if (id == 0) {
? ? ? ? ? ? hanleLeftFirst(id);
? ? ? ? } else {
? ? ? ? ? ? hanldRightFirst(id);
? ? ? ? }
? ? ? ? // 吃一口飯
? ? ? ? log.info("哲學(xué)家{}正在吃飯~", id);
? ? ? ? forks[id].release();
? ? ? ? forks[(id + 4) % 5].release();
? ? }
? ? private void hanleLeftFirst(int id) throws InterruptedException {
? ? ? ? forks[id].acquire();
? ? ? ? forks[(id + 4) % 5].acquire();
? ? }
? ? private void hanldRightFirst(int id) throws InterruptedException {
? ? ? ? forks[(id + 4) % 5].acquire();
? ? ? ? forks[id].acquire();
? ? }
? ? public static void main(String[] args) {
? ? ? ? for (int i = 0; i < 5; i++) {
? ? ? ? ? ? new Thread(new DiningPhilosophers(i)).start();
? ? ? ? }
? ? }
}到此這篇關(guān)于Java線程同步問題的文章就介紹到這了,更多相關(guān)Java線程同步內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
深入解析java HashMap實(shí)現(xiàn)原理
這篇文章主要介紹了深入解析java HashMap實(shí)現(xiàn)原理的相關(guān)資料,需要的朋友可以參考下2015-09-09
多態(tài)性是對(duì)象多種表現(xiàn)形式的體現(xiàn)。在面向?qū)ο笾校畛Ｒ姷亩鄳B(tài)發(fā)生在使用父類的引用來引用子類的對(duì)象。下面這篇文章主要給大家深入的介紹了Java三大特性中多態(tài)的相關(guān)資料，有需要的朋友可以參考借鑒，下面來一起看看吧。2017-01-01
java 實(shí)現(xiàn)取int型的第二個(gè)字節(jié)的數(shù)
這篇文章主要介紹了java 實(shí)現(xiàn)取int型的第二個(gè)字節(jié)的數(shù)，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2022-01-01
SpringBoot如何使用Fastjson解析Json數(shù)據(jù)
這篇文章主要介紹了SpringBoot如何使用Fastjson解析Json數(shù)據(jù),文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-03-03
Java中使用WebUploader插件上傳大文件單文件和多文件的方法小結(jié)
這篇文章主要介紹了Java中使用WebUploader插件上傳大文件單文件和多文件的方法小結(jié)的相關(guān)資料,需要的朋友可以參考下2016-06-06
這篇文章主要介紹了Mybatis insert方法主鍵回填和自定義操作，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-07-07
java實(shí)現(xiàn)圖的鄰接表存儲(chǔ)結(jié)構(gòu)的兩種方式及實(shí)例應(yīng)用詳解
這篇文章主要介紹了java實(shí)現(xiàn)圖的鄰接表存儲(chǔ)結(jié)構(gòu)的兩種方式及實(shí)例應(yīng)用詳解,鄰接表構(gòu)建圖是必須需要一個(gè)Graph對(duì)象，也就是圖對(duì)象！該對(duì)象包含屬性有：頂點(diǎn)數(shù)、邊數(shù)以及圖的頂點(diǎn)集合,需要的朋友可以參考下2019-06-06
@Autowired注解注入的xxxMapper報(bào)錯(cuò)問題及解決
這篇文章主要介紹了@Autowired注解注入的xxxMapper報(bào)錯(cuò)問題及解決，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-11-11
Eclipse+Java+Swing實(shí)現(xiàn)圖書管理系統(tǒng)(詳細(xì)代碼)
這篇文章主要介紹了Eclipse+Java+Swing實(shí)現(xiàn)圖書管理系統(tǒng)并附上詳細(xì)代碼，需要的小伙伴可以參考一下，希望對(duì)你有所幫助2022-01-01
java正則表達(dá)式簡(jiǎn)單使用和網(wǎng)頁(yè)爬蟲的制作代碼
java正則表達(dá)式簡(jiǎn)單使用和網(wǎng)頁(yè)爬蟲的制作代碼，需要的朋友可以參考一下2013-05-05