Java多线程神器:join使用及原理

join()

join()是线程类 Thread的方法,官方的说明是:
Waits for this thread to die.
等待这个线程结束,也就是说当前线程等待这个线程结束后再继续执行,下面来看这个示例就明白了。

示例

  1. publicstaticvoid main(String[] args)throwsException{
  2.    System.out.println("start");
  3.    Thread t =newThread(()->{
  4.        for(int i =0; i <5; i++){
  5.            System.out.println(i);
  6.            try{
  7.                Thread.sleep(500);
  8.            }catch(InterruptedException e){
  9.                e.printStackTrace();
  10.            }
  11.        }
  12.    });
  13.    t.start();
  14.    t.join();
  15.    System.out.println("end");
  16. }
结果输出:
  1. start
  2. 0
  3. 1
  4. 2
  5. 3
  6. 4
  7. end
线程t开始后,接着加入t.join()方法,t线程里面程序在主线程end输出之前全部执行完了,说明t.join()阻塞了主线程直到t线程执行完毕。
如果没有t.join(),end可能会在0~5之间输出。

join()原理

下面是join()的源码:
  1. publicfinalsynchronizedvoid join(long millis)
  2.    throwsInterruptedException{
  3.    longbase=System.currentTimeMillis();
  4.    long now =0;
  5.    if(millis <0){
  6.        thrownewIllegalArgumentException("timeout value is negative");
  7.    }
  8.    if(millis ==0){
  9.        while(isAlive()){
  10.            wait(0);
  11.        }
  12.    }else{
  13.        while(isAlive()){
  14.            long delay = millis - now;
  15.            if(delay <=0){
  16.                break;
  17.            }
  18.            wait(delay);
  19.            now =System.currentTimeMillis()-base;
  20.        }
  21.    }
  22. }
可以看出它是利用wait方法来实现的,上面的例子当main方法主线程调用线程t的时候,main方法获取到了t的对象锁,而t调用自身wait方法进行阻塞,只要当t结束或者到时间后才会退出,接着唤醒主线程继续执行。millis为主线程等待t线程最长执行多久,0为永久直到t线程执行结束。

本站所有文章均来自互联网,如有侵权,请联系站长删除。极客文库 » Java多线程神器:join使用及原理
分享到:
赞(0)

评论抢沙发

评论前必须登录!