简谈Java的join()方法

更新时间:2023-05-29 05:58:59 阅读: 评论:0

简谈Java的join()⽅法
join()是Thread类的⼀个⽅法。根据jdk⽂档的定义:
public final void join()throws : 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()主线程。例如:
1public class JoinTester01 implements Runnable {
2
3private String name;
4
5public JoinTester01(String name) {
6this.name = name;
7    }
8梦见小龙虾
9public void run() {
10    System.out.printf("%s begins: %s\n", name, new Date());
11try {
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
19public 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
25try {
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> milliconds 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结束后。
6public final synchronized void join(long millis)    throws InterruptedException {
7long ba = System.currentTimeMillis();
8long now = 0;
10if (millis < 0) {
11throw new IllegalArgumentException("timeout value is negative");
12        }
塞浦路斯旅游13
14if (millis == 0) {
15while (isAlive()) {
16                wait(0);
17            }
18        } el {
19while (isAlive()) {
20long delay = millis - now;
21if (delay <= 0) {
22break;
23                }
24                wait(delay);
25                now = System.currentTimeMillis() - ba;
26            }
27        }
28    }
可以看出,Join⽅法实现是通过wait(⼩提⽰:Object 提供的⽅法)。当main线程调⽤t.join时候,main线程会获得线程对象t的锁(wait 意味着拿到该对象的锁),调⽤该对象的wait(等待时间),直到该对象唤醒main线程,⽐如退出后。这就意味着main 线程调⽤t.join时,必须能够拿到线程t对象的锁。
1public class JoinTester02 implements Runnable {
2
3    Thread thread;
4
5public JoinTester02(Thread thread) {
6this.thread = thread;
7    }
8
开阔眼界英语
9public void run() {
10synchronized (thread) {
11        System.out.println("getObjectLock");
12try {
13        Thread.sleep(9000);
14        } catch (InterruptedException ex) {
15        ex.printStackTrace();
16        }
17        System.out.println("ReleaObjectLock");
18    }
19    }
20
21public 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
28try {
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
41public JoinTester02(Thread thread) {
42this.thread = thread;
43    }
44
45public void run() {
46synchronized (thread) {
47        System.out.println("getObjectLock");
48try {
49        Thread.sleep(9000);
50        } catch (InterruptedException ex) {
51        ex.printStackTrace();
52        }
53        System.out.println("ReleaObjectLock");
54    }
56
57public 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
64try {
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
ReleaObjectLock
Main finished!
getLockThread通过 synchronized  (thread) ,获取线程对象t的锁,并Sleep(9000)后释放,这就意味着,即使main⽅法t.join(1000)等待⼀秒钟,它必须等待ThreadTest 线程释放t锁后才能进⼊wait⽅法中。
本⽂完
参考:
Java 7 Concurency Cookbook

本文发布于:2023-05-29 05:58:59,感谢您对本站的认可!

本文链接:https://www.wtabcd.cn/fanwen/fan/82/804620.html

版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系,我们将在24小时内删除。

标签:线程   对象   等待   结束   主线   完成   没有   红烧
相关文章
留言与评论(共有 0 条评论)
   
验证码:
推荐文章
排行榜
Copyright ©2019-2022 Comsenz Inc.Powered by © 专利检索| 网站地图