java join 原理及其应用

逃离我推掉我的手 2022-08-01 00:16 139阅读 0赞

线程的合并的含义就是将几个并行线程的线程合并为一个单线程执行，应用场景是当一个线程必须等待另一个线程执行完毕才能执行时可以使用join方法。

join为非静态方法，定义如下：  
void join(): 等待该线程终止。   
void join(long millis): 等待该线程终止的时间最长为 millis 毫秒。   
void join(long millis, int nanos): 等待该线程终止的时间最长为 millis 毫秒 + nanos 纳秒。

测试代码：

Java代码 ![收藏代码][icon_star.png]

1.  public class ThreadJoinTest \{
2.  
3.  public static void main(String\[\] args) \{
4.  ThreadA ta = new ThreadA();
5.  new ThreadB(ta).start();
6.  \}
7.  
8.  \}
9.  
10. class ThreadA extends Thread \{
11. public void run() \{
12. try \{
13. System.out.println("runing A start^^^^^^^^^^^");
14. Thread.currentThread().sleep(2000);
15. System.out.println("runing A over^^^^^^^^^^^");
16. \} catch (InterruptedException e) \{
17. e.printStackTrace();
18. \}
19. \}
20. \}
21. 
22. class ThreadB extends Thread \{
23. 
24. private ThreadA ta;
25. 
26. public ThreadB(ThreadA ta) \{
27. this.ta = ta;
28. \}
29. 
30. public void run() \{
31. try \{
32. System.out.println("runing B start^^^^^^^^^^^");
33. ta.start();
34. // 在ThreaB中调用ThreadA的join()，此时的ThreadB将挂起，直到ThreadA执行结束ThreadB才继续执行
35. ta.join();
36. System.out.println("runing B over^^^^^^^^^^^");
37. 
38. \} catch (InterruptedException e) \{
39. e.printStackTrace();
40. \}
41. \}
42. \}

**仔细分析输出将一目了然：**

Java代码 ![收藏代码][icon_star.png]

1.  runing B start^^^^^^^^^^^
2.  runing A start^^^^^^^^^^^
3.  runing A over^^^^^^^^^^^
4.  runing B over^^^^^^^^^^^

在 t1.start()子线程就绪;之后添加t1.join()，则等t1线程执行完之后才执行主线程

\---------------

package com.wlh;

public class TestJoin \{ 
public static void main(String\[\] args) \{ 
MyThread2 t1 = new MyThread2("子线程"); 
t1.start(); 
try \{ 
t1.join(); 
\} catch (InterruptedException e) \{\} 
for(int i=1;i<=10;i++)\{ 
try \{ 
Thread.sleep(1000);//当前线程休息1000秒 
System.out.println("i am main thread"); 
\} catch (InterruptedException e) \{ 
e.printStackTrace(); 
\} 
 
\} 
\} 
\} 
class MyThread2 extends Thread \{ 
MyThread2(String s)\{ 
super(s); 
\} 
 
public void run()\{ 
for(int i =1;i<=10;i++)\{ 
System.out.println("i am "+getName()); 
try \{ 
sleep(1000);//当前线程休息1000秒 
\} catch (InterruptedException e) \{ 
return; 
\} 
\} 
\} 
\}

\--------------------

**仔细分析输出将一目了然：**

i am 子线程  
i am 子线程  
i am 子线程  
i am 子线程  
i am 子线程  
i am 子线程  
i am 子线程  
i am 子线程  
i am 子线程  
i am 子线程  
i am main thread  
i am main thread  
i am main thread  
i am main thread  
i am main thread  
i am main thread  
i am main thread  
i am main thread  
i am main thread  
i am main thread

线程的join合并的含义就是将几个并行线程的线程合并为一个单线程执行，应用场景是当一个线程必须等待另一个线程执行完毕才能执行时可以使用join方法。

<table style="background:#FB7"> 
 <tbody> 
 <tr> 
 <td>&nbsp;代码如下</td> 
 <td align="center" style="">复制代码</td> 
 </tr> 
 <tr> 
 <td colspan="2" style="padding:10px"> package com.javaer.thread; &nbsp; public class Tjoin { &nbsp; /** &nbsp;* @param args &nbsp;*/ public static void main(String[] args) { Thread t = new Thread(new Runner()); t.start(); try { t.join(1000); System.out.println("join ok"); } <a href="http://www.111cn.net/tags.php/catch/" rel="nofollow"> catch</a> (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); &nbsp; } &nbsp; } &nbsp; } &nbsp; class Runner implements Runnable { &nbsp; @Override public void run() { try { System.out.println("Start sleep"); Thread.sleep(1000); &nbsp;&nbsp; System.out.println("End sleep"); } catch (InterruptedException e) { e.printStackTrace(); } &nbsp; } } Start sleep join ok End sleep</td> 
 </tr> 
 </tbody> 
</table>

主线程等待1000ms，进行合并，跳回主线程，然后执行子线程

如果将

t.join(1000);  
改为

t.join(2000);  
主线程等待2000ms，进行合并。

结果

Start sleep  
End sleep  
join ok  
主线程等2000，开始join。 跳回主线程，发现子线程都执行完毕了。

如果改成

t.join(0)  
JDK这样说的 A timeout of 0 means to wait forever 字面意思是永远等待.

结果

Start sleep  
End sleep  
join ok  
其实Join方法实现是通过wait。 当main线程调用t.join时候，main线程会获得线程对象t的锁（wait 意味着拿到该对象的锁),调用该对象的wait(等待时间)，直到该对象唤醒main线程，比如退出后。

所以上面的t.join(0) 等到子线程退出以后，跳回主线程。

main 线程调用t.join时，必须能够拿到线程t对象的锁，如果拿不到它是无法wait的，刚开的例子t.join(1000)不是说明了main线程等待1秒，如果在它等待之前，其他线程获取了t对象的锁，它等待时间可不就是1秒了

<table style="background:#FB7"> 
 <tbody> 
 <tr> 
 <td>&nbsp;代码如下</td> 
 <td align="center" style="">复制代码</td> 
 </tr> 
 <tr> 
 <td colspan="2" style="padding:10px"> &nbsp; package com.javaer.thread; &nbsp; public class Tjoin { /** &nbsp;* @param args &nbsp;*/ public static void main(String[] args) { Thread t = new Thread(new Runner()); new Threader(t).start(); t.start(); try { t.join(1000); System.out.println("join ok"); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } &nbsp; class Threader extends Thread { Thread thread; public Threader(Thread thread) { this.thread = thread; } @Override public void run() { holdThreadLock(); } public void holdThreadLock() { synchronized (thread) { System.out.println("获取一个锁"); try { Thread.sleep(9000); } catch (InterruptedException ex) { ex.printStackTrace(); } System.out.println("释放锁"); } } } &nbsp; class Runner implements Runnable { &nbsp; @Override public void run() { try { System.out.println("Start sleep"); Thread.sleep(2000); System.out.println("End sleep"); } catch (InterruptedException e) { e.printStackTrace(); } } } </td> 
 </tr> 
 </tbody> 
</table>

获取一个锁  
Start sleep  
End sleep  
释放锁  
join ok  
一个线程获取了锁，主线在join的时候，即使被join的线程结束了，因为线程被锁住，所以即使join的时间也到了，但是还是必须等待锁释放，才能被join

感谢：

http://787141854-qq-com.iteye.com/blog/2072396

http://www.111cn.net/jsp/Java/63508.htm

[icon_star.png]: /images/20220801/57a21fe4696f442eb95b089fcbdd2157.png