static Object a = new Object();
static Object b = new Object();
public static void main(String[] args) throws InterruptedException, IOException {
final CountDownLatch countDownLatch = new CountDownLatch(1);
final Thread threadA = new Thread(new Runnable() {
@Override
public void run() {
System.out.println(Thread.currentThread().getId() + "获取a");
synchronized (a) {
System.out.println(Thread.currentThread().getId() + "进入a");
try {
countDownLatch.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getId() + "获取b");
synchronized (b) {
System.out.println(Thread.currentThread().getId() + "进入b");
}
}
}
});
threadA.start();
final Thread threadB = new Thread(new Runnable() {
@Override
public void run() {
System.out.println(Thread.currentThread().getId() + "获取b");
synchronized (b) {
System.out.println(Thread.currentThread().getId() + "进入b");
try {
countDownLatch.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getId() + "获取a");
synchronized (a) {
System.out.println(Thread.currentThread().getId() + "进入a");
}
}
}
});
threadB.start();
new Thread(new Runnable() {
@Override
public void run() {
countDownLatch.countDown();
System.out.println("threada interrupt");
threadA.interrupt();
System.out.println("threadb interrupt");
threadB.interrupt();
System.out.println("获取aaaaaa 前");
synchronized (a) {
System.out.println("获取aaaaaa");
}
}
}).start();
TimeUnit.SECONDS.sleep(10);
}
sychronized 不响应中断的证明
image.png
reentrantLock 响应锁中断
public static void main(String[] args) {
final ReentrantLock reentrantLockA = new ReentrantLock();
final ReentrantLock reentrantLockB = new ReentrantLock();
final CountDownLatch countDownLatch = new CountDownLatch(1);
final Thread threadA = new Thread(new Runnable() {
@Override
public void run() {
System.out.println(Thread.currentThread().getId() + "获取a");
try {
reentrantLockA.lockInterruptibly();
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getId() + "进入a");
try {
countDownLatch.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getId() + "获取b");
try {
reentrantLockB.lockInterruptibly();
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getId() + "进入b");
reentrantLockB.unlock();
reentrantLockA.unlock();
}
});
threadA.start();
final Thread threadB = new Thread(new Runnable() {
@Override
public void run() {
System.out.println(Thread.currentThread().getId() + "获取b");
try {
reentrantLockB.lockInterruptibly();
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getId() + "进入b");
try {
countDownLatch.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getId() + "获取a");
try {
reentrantLockA.lockInterruptibly();
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getId() + "进入a");
reentrantLockA.unlock();
reentrantLockB.unlock();
}
});
threadB.start();
new Thread(new Runnable() {
@Override
public void run() {
countDownLatch.countDown();
System.out.println("threada interrupt");
//threadA.interrupt();
System.out.println("threadb interrupt");
//threadB.interrupt();
System.out.println("获取aaaaaa 前");
reentrantLockA.lock();
System.out.println("获取aaaaaa");
reentrantLockA.unlock();
}
}).start();
}
先注释掉interrupt的情况
image.png
取消注释后的情况
image.png
