JAVA多線程之方法 JOIN詳解及實(shí)例代碼
JAVA多線程 JOIN
對(duì)于Java開發(fā)人員，多線程應(yīng)該是必須熟練應(yīng)用的知識(shí)點(diǎn)，特別是開發(fā)基于Java語言的產(chǎn)品。本文將深入淺出的表述Java多線程的知識(shí)點(diǎn)，在后續(xù)的系列里將側(cè)重于Java5由Doug Lea教授提供的Concurrent并行包的設(shè)計(jì)思想以及具體實(shí)現(xiàn)與應(yīng)用。
如何才能深入淺出呢，我的理解是帶著問題，而不是泛泛的看。所以該系列基本以解決問題為主，當(dāng)然我也非常希望讀者能夠提出更好的解決問題的方案以及提出更多的問題。由于水平有限，如果有什么錯(cuò)誤之處，請大家提出，共同討論，總之，我希望通過該系列我們能夠深入理解Java多線程來解決我們實(shí)際開發(fā)的問題。
作為開發(fā)人員，我想沒有必要討論多線程的基礎(chǔ)知識(shí)，比如什么是線程？ 如何創(chuàng)建等 ，這些知識(shí)點(diǎn)是可以通過書本和Google獲得的。本系列主要是如何理深入解多線程來幫助我們平時(shí)的開發(fā)，比如線程池如何實(shí)現(xiàn)？ 如何應(yīng)用鎖等。
（1）方法Join是干啥用的？ 簡單回答，同步，如何同步？ 怎么實(shí)現(xiàn)的？ 下面將逐個(gè)回答。
自從接觸Java多線程，一直對(duì)Join理解不了。JDK是這樣說的：
join public final void join(long millis)throws InterruptedException Waits at most millis milliseconds for this thread to die. A timeout of 0 means to wait forever.
大家能理解嗎？ 字面意思是等待一段時(shí)間直到這個(gè)線程死亡，我的疑問是那個(gè)線程，是它本身的線程還是調(diào)用它的線程的，上代碼：
package concurrentstudy;
/**
*
* @author vma
*/
public class JoinTest {
public static void main(String[] args) {
Thread t = new Thread(new RunnableImpl());
t.start();
try {
t.join(1000);
System.out.println("joinFinish");
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
class RunnableImpl implements Runnable {
@Override
public void run() {
try {
System.out.println("Begin sleep");
Thread.sleep(1000);
System.out.println("End sleep");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
結(jié)果是：
Begin sleep End sleep joinFinish
明白了吧，當(dāng)main線程調(diào)用t.join時(shí)，main線程等待t線程，等待時(shí)間是1000，如果t線程Sleep 2000呢
public void run() {
try {
System.out.println("Begin sleep");
// Thread.sleep(1000);
Thread.sleep(2000);
System.out.println("End sleep");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
結(jié)果是：
Begin sleep joinFinish End sleep
也就是說main線程只等1000毫秒，不管T什么時(shí)候結(jié)束，如果是t.join()呢， 看代碼：
public final void join() throws InterruptedException {
join(0);
}
就是說如果是t.join() = t.join(0) 0 JDK這樣說的 A timeout of 0 means to wait forever 字面意思是永遠(yuǎn)等待，是這樣嗎？
其實(shí)是等到t結(jié)束后。
這個(gè)是怎么實(shí)現(xiàn)的嗎？ 看JDK代碼：
/**
* Waits at most <code>millis</code> milliseconds for this thread to
* die. A timeout of <code>0</code> means to wait forever.
*
* @param millis the time to wait in milliseconds.
* @exception InterruptedException if any thread has interrupted
* the current thread. The <i>interrupted status</i> of the
* current thread is cleared when this exception is thrown.
*/
public final synchronized void join(long millis)
throws InterruptedException {
long base = System.currentTimeMillis();
long now = 0;
if (millis < 0) {
throw new IllegalArgumentException("timeout value is negative");
}
if (millis == 0) {
while (isAlive()) {
wait(0);
}
} else {
while (isAlive()) {
long delay = millis - now;
if (delay <= 0) {
break;
}
wait(delay);
now = System.currentTimeMillis() - base;
}
}
}
其實(shí)Join方法實(shí)現(xiàn)是通過wait（小提示：Object 提供的方法）。 當(dāng)main線程調(diào)用t.join時(shí)候，main線程會(huì)獲得線程對(duì)象t的鎖（wait 意味著拿到該對(duì)象的鎖),調(diào)用該對(duì)象的wait(等待時(shí)間)，直到該對(duì)象喚醒main線程，比如退出后。
這就意味著main 線程調(diào)用t.join時(shí)，必須能夠拿到線程t對(duì)象的鎖，如果拿不到它是無法wait的，剛開的例子t.join(1000)不是說明了main線程等待1秒，如果在它等待之前，其他線程獲取了t對(duì)象的鎖，它等待時(shí)間可不就是1毫秒了。上代碼介紹：
/*
* To change this template, choose Tools | Templates
* and open the template in the editor.
*/
package concurrentstudy;
/**
*
* @author vma
*/
public class JoinTest {
public static void main(String[] args) {
Thread t = new Thread(new RunnableImpl());
new ThreadTest(t).start();
t.start();
try {
t.join();
System.out.println("joinFinish");
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
class ThreadTest extends Thread {
Thread thread;
public ThreadTest(Thread thread) {
this.thread = thread;
}
@Override
public void run() {
holdThreadLock();
}
public void holdThreadLock() {
synchronized (thread) {
System.out.println("getObjectLock");
try {
Thread.sleep(9000);
} catch (InterruptedException ex) {
ex.printStackTrace();
}
System.out.println("ReleaseObjectLock");
}
}
}
class RunnableImpl implements Runnable {
@Override
public void run() {
try {
System.out.println("Begin sleep");
Thread.sleep(2000);
System.out.println("End sleep");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
在main方法中 通過new ThreadTest(t).start();實(shí)例化ThreadTest 線程對(duì)象， 它在holdThreadLock()方法中，通過synchronized (thread)，獲取線程對(duì)象t的鎖，并Sleep（9000）后釋放，這就意味著，即使main方法t.join(1000),等待一秒鐘，它必須等待ThreadTest 線程釋放t鎖后才能進(jìn)入wait方法中，它實(shí)際等待時(shí)間是9000+1000 MS
運(yùn)行結(jié)果是：
getObjectLock Begin sleep End sleep ReleaseObjectLock joinFinish
小結(jié)：
本節(jié)主要深入淺出join及ＪＤＫ中的實(shí)現(xiàn)。
感謝閱讀，希望能幫助到大家，謝謝大家對(duì)本站的支持！
相關(guān)文章
除了Java本身的字符串處理方式外，我們還可以使用Apache Common Langs里的StringUtils來簡化String的操作。但以上兩種方式對(duì)于我們?nèi)粘＞幊讨凶钊菀着龅降淖址幚韥碚f，仍然顯得有些不足。所以這篇文章給大家介紹Java8中字符串處理庫strman-java的使用。2016-09-09
今天小編就為大家分享一篇Java操作文件輸出為字符串以及字符串輸出為文件的方法，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過來看看吧2018-07-07
java ssm框架實(shí)現(xiàn)分頁功能的示例代碼(oracle)
這篇文章主要介紹了java ssm框架實(shí)現(xiàn)分頁功能的示例代碼(oracle)，小編覺得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧2018-03-03
詳解RabbitMQ中延遲隊(duì)列結(jié)合業(yè)務(wù)場景的使用
這篇文章主要介紹了詳解RabbitMQ中延遲隊(duì)列結(jié)合業(yè)務(wù)場景的使用，延遲隊(duì)列中的元素都是帶有時(shí)間屬性的，延遲隊(duì)列就是用來存放需要在指定時(shí)間被處理的元素的隊(duì)列，需要的朋友可以參考下2023-05-05
在Mac下IDEA安裝并使用protobuf方式(Java)
這篇文章主要介紹了在Mac下IDEA安裝并使用protobuf方式(Java),具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2023-11-11
理解maven命令package、install、deploy的聯(lián)系與區(qū)別
這篇文章主要介紹了理解maven命令package、install、deploy的聯(lián)系與區(qū)別，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-07-07
各種格式的編碼解碼工具類分享(hex解碼 base64編碼)
這篇文章主要介紹了各種格式的編碼解碼工具類，集成Commons-Codec、Commons-Lang及JDK提供的編解碼方法2014-01-01
這篇文章主要介紹了DataOutputStream亂碼問題的解決方案，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-09-09
java快速解析路徑中的參數(shù)(&與=拼接的參數(shù))
這篇文章主要介紹了java快速解析路徑中的參數(shù)(&與=拼接的參數(shù)),本文通過實(shí)例代碼給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友參考下吧2024-02-02
這篇文章主要介紹了如何將Set直接轉(zhuǎn)成數(shù)組，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2022-10-10