标签:join 线程 threadTest 底层 方法 wait
简述
join方法的主要作用就是同步,它可以使得线程之间的并行执行变为串行执行。在A线程中调用了B线程的join()方法时,表示只有当B线程执行完毕时,A线程才能继续执行。
底层
首先我们需要知道join方法底层是用wait方法实现的,所以join方法也会释放锁。
wait方法机制
这里在介绍底层前首先得介绍wait方法的一种机制,当wait方法获取的锁对象是线程实例的时候,线程的任务执行完后会notifyall所有在此线程实例上的wait队列里的线程
public class HighConcurrency { public static void main(String[] args) { try { Thread threadTest = new Thread(){ public void run(){ System.out.println("执行线程中方法"); try { Thread.sleep(2000); } catch (InterruptedException e) { e.printStackTrace(); } } }; threadTest.start(); synchronized(threadTest){ threadTest.wait();//当线程终止的时候,会调用线程自身的notifyAll()方法 } System.out.println("执行到了这里"); } catch (InterruptedException e) { e.printStackTrace(); } } }
执行结果:
执行线程中方法 执行到了这里
可以看到并没有线程执行了threadTest.notify但主线程中却被唤醒了,这正是这种机制的体现,当threadTest线程终止的时候会唤醒以
threadTest为锁的wait队列上的线程
join方法底层
我们再来看join方法的源码
public final synchronized void join(long millis) throws InterruptedException { long base = System.currentTimeMillis(); long now = 0L; if (millis < 0L) { throw new IllegalArgumentException("timeout value is negative"); } else { if (millis == 0L) { while(this.isAlive()) { this.wait(0L); } } else { while(this.isAlive()) { long delay = millis - now; if (delay <= 0L) { break; } this.wait(delay); now = System.currentTimeMillis() - base; } } } }
可以看到join方法底层就是调用了wait方法,我们调用一个线程的join,因为join方法是synchronized修饰的所以会获取该线程实例的锁,然后释放锁进入wait队列,当线程终止的时候也就会唤醒现在等待的线程。合起来也就是join方法的逻辑了。
我们还可以看到如果有时间的参数,则会wait固定時間。如果被虛假喚醒了,則會檢查獲得鎖的綫程有沒有存貨,若終止了則不再等待。
标签:join,线程,threadTest,底层,方法,wait 来源: https://www.cnblogs.com/qq2210446939/p/15098895.html
本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享; 2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关; 3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关; 4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除; 5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。