代码如下:
/**
* 自定义线程类
*/
public class MyThread extends Thread{
private static final ReentrantLock LOCK = new ReentrantLock();
private static final Condition condition = LOCK.newCondition();
public MyThread(String name) {
super(name);
}
@Override
public void run(){
LOCK.lock();
try {
System.out.println(super.getName() + " exe");
while (true) {
try {
condition.await(1, TimeUnit.SECONDS);
System.out.println(super.getName() + " await finish");
} catch (InterruptedException e) {
System.out.println(super.getName() + " interrupt");
System.out.println(this.getState());
}
}
} finally {
LOCK.unlock();
System.out.println(super.getName() + " unlock");
}
}
public static void main(String[] args) {
Thread thread1 = new MyThread("thread1");
thread1.start();
Thread thread2 = new MyThread("thread2");
thread2.start();
Thread thread3 = new MyThread("thread3");
thread3.start();
}
}
结果如下:
thread1 exe
thread2 exe
thread3 exe
thread1 await finish
thread3 await finish
thread2 await finish
thread3 await finish
thread1 await finish
thread2 await finish
我最初设想的是,三个线程抢LOCK锁,只有1个线程抢到,其他两个线程处于阻塞状态。
但从结果来看,三个线程都抢到了,请问这是为什么呢?
condition.await()方法后,会使得当前线程释放lock然后加入到等待队列中也就是说你这个锁加的没啥意义
Condition先搞清下这个类干嘛用,怎么用,它的await方法会使当前获得锁的线程进入等待状态并且释放锁,别的等待线程就可以继续竞争这个锁了。
因为三个线程各自用的是自己的锁的呀,你把 Lock 对象作为一个成员变量,由 main 传进去,那么所有的 Thread 实例共享一把锁,就会存在互斥了。
这里的问题根源是每个线程锁住的都是自己独立的 Lock 实例。