Java concurrency之LockSupport_动力节点Java学院整理
LockSupport介绍
LockSupport是用来创建锁和其他同步类的基本线程阻塞原语。
LockSupport中的park()和unpark()的作用分别是阻塞线程和解除阻塞线程,而且park()和unpark()不会遇到“Thread.suspend和Thread.resume所可能引发的死锁”问题。
因为park()和unpark()有许可的存在;调用park()的线程和另一个试图将其unpark()的线程之间的竞争将保持活性。
LockSupport函数列表
//返回提供给最近一次尚未解除阻塞的park方法调用的blocker对象,如果该调用不受阻塞,则返回null。 staticObjectgetBlocker(Threadt) //为了线程调度,禁用当前线程,除非许可可用。 staticvoidpark() //为了线程调度,在许可可用之前禁用当前线程。 staticvoidpark(Objectblocker) //为了线程调度禁用当前线程,最多等待指定的等待时间,除非许可可用。 staticvoidparkNanos(longnanos) //为了线程调度,在许可可用前禁用当前线程,并最多等待指定的等待时间。 staticvoidparkNanos(Objectblocker,longnanos) //为了线程调度,在指定的时限前禁用当前线程,除非许可可用。 staticvoidparkUntil(longdeadline) //为了线程调度,在指定的时限前禁用当前线程,除非许可可用。 staticvoidparkUntil(Objectblocker,longdeadline) //如果给定线程的许可尚不可用,则使其可用。 staticvoidunpark(Threadthread)
LockSupport示例
对比下面的“示例1”和“示例2”可以更清晰的了解LockSupport的用法。
示例1
publicclassWaitTest1{ publicstaticvoidmain(String[]args){ ThreadAta=newThreadA("ta"); synchronized(ta){//通过synchronized(ta)获取“对象ta的同步锁” try{ System.out.println(Thread.currentThread().getName()+"startta"); ta.start(); System.out.println(Thread.currentThread().getName()+"block"); //主线程等待 ta.wait(); System.out.println(Thread.currentThread().getName()+"continue"); }catch(InterruptedExceptione){ e.printStackTrace(); } } } staticclassThreadAextendsThread{ publicThreadA(Stringname){ super(name); } publicvoidrun(){ synchronized(this){//通过synchronized(this)获取“当前对象的同步锁” System.out.println(Thread.currentThread().getName()+"wakupothers"); notify();//唤醒“当前对象上的等待线程” } } } }
示例2
importjava.util.concurrent.locks.LockSupport; publicclassLockSupportTest1{ privatestaticThreadmainThread; publicstaticvoidmain(String[]args){ ThreadAta=newThreadA("ta"); //获取主线程 mainThread=Thread.currentThread(); System.out.println(Thread.currentThread().getName()+"startta"); ta.start(); System.out.println(Thread.currentThread().getName()+"block"); //主线程阻塞 LockSupport.park(mainThread); System.out.println(Thread.currentThread().getName()+"continue"); } staticclassThreadAextendsThread{ publicThreadA(Stringname){ super(name); } publicvoidrun(){ System.out.println(Thread.currentThread().getName()+"wakupothers"); //唤醒“主线程” LockSupport.unpark(mainThread); } } }
运行结果:
mainstartta
mainblock
tawakupothers
maincontinue
说明:park和wait的区别。wait让线程阻塞前,必须通过synchronized获取同步锁。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持毛票票。