简谈Java的join()方法(转)
join()是Thread类的一个方法。根据jdk文档的定义:
public final void join()throws InterruptedException: Waits for this thread to die.
join()方法的作用,是等待这个线程结束;但显然,这样的定义并不清晰。个人认为"Java 7 Concurrency Cookbook"的定义较为清晰:
join() method suspends the execution of the calling thread until the object called finishes its execution.
也就是说,t.join()方法阻塞调用此方法的线程(calling thread),直到线程t完成,此线程再继续;通常用于在main()主线程内,等待其它线程完成再结束main()主线程。例如:
1 public class JoinTester01 implements Runnable {2 3 private String name;4 5 public JoinTester01(String name) {6 this.name = name;7 }8 9 public void run() { 10 System.out.printf("%s begins: %s\n", name, new Date()); 11 try { 12 TimeUnit.SECONDS.sleep(4); 13 } catch (InterruptedException e) { 14 e.printStackTrace(); 15 } 16 System.out.printf("%s has finished: %s\n", name, new Date()); 17 } 18 19 public static void main(String[] args) { 20 Thread thread1 = new Thread(new JoinTester01("One")); 21 Thread thread2 = new Thread(new JoinTester01("Two")); 22 thread1.start(); 23 thread2.start(); 24 25 try { 26 thread1.join(); 27 thread2.join(); 28 } catch (InterruptedException e) { 29 // TODO Auto-generated catch block 30 e.printStackTrace(); 31 } 32 33 System.out.println("Main thread is finished"); 34 } 35 36 }
上述代码如果没有join()方法,输出如下:
Main thread is finished
One begins: Wed Aug 28 10:21:36 CST 2013
Two begins: Wed Aug 28 10:21:36 CST 2013
Two has finished: Wed Aug 28 10:21:40 CST 2013
One has finished: Wed Aug 28 10:21:40 CST 2013
可以看出主线程main比其它两个线程先结束。
最后来深入了解一下join(),请看其源码:
1 /**2 * Waits at most <code>millis</code> milliseconds for this thread to 3 * die. A timeout of <code>0</code> means to wait forever. 4 */5 //此处A timeout of 0 means to wait forever 字面意思是永远等待,其实是等到t结束后。6 public final synchronized void join(long millis) throws InterruptedException {7 long base = System.currentTimeMillis();8 long now = 0;9 10 if (millis < 0) { 11 throw new IllegalArgumentException("timeout value is negative"); 12 } 13 14 if (millis == 0) { 15 while (isAlive()) { 16 wait(0); 17 } 18 } else { 19 while (isAlive()) { 20 long delay = millis - now; 21 if (delay <= 0) { 22 break; 23 } 24 wait(delay); 25 now = System.currentTimeMillis() - base; 26 } 27 } 28 }
可以看出,Join方法实现是通过wait(小提示:Object 提供的方法)。 当main线程调用t.join时候,main线程会获得线程对象t的锁(wait 意味着拿到该对象的锁),调用该对象的wait(等待时间),直到该对象唤醒main线程 ,比如退出后。这就意味着main 线程调用t.join时,必须能够拿到线程t对象的锁。
1 public class JoinTester02 implements Runnable {2 3 Thread thread;4 5 public JoinTester02(Thread thread) {6 this.thread = thread;7 }8 9 public void run() { 10 synchronized (thread) { 11 System.out.println("getObjectLock"); 12 try { 13 Thread.sleep(9000); 14 } catch (InterruptedException ex) { 15 ex.printStackTrace(); 16 } 17 System.out.println("ReleaseObjectLock"); 18 } 19 } 20 21 public static void main(String[] args) { 22 Thread thread = new Thread(new JoinTester01("Three")); 23 Thread getLockThread = new Thread(new JoinTester02(thread)); 24 25 getLockThread.start(); 26 thread.start(); 27 28 try { 29 thread.join(); 30 } catch (InterruptedException e) { 31 // TODO Auto-generated catch block 32 e.printStackTrace(); 33 } 34 System.out.println("Main finished!"); 35 } 36 37 }public class JoinTester02 implements Runnable { 38 39 Thread thread; 40 41 public JoinTester02(Thread thread) { 42 this.thread = thread; 43 } 44 45 public void run() { 46 synchronized (thread) { 47 System.out.println("getObjectLock"); 48 try { 49 Thread.sleep(9000); 50 } catch (InterruptedException ex) { 51 ex.printStackTrace(); 52 } 53 System.out.println("ReleaseObjectLock"); 54 } 55 } 56 57 public static void main(String[] args) { 58 Thread thread = new Thread(new JoinTester01("Three")); 59 Thread getLockThread = new Thread(new JoinTester02(thread)); 60 61 getLockThread.start(); 62 thread.start(); 63 64 try { 65 thread.join(); 66 } catch (InterruptedException e) { 67 // TODO Auto-generated catch block 68 e.printStackTrace(); 69 } 70 System.out.println("Main finished!"); 71 } 72 73 }
输出如下:
getObjectLock
Three begins: Wed Aug 28 10:42:00 CST 2013
Three has finished: Wed Aug 28 10:42:04 CST 2013
ReleaseObjectLock
Main finished!
getLockThread通过 synchronized (thread) ,获取线程对象t的锁,并Sleep(9000)后释放,这就意味着,即使main方法t.join(1000)等待一秒钟,它必须等待ThreadTest 线程释放t锁后才能进入wait方法中。
本文完
参考:
http://uule.iteye.com/blog/1101994
转自:http://www.cnblogs.com/techyc/p/3286678.html
转载于:https://www.cnblogs.com/zl1991/p/6930019.html
简谈Java的join()方法(转)相关推荐
- java线程join方法
java线程join方法 1.join方法 join方法的作用是进行线程插队,也就是说调用了join方法的线程相对于调用它的上级线程拥有跟高的执行权.调用join方法的线程的上级线程必须等待调用j ...
- java线程join方法会释放锁吗
java线程join方法会释放锁吗,虽然join底层使用wait,wait是释放锁的 wait()和join()的调用方的区别: object.wait()和thread.join() join()的 ...
- Java中join()方法的理解
thread.Join把指定的线程加入到当前线程,可以将两个交替执行的线程合并为顺序执行的线程. 比如在线程B中调用了线程A的Join()方法,直到线程A执行完毕后,才会继续执行线程B. t.join ...
- Java中join()方法原理及使用教程
简介 前面几篇文章讲解了wait()方法之后,我们再来讲讲join()方法,因为join()方法就是通过wait()方法实现的. 一.join()方法的作用 作用:让主线程等待(WAITING状态), ...
- Java:join方法详解
文章目录 概念 原理 总结 代码案例:实现子线程先执行,主线程再执行 概念 Thread类提供了让一个线程等待另一个线程完成的方法--join()方法. 当在某个程序执行流中调用其他线程的join() ...
- java的join方法_Javajoin方法详解
方法Join 是干啥用的? 简单回答,同步,如何同步? 怎么实现的? 下面将逐个回答. 自从接触Java 多线程,一直对Join 理解不了.JDK 是这样说的:join public final vo ...
- 简谈java的split
最近都在处理视频音频,今天在合成音频视频时为了给合成的新文件换个新名字,我打算获取了之前的视频名称,用split来分割出不带后缀的名字,再自己加上后缀. 众所周知split可以分割由某种字符分段的St ...
- 简谈 Java 中的泛型通配符
很好的一篇文章https://zhuanlan.zhihu.com/p/26681625 转载于:https://www.cnblogs.com/hihtml5/p/6978651.html
- 【JAVA】Object类的方法简谈
Object类的方法简谈 Java中所有的类都继承自Object类,那我们今天来探讨一下Object类中的方法 PS:Object源码中,作者那一栏中,出现了这个 package java.lang; ...
最新文章
- 最强无监督行人重识别方法 Cluster Contrast ReID
- 2016年秋季个人阅读计划
- GeoAnalyticsServer在Linux下集群部署手册
- for循环只执行一次_Python中for循环和while循环有什么区别?
- 网络编程--sockaddr 与 sockaddr_in
- visual studio 使用快捷方法1
- Go的50坑:新Golang开发者要注意的陷阱、技巧和常见错误[1]
- 常见的系统故障及排除
- html简单实现下拉菜单
- Java实现图片无损任意角度旋转
- 智慧城管监控指挥中心建设
- C盘搬家,不需要任何第三方工具
- 推荐系统中的context到底指的是什么?
- 超出ipc连接数范围_终端服务器超出了最大允许连接数的解决办法 (全文)
- 玉品游戏java_整蛊游戏N合一(玉品)
- 如何确认是文章发表在哪里?
- 【rust】part-7 self,crate,super、use,as
- 一文掌握Pandas可视化图表
- 主引导记录(MBR)
- 列表xcode项目下所有的lnfo.plist