时间:2021-05-19
java 中的 join() 方法在多线程中会涉及到,这个方法最初理解起来可能有点抽象,用一两次大概就懂了。简单说就是当前线程等待调用join方法的线程结束才能继续往下执行。
如下,
MyRunnable 类是实现 Runnable 接口的多线程类,其run() 方法是一个计算,计算值存储在 result 字段,获取计算结果就必须等线程执行完之后调用 getResult() 获取
public class MyRunnable implements Runnable { private int num; private String threadName; private long result; public MyRunnable(int num, String threadName) { this.threadName = threadName; this.num = num; } public void run() { for (int i = 0; i < num; i++) { result += i; } } public long getResult() { return result; }} public class NormalTest { public static void main(String[] args) { normal(); } private static void normal() { MyRunnable myRunnable_1 = new MyRunnable(1000, "runnable_1"); Thread thread_1 = new Thread(myRunnable_1); thread_1.start(); do { System.out.println("--------------------------------------------------"); System.out.println("thread status: " + thread_1.isAlive() + ",result: " + myRunnable_1.getResult()); } while (thread_1.isAlive()); }}获取计算结果需要持续判断线程 thread_1 是否结束才能最终获取,输出如下:
--------------------------------------------------
thread status: true,result: 0
--------------------------------------------------
thread status: true,result: 11026
--------------------------------------------------
thread status: false,result: 499500
而使用join()方法可以省去判断的麻烦,如下
public class JoinTest { public static void main(String[] args) { join(); } private static void join() { MyRunnable myRunnable_1 = new MyRunnable(1000, "runnable_1"); Thread thread_1 = new Thread(myRunnable_1); thread_1.start(); try { thread_1.join(); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("thread status: " + thread_1.isAlive() + ",result: " + myRunnable_1.getResult()); }}输出如下:
thread status: false,result: 499500
调用join方法以后当前线程(在这里就是main函数)会等待thread_1 结束后才继续执行下面的代码。
其实 join() 方法内部的实现跟上面例子中的normal()方法很类似,也是使用线程的 isAlive() 方法来判断线程是否结束,核心源码如下:
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) { // join 方法如果不传参数会默认millis 为 0 while (isAlive()) { wait(0); } } else { while (isAlive()) { long delay = millis - now; if (delay <= 0) { break; } wait(delay); now = System.currentTimeMillis() - base; } } }当然上述还涉及 Object 类的 wait() 方法,感兴趣可以查一下,这里可以简单的理解就是一个等待多少时间。
到此这篇关于java中join方法的理解与说明的文章就介绍到这了,更多相关java中join方法内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持!
声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。
Java中==运算符与equals方法的区别及intern方法详解1.==运算符与equals()方法2.hashCode()方法的应用3.intern()方法
java深拷贝与浅拷贝机制详解概要:在Java中,拷贝分为深拷贝和浅拷贝两种。java在公共超类Object中实现了一种叫做clone的方法,这种方法clone
详解Java注解的实现与使用方法Java注解是java5版本发布的,其作用就是节省配置文件,增强代码可读性。在如今各种框架及开发中非常常见,特此说明一下。如何创
本文实例讲述了Java中join线程操作。分享给大家供大家参考,具体如下:一点睛Tread提供了让一个线程等待另外一个线程完成的方法——join()方法。当在某
本文研究的主要是Java多线程中join方法的使用问题,以下文为具体实例。Thread的非静态方法join()让一个线程B“加入”到另外一个线程A的尾部。在A执