java多线程16:join()的使用

讲解join()方法之前请确保对于即wait()/notify()/notifyAll()机制已熟练掌握。可以参考前面的笔记

join()方法的作用是等待线程销毁。join()方法反应的是一个很现实的问题,比如main线程的执行时间是1s,子线程的执行时间是10s,但是主线程依赖子线程执行完的结果,这时怎么办?可以像生产者/消费者模型一样,搞一个缓冲区,子线程执行完把数据放在缓冲区中,通知main线程,main线程去拿,这样就不会浪费main线程的时间了。另外一种方法,就是join()了。

join()方法之前的铺垫


上面的主线程想等待子线程,但是主线程先打印了,如果要实现主线程等待呢



用join()来解决


使用join成功的让主线程等待了,其实join内部还是使用的等待,所以join是放锁的




join()方法与异常


上面是ThreadB 调用a.join(),其实根据join的源码是当前B线程锁a线程对象,wait之后,B线程等待A线程notify,而要interrupt B线程就会出现异常,但是A线程还是继续,A线程是不受影响的




join(long)方法的使用


通过上面代码可以发现 join(long)  和 sleep(long)实现的效果是一样

join()方法的一个重点是要区分出和sleep()方法的区别。join(2000)也是可以的,表示调用join()方法所在的线程最多等待2000ms,两者的区别在于:

sleep(2000)不释放锁,join(2000)释放锁,因为join()方法内部使用的是wait(),因此会释放锁。看一下join(2000)的源码就知道了,join()其实和join(2000)一样,无非是join(0)而已:

  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) {
         while (isAlive()) {
         wait(0);
         }
     } else {
         while (isAlive()) {
         long delay = millis - now;
         if (delay <= 0) {
             break;
         }
         wait(delay);
         now = System.currentTimeMillis() - base;
         }
     }
     }

第12行、第20行应该已经很清楚了

而sleep是不会释放锁的




sleep(long)方法不放锁


上面的例子都证明了  join 是放锁的,而sleep是不会放锁的

下面例子证明了join的另一种问题,原因是join是wait实现的,被其它线程唤醒后,会抢锁,而且是优先抢到锁





方法join()之后的代码提前运行-----出现意外


解释意外的发生情况



可以清楚的看到,出现的情况是多种多样的,原因就在于join会抢锁,执行完毕之后,就放锁然后执行锁之后的代码,也是由于线程的随机性,情况多种多样,join不是每次都会抢到锁






时间: 2024-10-29 03:54:00

java多线程16:join()的使用的相关文章

java多线程中join用法

thread.Join把指定的线程加入到当前线程,可以将两个交替执行的线程合并为顺序执行的线程.比如在线程B中调用了线程A的Join()方法,直到线程A执行完毕后,才会继续执行线程B. package com.wzs; /** * Java多线程中join用法 * * @author Administrator * */ public class JoinTest { public static void main(String[] args) { BThread bThread = new B

Java多线程中join、yield、sleep方法详解

在Java多线程编程中,Thread类是其中一个核心和关键的角色.因此,对该类中一些基础常用方法的理解和熟练使用是开发多线程代码的基础.本篇主要总结一下Thread中常用的一些静态方法的含义及代码中的使用. sleep方法 源码如下: /** * Causes the currently executing thread to sleep (temporarily cease * execution) for the specified number of milliseconds, subje

Java 多线程 Fork/Join

Fork/Join Fork/Join将大任务切分成小任务来分治运算,fork分join合. 一般直接使用ForkJoinTask的子类RecursiveTask. RecursiveTask的用法 1.新建类A来继承RecursiveTask,实现compute()方法,这个方法就是需要分治的代码.其中,调用fork()方法来表示需要分解计算的内容,调用join()方法来获取结果 2.新建ForkJoinPool,使用ForkJoinPool.submit(A的实例),来提交分治代码,并使用F

Java多线程学习:Join()

方法join的作用是使所属的线程对象x正常执行run()方法中的任务,而使当前线程Z进行无限期的阻塞,等待线程X销毁后再继续执行线程Z后面的代码.一般用于子线程先执行完毕再继续执行主线程的情况. 但是join方法后面的代码会不会提前执行呢?看下面的代码 1 public class ThreadA extends Thread { 2 3 private ThreadB threadB; 4 5 public ThreadA(ThreadB threadB) { 6 super(); 7 thi

JAVA多线程---wait() &amp; join()

题外话: interrupt()方法  并不能中断一个正常运行的线程!!! class myThread extends Thread{ @Override public void run(){ for (int i = 0; i < 1000; i++) { System.out.println(i); } } } public class waitTest { public static void main(String[] args) throws Exception{ Thread t

Java多线程的join()

假设在main线程里又起了一个thread1线程,在调用了thread1.start()之后: 如果在main线程里调用了thread1.join(),那么main线程将会block,直到thread1执行完了之后,main线程才会继续执行. 如果在main线程里没有调用thread1.join(),那么main线程和thread1线程将会并行执行. 测试代码如下: 1 public class JoinThread extends Thread{ 2 public JoinThread(Str

Java多线程16:线程组

线程组 可以把线程归属到某一个线程组中,线程组中可以有线程对象,也可以有线程组,组中还可以有线程,这样的组织结构有点类似于树的形式,如图所示: 线程组的作用是:可以批量管理线程或线程组对象,有效地对线程或线程组对象进行组织. 线程关联线程组:1级关联 所谓1级关联就是父对象中有子对象,但并不创建孙对象.这种情况在开发中很常见,比如创建一些线程时,为了有效对这些线程进行阻止管理,通常情况下是创建一个线程组,然后再将部分线程归属到该组中,以此来对零散的线程对象进行有效的管理. 看一下简单的1级关联的

Java多线程中join方法详解

join()方法用于让当前执行线程等待join线程执行结束.其实现原理是不停的检查join线程是否存活,如果join线程存活则让当前线程永远等待. join()方法部分实现细节 while(isAlive()) { wait(0) } 其中wait(0)表示永远等待下去. join线程中止后,线程的this.notifyAll()方法会被调用,调用notifyAll()是在JVM里调用的所有在JDK中看不到,大家可以看JVM源码 示例程序: public calss ThreadTest{ pu

java 多线程2:Thread的实例方法

Thread类中的方法调用方式: 学习Thread类中的方法是学习多线程的第一步.在学习多线程之前特别提出一点,调用Thread中的方法的时候,在线程类中,有两种方式,一定要理解这两种方式的区别: 1.this.XXX() 和 线程对象实例.XXX() 这里要首先参考 多线程 Thread.currentThread().getName() ,对象实例.getName() 和 this.getName()区别 理解采用Thread继承实现线程的几种启动方式出现的问题 这种调用方式表示的线程是线程