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获取同步锁。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持毛票票。