共計 1257 個字符,預計需要花費 4 分鐘才能閱讀完成。
這篇文章主要介紹“Java 如何在兩個線程間進行通訊”,在日常操作中,相信很多人在 Java 如何在兩個線程間進行通訊問題上存在疑惑,丸趣 TV 小編查閱了各式資料,整理出簡單好用的操作方法,希望對大家解答”Java 如何在兩個線程間進行通訊”的疑惑有所幫助!接下來,請跟著丸趣 TV 小編一起來學習吧!
在并發編程中,我們必須考慮的問題時如何在兩個線程間進行通訊。這里的通訊指的是不同的線程之間如何交換信息。
目前有兩種方式:
共享內存
消息傳遞(actor 模型)
# 共享內存
共享內存這種方式比較常見,我們經常會設置一個共享變量。然后多個線程去操作同一個共享變量。從而達到線程通訊的目的。例如,我們使用多個線程去執行頁面抓取任務,我們可以使用一個共享變量 count 來記錄任務完成的數量。每當一個線程完成抓取任務,會在原來的 count 上執行加 1 操作。這樣每個線程都可以通過獲取這個 count 變量來獲得當前任務的完成情況。當然必須要考慮的是共享變量的同步問題,這也共享內存容易出錯的原因所在。
這種通訊模型中,不同的線程之間是沒有直接聯系的。都是通過共享變量這個“中間人”來進行交互。而這個“中間人”必要情況下還需被保護在臨界區內(加鎖或同步)。由此可見,一旦共享變量變得多起來,并且涉及到多種不同線程對象的交互,這種管理會變得非常復雜,極容易出現死鎖等問題。
給出案例
# 消息傳遞
消息傳遞方式采取的是線程之間的直接通信,不同的線程之間通過顯式的發送消息來達到交互目的。消息傳遞最有名的方式應該是 actor 模型了。在這種模型下,一切都是 actor,所有的 actor 之間的通信都必須通過傳遞消息才能達到。每個 actor 都有一個收件箱(消息隊列)用來保存收到其他 actor 傳遞來的消息。actor 自己也可以給自己發送消息。這才是面向對象的精髓啊!
這種模型看起來比共享內存模型要復雜。但是一旦碰到復雜業務的話,actor 模型的優勢就體現出來了。我們還是以剛才多線程抓取網站為例子看一下在這種模型下如何去解決。
首先我們定義一個統計 actor 用來統計任務完成量。然后把多個網址(消息方式)發給多個抓取 actor,抓取 actor 處理完任務后發送消息通知統計 actor 任務完成,統計 actor 對自己保存的變量 count(這個只有統計 actor 才能看到)加一。
最后讓我們來總結一下這兩種通訊模式:
并發模型通信機制同步機制共享內存線程之間共享程序的公共狀態,線程之間通過寫 - 讀內存中的公共狀態來隱式進行通信同步是顯式進行的。程序員必須顯式指定某個方法或某段代碼需要在線程之間互斥執行。消息傳遞(actor) 線程之間沒有公共狀態,線程之間必須通過明確的發送消息來顯式進行通信. 由于消息的發送必須在消息的接收之前,因此同步是隱式進行的。
到此,關于“Java 如何在兩個線程間進行通訊”的學習就結束了,希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學習,快去試試吧!若想繼續學習更多相關知識,請繼續關注丸趣 TV 網站,丸趣 TV 小編會繼續努力為大家帶來更多實用的文章!