LockSupport使用类似信号量的机制。当调用LockSupport.unpark()时,给当前线程提供了一个调用LockSupport.park()的许可。和信号量不同的是,这个许可不可以累加(即连续的unpark()和1次效果一样)。提供的主要方法如下:
// 阻塞当前线程,只有调用unpark(Thread thread)或者当前线程被中断,才能返回下面给出一个简单的demo:
public static void park();
// 在park()方法的基础上增加了超时时间,单位为nanos纳秒
public static void parkNanos(long nanos);
// 唤醒处于阻塞状态的thread
public static void unpark(Thread thread);
// 阻塞当前线程,知道deadline(从1970年到现在的毫秒数)
public static void parkUntil(long deadline);
public class LockSupportDemo {从上述代码可以看出,LockSupport.unpark(t1)执行的条件是,有在线程t1里面执行LockSupport.park(),否则会阻塞。如果在主线程里执行两次LockSupport.unpark(t1),则效果还是一样的。
public static Object u = new Object();
static ChangeObjectThread t1 = new ChangeObjectThread("t1");
static ChangeObjectThread t2 = new ChangeObjectThread("t2");
public static class ChangeObjectThread extends Thread {
public ChangeObjectThread(String name) {
super.setName(name);
}
@Override
public void run() {
synchronized (u) {
System.out.println("in " + getName());
LockSupport.park();
System.out.println("===========");
}
}
}
public static void main(String[] args) throws InterruptedException {
t1.start();
Thread.sleep(100);
t2.start();
LockSupport.unpark(t1);
// LockSupport.unpark(t1);
Thread.sleep(2000);
LockSupport.unpark(t2);
t1.join();
t2.join();
}
}
链接: http://moguhu.com/article/detail?articleId=31