介绍 锁池EntryList 等待池WaitSet 锁池 假设线程A已经拥有了某个对象(不是类)的锁,而其他线程B,C想要调用这个对象的某个synchronized方法(或者块),由于B,C线程在进入对象的synch
介绍
锁池EntryList
等待池WaitSet
锁池
假设线程A已经拥有了某个对象(不是类)的锁,而其他线程B,C想要调用这个对象的某个synchronized方法(或者块),由于B,C线程在进入对象的synchronized方法(或者块)之前就必须先获得该对象锁的拥有权,而恰巧该对象的锁目前正被线程A所占用,此时B,C线程就会被阻塞,进入一个地方去等待锁的释放,这个地方便是该对象的锁池
等待池
假设线程A调用了某个对象的wait()方法,线程A就会释放该对象的锁,同时线程A就进入到了该对象的等待池中,进入到等待池中的线程不会去竞争改对象的锁
notifyAll会让所有处于等待池的线程全部进入锁池去竞争获取锁的机会
notify只会随机选取一个处于等待池中的线程进入锁池去竞争获取锁的机会
例子
我们用例子演示说明
开3个等待的线程,一个通知的线程,通知的线程里面调用notify方法
public class ShowDemo {public static void main(String[] args) {
Object lock = new Object();
Runnable waitTask = new Runnable() {
@Override
public void run() {
synchronized (lock) {
try {
System.out.println(Thread.currentThread().getName() + " wait");
lock.wait();
System.out.println(Thread.currentThread().getName() + " notify");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
};
Runnable notifyTask = new Runnable() {
@Override
public void run() {
synchronized (lock) {
// lock.notifyAll(); 换成这个所有线程都结束
lock.notify();
}
}
};
Thread thread1 = new Thread(waitTask, "thread1");
Thread thread2 = new Thread(waitTask, "thread2");
Thread thread3 = new Thread(waitTask, "thread3");
thread1.start();
thread2.start();
thread3.start();
// 确保thread1,thread2,thread3都启动后,启动thread4
try {
TimeUnit.SECONDS.sleep(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
Thread thread4 = new Thread(notifyTask, "thread4");
thread4.start();
}
}
看到只有一个线程结束了,其余2个线程一直阻塞。
thread2 waitthread3 wait
thread1 wait
thread2 notify
将notifyTask中的notify换成notifyAll,输入如下,可以看到3个线程都正常结束
thread1 waitthread2 wait
thread3 wait
thread3 notify
thread2 notify
thread1 notify