javaSE-(多執行緒)
1、多執行緒有什麼用?
一個可能在很多人看來很扯淡的一個問題:我會用多執行緒就好了,還管它有什麼用?在我看來,這個回答更扯淡。所謂”知其然知其所以然”,”會用”只是”知其然”,”為什麼用”才是”知其所以然”,只有達到”知其然知其所以然”的程度才可以說是把一個知識點運用自如。OK,下面說說我對這個問題的看法:
(1)發揮多核CPU的優勢
隨著工業的進步,現在的筆記本、桌上型電腦乃至商用的應用伺服器至少也都是雙核的,4核、8核甚至16核的也都不少見,如果是單執行緒的程式,那麼在雙核CPU上就浪費了50%,在4核CPU上就浪費了75%。單核CPU上所謂的”多執行緒”那是假的多執行緒,同一時間處理器只會處理一段邏輯,只不過執行緒之間切換得比較快,看著像多個執行緒”同時”執行罷了。多核CPU上的多執行緒才是真正的多執行緒,它能讓你的多段邏輯同時工作,多執行緒,可以真正發揮出多核CPU的優勢來,達到充分利用CPU的目的。
(2)防止阻塞
從程式執行效率的角度來看,單核CPU不但不會發揮出多執行緒的優勢,反而會因為在單核CPU上執行多執行緒導致執行緒上下文的切換,而降低程式整體的效率。但是單核CPU我們還是要應用多執行緒,就是為了防止阻塞。試想,如果單核CPU使用單執行緒,那麼只要這個執行緒阻塞了,比方說遠端讀取某個資料吧,對端遲遲未返回又沒有設定超時時間,那麼你的整個程式在資料返回回來之前就停止運行了。多執行緒可以防止這個問題,多條執行緒同時執行,哪怕一條執行緒的程式碼執行讀取資料阻塞,也不會影響其它任務的執行。
(3)便於建模
這是另外一個沒有這麼明顯的優點了。假設有一個大的任務A,單執行緒程式設計,那麼就要考慮很多,建立整個程式模型比較麻煩。但是如果把這個大的任務A分解成幾個小任務,任務B、任務C、任務D,分別建立程式模型,並通過多執行緒分別執行這幾個任務,那就簡單很多了。
2、建立執行緒的方式
比較常見的一個問題了,一般就是兩種:
(1)繼承Thread類
(2)實現Runnable介面
至於哪個好,不用說肯定是後者好,因為實現介面的方式比繼承類的方式更靈活,也能減少程式之間的耦合度,面向介面程式設計也是設計模式6大原則的核心。
3、start()方法和run()方法的區別
只有呼叫了start()方法,才會表現出多執行緒的特性,不同執行緒的run()方法裡面的程式碼交替執行。如果只是呼叫run()方法,那麼程式碼還是同步執行的,必須等待一個執行緒的run()方法裡面的程式碼全部執行完畢之後,另外一個執行緒才可以執行其run()方法裡面的程式碼。
4、Runnable介面和Callable介面的區別
有點深的問題了,也看出一個Java程式設計師學習知識的廣度。
Runnable介面中的run()方法的返回值是void,它做的事情只是純粹地去執行run()方法中的程式碼而已;Callable介面中的call()方法是有返回值的,是一個泛型,和Future、FutureTask配合可以用來獲取非同步執行的結果。
這其實是很有用的一個特性,因為多執行緒相比單執行緒更難、更復雜的一個重要原因就是因為多執行緒充滿著未知性,某條執行緒是否執行了?某條執行緒執行了多久?某條執行緒執行的時候我們期望的資料是否已經賦值完畢?無法得知,我們能做的只是等待這條多執行緒的任務執行完畢而已。而Callable+Future/FutureTask卻可以獲取多執行緒執行的結果,可以在等待時間太長沒獲取到需要的資料的情況下取消該執行緒的任務,真的是非常有用。
5、CyclicBarrier和CountDownLatch的區別
兩個看上去有點像的類,都在java.util.concurrent下,都可以用來表示程式碼執行到某個點上,二者的區別在於:
(1)CyclicBarrier的某個執行緒執行到某個點上之後,該執行緒即停止執行,直到所有的執行緒都到達了這個點,所有執行緒才重新執行;CountDownLatch則不是,某執行緒執行到某個點上之後,只是給某個數值-1而已,該執行緒繼續執行
(2)CyclicBarrier只能喚起一個任務,CountDownLatch可以喚起多個任務
(3)CyclicBarrier可重用,CountDownLatch不可重用,計數值為0該CountDownLatch就不可再用了
6、Volatile關鍵字的作用
一個非常重要的問題,是每個學習、應用多執行緒的Java程式設計師都必須掌握的。理解volatile關鍵字的作用的前提是要理解Java記憶體模型,這裡就不講Java記憶體模型了,可以參見第31點,volatile關鍵字的作用主要有兩個:
(1)多執行緒主要圍繞可見性和原子性兩個特性而展開,使用volatile關鍵字修飾的變數,保證了其在多執行緒之間的可見性,即每次讀取到volatile變數,一定是最新的資料
(2)程式碼底層執行不像我們看到的高階語言—-Java程式這麼簡單,它的執行是Java程式碼–>位元組碼–>根據位元組碼執行對應的C/C++程式碼–>C/C++程式碼被編譯成組合語言–>和硬體電路互動,現實中,為了獲取更好的效能JVM可能會對指令進行重排序,多執行緒下可能會出現一些意想不到的問題。使用volatile則會對禁止語義重排序,當然這也一定程度上降低了程式碼執行效率
從實踐角度而言,volatile的一個重要作用就是和CAS結合,保證了原子性,詳細的可以參見java.util.concurrent.atomic包下的類,比如AtomicInteger。
7、什麼是執行緒安全
又是一個理論的問題,各式各樣的答案有很多,我給出一個個人認為解釋地最好的:如果你的程式碼在多執行緒下執行和在單執行緒下執行永遠都能獲得一樣的結果,那麼你的程式碼就是執行緒安全的。
這個問題有值得一提的地方,就是執行緒安全也是有幾個級別的:
(1)不可變
像String、Integer、Long這些,都是final型別的類,任何一個執行緒都改變不了它們的值,要改變除非新建立一個,因此這些不可變物件不需要任何同步手段就可以直接在多執行緒環境下使用
(2)絕對執行緒安全
不管執行時環境如何,呼叫者都不需要額外的同步措施。要做到這一點通常需要付出許多額外的代價,Java中標註自己是執行緒安全的類,實際上絕大多數都不是執行緒安全的,不過絕對執行緒安全的類,Java中也有,比方說CopyOnWriteArrayList、CopyOnWriteArraySet
(3)相對執行緒安全
相對執行緒安全也就是我們通常意義上所說的執行緒安全,像Vector這種,add、remove方法都是原子操作,不會被打斷,但也僅限於此,如果有個執行緒在遍歷某個Vector、有個執行緒同時在add這個Vector,99%的情況下都會出現ConcurrentModificationException,也就是fail-fast機制。
(4)執行緒非安全
這個就沒什麼好說的了,ArrayList、LinkedList、HashMap等都是執行緒非安全的類
8、Java中如何獲取到執行緒dump檔案
死迴圈、死鎖、阻塞、頁面開啟慢等問題,打執行緒dump是最好的解決問題的途徑。所謂執行緒dump也就是執行緒堆疊,獲取到執行緒堆疊有兩步:
(1)獲取到執行緒的pid,可以通過使用jps命令,在Linux環境下還可以使用ps -ef | grep java
(2)列印執行緒堆疊,可以通過使用jstack pid命令,在Linux環境下還可以使用kill -3 pid
另外提一點,Thread類提供了一個getStackTrace()方法也可以用於獲取執行緒堆疊。這是一個例項方法,因此此方法是和具體執行緒例項繫結的,每次獲取獲取到的是具體某個執行緒當前執行的堆疊,
9、一個執行緒如果出現了執行時異常會怎麼樣
如果這個異常沒有被捕獲的話,這個執行緒就停止執行了。另外重要的一點是:如果這個執行緒持有某個某個物件的監視器,那麼這個物件監視器會被立即釋放
10、如何在兩個執行緒之間共享資料
通過線上程之間共享物件就可以了,然後通過wait/notify/notifyAll、await/signal/signalAll進行喚起和等待,比方說阻塞佇列BlockingQueue就是為執行緒之間共享資料而設計的
11、sleep方法和wait方法有什麼區別
這個問題常問,sleep方法和wait方法都可以用來放棄CPU一定的時間,不同點在於如果執行緒持有某個物件的監視器,sleep方法不會放棄這個物件的監視器,wait方法會放棄這個物件的監視器
12、生產者消費者模型的作用是什麼
這個問題很理論,但是很重要:
(1)通過平衡生產者的生產能力和消費者的消費能力來提升整個系統的執行效率,這是生產者消費者模型最重要的作用
(2)解耦,這是生產者消費者模型附帶的作用,解耦意味著生產者和消費者之間的聯絡少,聯絡越少越可以獨自發展而不需要收到相互的制約
13、ThreadLocal有什麼用
簡單說ThreadLocal就是一種以空間換時間的做法,在每個Thread裡面維護了一個以開地址法實現的ThreadLocal.ThreadLocalMap,把資料進行隔離,資料不共享,自然就沒有執行緒安全方面的問題了
14、為什麼wait()方法和notify()/notifyAll()方法要在同步塊中被呼叫
這是JDK強制的,wait()方法和notify()/notifyAll()方法在呼叫前都必須先獲得物件的鎖
15、wait()方法和notify()/notifyAll()方法在放棄物件監視器時有什麼區別
wait()方法和notify()/notifyAll()方法在放棄物件監視器的時候的區別在於:wait()方法立即釋放物件監視器,notify()/notifyAll()方法則會等待執行緒剩餘程式碼執行完畢才會放棄物件監視器。
16、為什麼要使用執行緒池
避免頻繁地建立和銷燬執行緒,達到執行緒物件的重用。另外,使用執行緒池還可以根據專案靈活地控制併發的數目。
17、怎麼檢測一個執行緒是否持有物件監視器
我也是在網上看到一道多執行緒面試題才知道有方法可以判斷某個執行緒是否持有物件監視器:Thread類提供了一個holdsLock(Object obj)方法,當且僅當物件obj的監視器被某條執行緒持有的時候才會返回true,注意這是一個static方法,這意味著“某條執行緒”指的是當前執行緒。
18、synchronized和ReentrantLock的區別
synchronized是和if、else、for、while一樣的關鍵字,ReentrantLock是類,這是二者的本質區別。既然ReentrantLock是類,那麼它就提供了比synchronized更多更靈活的特性,可以被繼承、可以有方法、可以有各種各樣的類變數,ReentrantLock比synchronized的擴充套件性體現在幾點上:
(1)ReentrantLock可以對獲取鎖的等待時間進行設定,這樣就避免了死鎖
(2)ReentrantLock可以獲取各種鎖的資訊
(3)ReentrantLock可以靈活地實現多路通知
另外,二者的鎖機制其實也是不一樣的。ReentrantLock底層呼叫的是Unsafe的park方法加鎖,synchronized操作的應該是物件頭中mark word,這點我不能確定。
19、ConcurrentHashMap的併發度是什麼
ConcurrentHashMap的併發度就是segment的大小,預設為16,這意味著最多同時可以有16條執行緒操作ConcurrentHashMap,這也是ConcurrentHashMap對Hashtable的最大優勢,任何情況下,Hashtable能同時有兩條執行緒獲取Hashtable中的資料嗎?
20、ReadWriteLock是什麼
首先明確一下,不是說ReentrantLock不好,只是ReentrantLock某些時候有侷限。如果使用ReentrantLock,可能本身是為了防止執行緒A在寫資料、執行緒B在讀資料造成的資料不一致,但這樣,如果執行緒C在讀資料、執行緒D也在讀資料,讀資料是不會改變資料的,沒有必要加鎖,但是還是加鎖了,降低了程式的效能。
因為這個,才誕生了讀寫鎖ReadWriteLock。ReadWriteLock是一個讀寫鎖介面,ReentrantReadWriteLock是ReadWriteLock介面的一個具體實現,實現了讀寫的分離,讀鎖是共享的,寫鎖是獨佔的,讀和讀之間不會互斥,讀和寫、寫和讀、寫和寫之間才會互斥,提升了讀寫的效能。
21、FutureTask是什麼
這個其實前面有提到過,FutureTask表示一個非同步運算的任務。FutureTask裡面可以傳入一個Callable的具體實現類,可以對這個非同步運算的任務的結果進行等待獲取、判斷是否已經完成、取消任務等操作。當然,由於FutureTask也是Runnable介面的實現類,所以FutureTask也可以放入執行緒池中。
22、Linux環境下如何查詢哪個執行緒使用CPU最長
這是一個比較偏實踐的問題,這種問題我覺得挺有意義的。可以這麼做:
(1)獲取專案的pid,jps或者ps -ef | grep java,這個前面有講過
(2)top -H -p pid,順序不能改變
這樣就可以打印出當前的專案,每條執行緒佔用CPU時間的百分比。注意這裡打出的是LWP,也就是作業系統原生執行緒的執行緒號,我筆記本山沒有部署Linux環境下的Java工程,因此沒有辦法截圖演示,網友朋友們如果公司是使用Linux環境部署專案的話,可以嘗試一下。
使用”top -H -p pid”+”jps pid”可以很容易地找到某條佔用CPU高的執行緒的執行緒堆疊,從而定位佔用CPU高的原因,一般是因為不當的程式碼操作導致了死迴圈。
最後提一點,”top -H -p pid”打出來的LWP是十進位制的,”jps pid”打出來的本地執行緒號是十六進位制的,轉換一下,就能定位到佔用CPU高的執行緒的當前執行緒堆疊了。
23、Java程式設計寫一個會導致死鎖的程式
第一次看到這個題目,覺得這是一個非常好的問題。很多人都知道死鎖是怎麼一回事兒:執行緒A和執行緒B相互等待對方持有的鎖導致程式無限死迴圈下去。當然也僅限於此了,問一下怎麼寫一個死鎖的程式就不知道了,這種情況說白了就是不懂什麼是死鎖,懂一個理論就完事兒了,實踐中碰到死鎖的問題基本上是看不出來的。
真正理解什麼是死鎖,這個問題其實不難,幾個步驟:
(1)兩個執行緒裡面分別持有兩個Object物件:lock1和lock2。這兩個lock作為同步程式碼塊的鎖;
(2)執行緒1的run()方法中同步程式碼塊先獲取lock1的物件鎖,Thread.sleep(xxx),時間不需要太多,50毫秒差不多了,然後接著獲取lock2的物件鎖。這麼做主要是為了防止執行緒1啟動一下子就連續獲得了lock1和lock2兩個物件的物件鎖
(3)執行緒2的run)(方法中同步程式碼塊先獲取lock2的物件鎖,接著獲取lock1的物件鎖,當然這時lock1的物件鎖已經被執行緒1鎖持有,執行緒2肯定是要等待執行緒1釋放lock1的物件鎖的
這樣,執行緒1″睡覺”睡完,執行緒2已經獲取了lock2的物件鎖了,執行緒1此時嘗試獲取lock2的物件鎖,便被阻塞,此時一個死鎖就形成了。程式碼就不寫了,佔的篇幅有點多,Java多執行緒7:死鎖這篇文章裡面有,就是上面步驟的程式碼實現。
24、怎麼喚醒一個阻塞的執行緒
如果執行緒是因為呼叫了wait()、sleep()或者join()方法而導致的阻塞,可以中斷執行緒,並且通過丟擲InterruptedException來喚醒它;如果執行緒遇到了IO阻塞,無能為力,因為IO是作業系統實現的,Java程式碼並沒有辦法直接接觸到作業系統。
25、不可變物件對多執行緒有什麼幫助
前面有提到過的一個問題,不可變物件保證了物件的記憶體可見性,對不可變物件的讀取不需要進行額外的同步手段,提升了程式碼執行效率。
26、什麼是多執行緒的上下文切換
多執行緒的上下文切換是指CPU控制權由一個已經正在執行的執行緒切換到另外一個就緒並等待獲取CPU執行權的執行緒的過程。
27、如果你提交任務時,執行緒池佇列已滿,這時會發生什麼
如果你使用的LinkedBlockingQueue,也就是無界佇列的話,沒關係,繼續新增任務到阻塞佇列中等待執行,因為LinkedBlockingQueue可以近乎認為是一個無窮大的佇列,可以無限存放任務;如果你使用的是有界佇列比方說ArrayBlockingQueue的話,任務首先會被新增到ArrayBlockingQueue中,ArrayBlockingQueue滿了,則會使用拒絕策略RejectedExecutionHandler處理滿了的任務,預設是AbortPolicy。
28、Java中用到的執行緒排程演算法是什麼
搶佔式。一個執行緒用完CPU之後,作業系統會根據執行緒優先順序、執行緒飢餓情況等資料算出一個總的優先順序並分配下一個時間片給某個執行緒執行。
29、Thread.sleep(0)的作用是什麼
這個問題和上面那個問題是相關的,我就連在一起了。由於Java採用搶佔式的執行緒排程演算法,因此可能會出現某條執行緒常常獲取到CPU控制權的情況,為了讓某些優先順序比較低的執行緒也能獲取到CPU控制權,可以使用Thread.sleep(0)手動觸發一次作業系統分配時間片的操作,這也是平衡CPU控制權的一種操作。
30、什麼是自旋
很多synchronized裡面的程式碼只是一些很簡單的程式碼,執行時間非常快,此時等待的執行緒都加鎖可能是一種不太值得的操作,因為執行緒阻塞涉及到使用者態和核心態切換的問題。既然synchronized裡面的程式碼執行地非常快,不妨讓等待鎖的執行緒不要被阻塞,而是在synchronized的邊界做忙迴圈,這就是自旋。如果做了多次忙迴圈發現還沒有獲得鎖,再阻塞,這樣可能是一種更好的策略。
31、什麼是Java記憶體模型
Java記憶體模型定義了一種多執行緒訪問Java記憶體的規範。Java記憶體模型要完整講不是這裡幾句話能說清楚的,我簡單總結一下Java記憶體模型的幾部分內容:
(1)Java記憶體模型將記憶體分為了主記憶體和工作記憶體。類的狀態,也就是類之間共享的變數,是儲存在主記憶體中的,每次Java執行緒用到這些主記憶體中的變數的時候,會讀一次主記憶體中的變數,並讓這些記憶體在自己的工作記憶體中有一份拷貝,執行自己執行緒程式碼的時候,用到這些變數,操作的都是自己工作記憶體中的那一份。線上程程式碼執行完畢之後,會將最新的值更新到主記憶體中去
(2)定義了幾個原子操作,用於操作主記憶體和工作記憶體中的變數
(3)定義了volatile變數的使用規則
(4)happens-before,即先行發生原則,定義了操作A必然先行發生於操作B的一些規則,比如在同一個執行緒內控制流前面的程式碼一定先行發生於控制流後面的程式碼、一個釋放鎖unlock的動作一定先行發生於後面對於同一個鎖進行鎖定lock的動作等等,只要符合這些規則,則不需要額外做同步措施,如果某段程式碼不符合所有的happens-before規則,則這段程式碼一定是執行緒非安全的
32、什麼是CAS
CAS,全稱為Compare and Set,即比較-設定。假設有三個運算元:記憶體值V、舊的預期值A、要修改的值B,當且僅當預期值A和記憶體值V相同時,才會將記憶體值修改為B並返回true,否則什麼都不做並返回false。當然CAS一定要volatile變數配合,這樣才能保證每次拿到的變數是主記憶體中最新的那個值,否則舊的預期值A對某條執行緒來說,永遠是一個不會變的值A,只要某次CAS操作失敗,永遠都不可能成功。
33、什麼是樂觀鎖和悲觀鎖
(1)樂觀鎖:就像它的名字一樣,對於併發間操作產生的執行緒安全問題持樂觀狀態,樂觀鎖認為競爭不總是會發生,因此它不需要持有鎖,將比較-設定這兩個動作作為一個原子操作嘗試去修改記憶體中的變數,如果失敗則表示發生衝突,那麼就應該有相應的重試邏輯。
(2)悲觀鎖:還是像它的名字一樣,對於併發間操作產生的執行緒安全問題持悲觀狀態,悲觀鎖認為競爭總是會發生,因此每次對某資源進行操作時,都會持有一個獨佔的鎖,就像synchronized,不管三七二十一,直接上了鎖就操作資源了。
34、什麼是AQS
簡單說一下AQS,AQS全稱為AbstractQueuedSychronizer,翻譯過來應該是抽象佇列同步器。
如果說java.util.concurrent的基礎是CAS的話,那麼AQS就是整個Java併發包的核心了,ReentrantLock、CountDownLatch、Semaphore等等都用到了它。AQS實際上以雙向佇列的形式連線所有的Entry,比方說ReentrantLock,所有等待的執行緒都被放在一個Entry中並連成雙向佇列,前面一個執行緒使用ReentrantLock好了,則雙向佇列實際上的第一個Entry開始執行。
AQS定義了對雙向佇列所有的操作,而只開放了tryLock和tryRelease方法給開發者使用,開發者可以根據自己的實現重寫tryLock和tryRelease方法,以實現自己的併發功能。
35、單例模式的執行緒安全性
老生常談的問題了,首先要說的是單例模式的執行緒安全意味著:某個類的例項在多執行緒環境下只會被建立一次出來。單例模式有很多種的寫法,我總結一下:
(1)餓漢式單例模式的寫法:執行緒安全
(2)懶漢式單例模式的寫法:非執行緒安全
(3)雙檢鎖單例模式的寫法:執行緒安全
36、Semaphore有什麼作用
Semaphore就是一個訊號量,它的作用是限制某段程式碼塊的併發數。Semaphore有一個建構函式,可以傳入一個int型整數n,表示某段程式碼最多隻有n個執行緒可以訪問,如果超出了n,那麼請等待,等到某個執行緒執行完畢這段程式碼塊,下一個執行緒再進入。由此可以看出如果Semaphore建構函式中傳入的int型整數n=1,相當於變成了一個synchronized了。
37、Hashtable的size()方法中明明只有一條語句”return count”,為什麼還要做同步?
這是我之前的一個困惑,不知道大家有沒有想過這個問題。某個方法中如果有多條語句,並且都在操作同一個類變數,那麼在多執行緒環境下不加鎖,勢必會引發執行緒安全問題,這很好理解,但是size()方法明明只有一條語句,為什麼還要加鎖?
關於這個問題,在慢慢地工作、學習中,有了理解,主要原因有兩點:
(1)同一時間只能有一條執行緒執行固定類的同步方法,但是對於類的非同步方法,可以多條執行緒同時訪問。所以,這樣就有問題了,可能執行緒A在執行Hashtable的put方法新增資料,執行緒B則可以正常呼叫size()方法讀取Hashtable中當前元素的個數,那讀取到的值可能不是最新的,可能執行緒A添加了完了資料,但是沒有對size++,執行緒B就已經讀取size了,那麼對於執行緒B來說讀取到的size一定是不準確的。而給size()方法加了同步之後,意味著執行緒B呼叫size()方法只有在執行緒A呼叫put方法完畢之後才可以呼叫,這樣就保證了執行緒安全性
(2)CPU執行程式碼,執行的不是Java程式碼,這點很關鍵,一定得記住。Java程式碼最終是被翻譯成彙編程式碼執行的,彙編程式碼才是真正可以和硬體電路互動的程式碼。即使你看到Java程式碼只有一行,甚至你看到Java程式碼編譯之後生成的位元組碼也只有一行,也不意味著對於底層來說這句語句的操作只有一個。一句”return count”假設被翻譯成了三句彙編語句執行,完全可能執行完第一句,執行緒就切換了。
38、執行緒類的構造方法、靜態塊是被哪個執行緒呼叫的
這是一個非常刁鑽和狡猾的問題。請記住:執行緒類的構造方法、靜態塊是被new這個執行緒類所在的執行緒所呼叫的,而run方法裡面的程式碼才是被執行緒自身所呼叫的。
如果說上面的說法讓你感到困惑,那麼我舉個例子,假設Thread2中new了Thread1,main函式中new了Thread2,那麼:
(1)Thread2的構造方法、靜態塊是main執行緒呼叫的,Thread2的run()方法是Thread2自己呼叫的
(2)Thread1的構造方法、靜態塊是Thread2呼叫的,Thread1的run()方法是Thread1自己呼叫的
39、同步方法和同步塊,哪個是更好的選擇
同步塊,這意味著同步塊之外的程式碼是非同步執行的,這比同步整個方法更提升程式碼的效率。請知道一條原則:同步的範圍越少越好。
藉著這一條,我額外提一點,雖說同步的範圍越少越好,但是在Java虛擬機器中還是存在著一種叫做鎖粗化的優化方法,這種方法就是把同步範圍變大。這是有用的,比方說StringBuffer,它是一個執行緒安全的類,自然最常用的append()方法是一個同步方法,我們寫程式碼的時候會反覆append字串,這意味著要進行反覆的加鎖->解鎖,這對效能不利,因為這意味著Java虛擬機器在這條執行緒上要反覆地在核心態和使用者態之間進行切換,因此Java虛擬機器會將多次append方法呼叫的程式碼進行一個鎖粗化的操作,將多次的append的操作擴充套件到append方法的頭尾,變成一個大的同步塊,這樣就減少了加鎖–>解鎖的次數,有效地提升了程式碼執行的效率。
40、高併發、任務執行時間短的業務怎樣使用執行緒池?併發不高、任務執行時間長的業務怎樣使用執行緒池?併發高、業務執行時間長的業務怎樣使用執行緒池?
這是我在併發程式設計網上看到的一個問題,把這個問題放在最後一個,希望每個人都能看到並且思考一下,因為這個問題非常好、非常實際、非常專業。關於這個問題,個人看法是:
(1)高併發、任務執行時間短的業務,執行緒池執行緒數可以設定為CPU核數+1,減少執行緒上下文的切換
(2)併發不高、任務執行時間長的業務要區分開看:
a)假如是業務時間長集中在IO操作上,也就是IO密集型的任務,因為IO操作並不佔用CPU,所以不要讓所有的CPU閒下來,可以加大執行緒池中的執行緒數目,讓CPU處理更多的業務
b)假如是業務時間長集中在計算操作上,也就是計算密集型任務,這個就沒辦法了,和(1)一樣吧,執行緒池中的執行緒數設定得少一些,減少執行緒上下文的切換
(3)併發高、業務執行時間長,解決這種型別任務的關鍵不在於執行緒池而在於整體架構的設計,看看這些業務裡面某些資料是否能做快取是第一步,增加伺服器是第二步,至於執行緒池的設定,設定參考(2)。最後,業務執行時間長的問題,也可能需要分析一下,看看能不能使用中介軟體對任務進行拆分和解耦。
- 多執行緒:指的是這個程式(一個程序)執行時產生了不止一個執行緒
- 並行與併發:
- 並行:多個cpu例項或者多臺機器同時執行一段處理邏輯,是真正的同時。
- 併發:通過cpu排程演算法,讓使用者看上去同時執行,實際上從cpu操作層面不是真正的同時。併發往往在場景中有公用的資源,那麼針對這個公用的資源往往產生瓶頸,我們會用TPS或者QPS來反應這個系統的處理能力。
併發與並行
- 執行緒安全:經常用來描繪一段程式碼。指在併發的情況之下,該程式碼經過多執行緒使用,執行緒的排程順序不影響任何結果。這個時候使用多執行緒,我們只需要關注系統的記憶體,cpu是不是夠用即可。反過來,執行緒不安全就意味著執行緒的排程順序會影響最終結果,如不加事務的轉賬程式碼:
void transferMoney(User from, User to, float amount){ to.setMoney(to.getBalance() + amount); from.setMoney(from.getBalance() - amount); }
- 同步:Java中的同步指的是通過人為的控制和排程,保證共享資源的多執行緒訪問成為執行緒安全,來保證結果的準確。如上面的程式碼簡單加入
@synchronized
關鍵字。在保證結果準確的同時,提高效能,才是優秀的程式。執行緒安全的優先順序高於效能。
好了,讓我們開始吧。我準備分成幾部分來總結涉及到多執行緒的內容:
- 紮好馬步:執行緒的狀態
- 內功心法:每個物件都有的方法(機制)
- 太祖長拳:基本執行緒類
- 九陰真經:高階多執行緒控制類
紮好馬步:執行緒的狀態
先來兩張圖:
執行緒狀態
執行緒狀態轉換
各種狀態一目瞭然,值得一提的是"Blocked"和"Waiting"這兩個狀態的區別:
執行緒在Running的過程中可能會遇到阻塞(Blocked)情況
對Running狀態的執行緒加同步鎖(Synchronized)使其進入(lock blocked pool ),同步鎖被釋放進入可執行狀態(Runnable)。從jdk原始碼註釋來看,blocked指的是對monitor的等待(可以參考下文的圖)即該執行緒位於等待區。執行緒在Running的過程中可能會遇到等待(Waiting)情況
執行緒可以主動呼叫object.wait或者sleep,或者join(join內部呼叫的是sleep,所以可看成sleep的一種)進入。從jdk原始碼註釋來看,waiting是等待另一個執行緒完成某一個操作,如join等待另一個完成執行,object.wait()等待object.notify()方法執行。
Waiting狀態和Blocked狀態有點費解,我個人的理解是:Blocked其實也是一種wait,等待的是monitor,但是和Waiting狀態不一樣,舉個例子,有三個執行緒進入了同步塊,其中兩個呼叫了object.wait(),進入了waiting狀態,這時第三個呼叫了object.notifyAll(),這時候前兩個執行緒就一個轉移到了Runnable,一個轉移到了Blocked。
從下文的monitor結構圖來區別:每個 Monitor在某個時刻,只能被一個執行緒擁有,該執行緒就是 “Active Thread”,而其它執行緒都是 “Waiting Thread”,分別在兩個佇列 “ Entry Set”和 “Wait Set”裡面等候。在 “Entry Set”中等待的執行緒狀態Blocked,從jstack的dump中來看是 “Waiting for monitor entry”,而在 “Wait Set”中等待的執行緒狀態是Waiting,表現在jstack的dump中是 “in Object.wait()”。
此外,在runnable狀態的執行緒是處於被排程的執行緒,此時的排程順序是不一定的。Thread類中的yield方法可以讓一個running狀態的執行緒轉入runnable。
內功心法:每個物件都有的方法(機制)
synchronized, wait, notify 是任何物件都具有的同步工具。讓我們先來了解他們
monitor
他們是應用於同步問題的人工執行緒排程工具。講其本質,首先就要明確monitor的概念,Java中的每個物件都有一個監視器,來監測併發程式碼的重入。在非多執行緒編碼時該監視器不發揮作用,反之如果在synchronized 範圍內,監視器發揮作用。
wait/notify必須存在於synchronized塊中。並且,這三個關鍵字針對的是同一個監視器(某物件的監視器)。這意味著wait之後,其他執行緒可以進入同步塊執行。
當某程式碼並不持有監視器的使用權時(如圖中5的狀態,即脫離同步塊)去wait或notify,會丟擲java.lang.IllegalMonitorStateException。也包括在synchronized塊中去呼叫另一個物件的wait/notify,因為不同物件的監視器不同,同樣會丟擲此異常。
再講用法:
相關推薦
Android核心技術-day05-04-JavaSE多執行緒下載
package com.gaozewen.lib; import java.io.BufferedReader; import java.io.File; import java.io.FileInputStream; import java.io.InputStream; import ja
JavaSE多執行緒
鎖的基礎知識: 鎖的型別: 悲觀鎖和樂觀鎖: 樂觀鎖:認為讀多寫少,遇到併發寫的可能性極低,即每次去拿資料的時候認為別人不會修改,所以不會上鎖,但是在更新的時候會判斷在此期間有沒有 人更新這個資料。 判斷依據:
javaSE-(多執行緒)
1、多執行緒有什麼用?一個可能在很多人看來很扯淡的一個問題:我會用多執行緒就好了,還管它有什麼用?在我看來,這個回答更扯淡。所謂”知其然知其所以然”,”會用”只是”知其然”,”為什麼用”才是”知其所以然”,只有達到”知其然知其所以然”的程度才可以說是把一個知識點運用自如。OK
JavaSE基礎學習筆記及案例(二)多執行緒(下)與簡單工廠模式的瞭解
1.多執行緒(下) 1.1單例設計模式:保證類在記憶體中只存在一個物件 ************餓漢式與懶漢式的區別【面試題】 餓漢式單例模式:以空間換時間 懶漢式單例模式:以時間換空間(不推薦使用,僅在面試中用到) 3.多執行緒訪問時:餓漢式不會建立多個物件;而懶漢式
JavaSE基礎學習筆記及案例(一)IO流與多執行緒(上)
IO流 1. IO流知識點 IO流(字元輸入流FileReader) 位元組輸入流 FileInputStream IO流(字元輸出流FileWriter) 位元組輸出流 FileOutputStream 字元緩衝區輸入流( BufferedReader) 位元組緩衝區輸入流Bu
javaSE (四十)網路程式設計(TCP傳輸、伺服器多執行緒、網路程式設計練習:反轉字串、上傳檔案)
1、TCP傳輸: 1.客戶端 建立Socket連結服務端(指定ip地址,埠號),通過ip地址找到對應的伺服器 呼叫Socket的getInputStream和getOutputStream方法獲取和伺服器端相連的IO流 2.伺服器端 建立Se
javaSE (三十九)網路程式設計(網路程式設計三要素和Socket、UDP傳輸、多執行緒UDP傳輸)
1、網路程式設計三要素: 地址:定位電腦 本地迴路地址:127.0.0.1 廣播地址:255.255.255.255 埠號:定位電腦中的程式 o~65525 儘量使用1024以上的 協議:資料交換的規則/標準 UDP: 面向無連線,資料不安全,速度快,不區分客戶端與服
javaSE (三十五)多執行緒 ( 多執行緒實現方法和區別、同步程式碼塊和方法(執行緒安全))
主要還是熟悉api,熟悉方法,簡單,需要多實踐 1、 多執行緒實現方法和區別: 多執行緒實現的兩種方法: 1)類繼承Thread類或實現Runnable介面,重寫run()方法 2)建立Thread的子類物件(需要開幾個執行緒就建立幾個物件,可建立匿名內部類) 3)子類
JavaSE學習過程中問題總結 —— 集合框架、IO流、多執行緒等
回顧完基本概念和一些常用類,進入重點:(內容很多但沒有分文章寫,主要是自己的知識鞏固和做下筆記,不夠負責任,算不上知識分享)一、集合框架1、集合引入(1)物件陣列的概念:將多個類物件存放為陣列特點:長度固定,不適應變化的需求。(2)面向物件強調的是物件,需要容器來進行儲存和操
動態彈球的實現 加入了多執行緒技術--javaSE遊戲準備工作
任務描述:實現了動態彈球的功能,對於有彈球功能的SE遊戲奠定了基礎。 package 運用執行緒技術的小球; import java.awt.*; import java.awt.event.*; import java.awt.geom.*;//不清楚這個有什麼
javaSE高階開發多執行緒——1 程序與執行緒 and 2 多執行緒的實現
一、程序與執行緒 1.程序的概念 執行緒隸屬於某個程序,程序是一個程式的執行週期,但是我們的執行緒是執行程序中的某個任務 所以如果程序不存在的話,那麼執行緒自然也就不會存在了。 我們應該時刻將執行緒和任務對等起來,執行一個程式啟動一個程序。這樣就可以提升沃恩程式的執行
JavaSE(十)多執行緒程式設計
多執行緒程式設計 執行緒的概念 多執行緒簡介 建立新執行緒 執行緒狀態 join練習 中斷執行緒 volatile 守護執行緒 執行緒同步 執行緒同步
javase知識點 ----20 (多執行緒)
1、程序:正在執行的程式稱作一個程序。程序負責了記憶體空間的劃分。 Windows號稱是多工的作業系統,那麼Windows是同時執行多個應用程式嗎? 從巨集觀角度:Windows確實是在同時執行多個應用程式。 從微觀角度:cpu是做了
JavaSE中多執行緒案例2(關於多執行緒通訊-等待與喚醒)
案例要求:有一個抽獎池,該抽獎池中存放了獎勵的金額,該抽獎池用一個數組int[] arr = {10,5,20,50,100,200,500,800,2,80,300}; 建立兩個抽獎箱(執行緒)設定執行緒名稱分別為“抽獎箱1”,“抽獎箱2”,隨機從arr陣列中獲取獎項元素並
javase複習整理(一):基礎要點、重點、易錯點、多執行緒梳理總結
最近抽出時間從新回頭複習了一下javase基礎,把自己以前理解的不透徹和易錯的知識點重新梳理了一下,便於以後查閱。那麼接下來就開始複習總結! 一、java語言基礎 1、在java中,邏輯運算子“&
【JavaSE:1.多執行緒】
最初場景:生產者消費者模式 模擬買票Ticket package multiThread; public class Ticket implements Runnable { //共100票 int ticket = 100; @Override
Windbg除錯----多執行緒控制除錯
在除錯程式的時候,可能經常會有這樣的需求,讓一個執行緒在特定的時候才讓其開始執行或者暫停執行。比如複雜的多執行緒導致死鎖的問題,又或者多執行緒中的Race Condition 導致程式執行異常等。 很多時候,我們可以藉助編寫除錯程式碼來達到多執行緒的除錯,可是有些情況下除錯的執行粒度是指
Java多執行緒實現電影院售票案例
某電影院目前正在上映賀歲大片,共有100張票,而它有3個售票視窗,請設計一個程式模擬該電影院售票。 定義Sell類實現Runnable介面,很好的解決了單繼承共享資源問題 public class Sell implements Runnable { // 定義100張票,三個售票
Objective-C高階程式設計:iOS與OS X多執行緒和記憶體管理
這篇文章主要給大家講解一下GCD的平時不太常用的API,以及文末會貼出GCD定時器的一個小例子。 需要學習的朋友可以通過網盤免費下載pdf版 (先點選普通下載-----再選擇普通使用者就能免費下載了)http://putpan.com/fs/cy1i1beebn7s0h4u9/ 1.G
java多執行緒物件鎖、類鎖、同步機制詳解
1.在java多執行緒程式設計中物件鎖、類鎖、同步機制synchronized詳解: 物件鎖:在java中每個物件都有一個唯一的鎖,物件鎖用於物件例項方法或者一個物件例項上面的。 類鎖:是用於一個類靜態方法或者class物件的,一個