快捷導(dǎo)航

Java多線程中的ReentrantLock可中斷鎖詳細(xì)解讀

更新時(shí)間：2023年12月14日 08:54:34 作者：Terisadeng

這篇文章主要介紹了Java多線程中的ReentrantLock可中斷鎖詳細(xì)解讀,ReentrantLock中的lockInterruptibly()方法使得線程可以在被阻塞時(shí)響應(yīng)中斷,比如一個(gè)線程t1通過lockInterruptibly()方法獲取到一個(gè)可重入鎖,并執(zhí)行一個(gè)長(zhǎng)時(shí)間的任務(wù),需要的朋友可以參考下

ReentrantLock可中斷鎖

ReentrantLock中的lockInterruptibly()方法使得線程可以在被阻塞時(shí)響應(yīng)中斷，比如一個(gè)線程t1通過lockInterruptibly()方法獲取到一個(gè)可重入鎖，并執(zhí)行一個(gè)長(zhǎng)時(shí)間的任務(wù)，另一個(gè)線程通過interrupt()方法就可以立刻打斷t1線程的執(zhí)行，來獲取t1持有的那個(gè)可重入鎖。而通過ReentrantLock的lock()方法或者Synchronized持有鎖的線程是不會(huì)響應(yīng)其他線程的interrupt()方法的，直到該方法主動(dòng)釋放鎖之后才會(huì)響應(yīng)interrupt()方法。下面看一個(gè)示例：

package com.teriste.thread;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.ReentrantLock;
/**
 * 測(cè)試ReentrantLock可中斷鎖的效果
 */
public class ThreadInteruptDemo {
    ReentrantLock lock1=new ReentrantLock();
    ReentrantLock lock2=new ReentrantLock();
    /**
     * ReentrantLock響應(yīng)中斷
     * @throws Exception
     */
    public void exeInterupt() throws Exception{
        Thread t1=new Thread(new DemoThread(lock1,lock2));
        Thread t2=new Thread(new DemoThread(lock2,lock1));
        t1.start();
        t2.start();
        System.out.println(t1.getName()+"中斷");
        //主線程睡眠1秒，避免線程t1直接響應(yīng)run方法中的睡眠中斷
        Thread.sleep(1000);
        t1.interrupt();
        //阻塞主線程，避免所有線程直接結(jié)束，影響死鎖效果
        Thread.sleep(10000);
    }
    Object syn1=new Object();
    Object syn2=new Object();
    /**
     * Synchronized響應(yīng)中斷
     * @throws Exception
     */
    public void exeInteruptSyn() throws Exception{
        Thread t1=new Thread(new DemoThread1(syn1,syn2));
        Thread t2=new Thread(new DemoThread1(syn2,syn1));
        t1.start();
        t2.start();
        System.out.println(t1.getName()+"中斷");
        //主線程睡眠1秒，避免線程t1直接響應(yīng)run方法中的睡眠中斷
        Thread.sleep(1000);
        t1.interrupt();
        //阻塞主線程，避免所有線程直接結(jié)束，影響死鎖效果
        Thread.sleep(100000);
    }
    /**
     * ReentrantLock實(shí)現(xiàn)死鎖
     */
    static class DemoThread implements Runnable{
        ReentrantLock lock1;
        ReentrantLock lock2;
        public DemoThread(ReentrantLock lock1,ReentrantLock lock2){
            this.lock1=lock1;
            this.lock2=lock2;
        }
        @Override
        public void run() {
            try {
                //可中斷的獲取鎖
                lock1.lockInterruptibly();
                //lock1.lock();
                //睡眠200毫秒，保證兩個(gè)線程分別已經(jīng)獲取到兩個(gè)鎖，實(shí)現(xiàn)相互的鎖等待
                TimeUnit.MILLISECONDS.sleep(200);
                //lock2.lock();
                //可中斷的獲取鎖
                lock2.lockInterruptibly();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }finally {
                lock1.unlock();
                lock2.unlock();
                System.out.println("線程"+Thread.currentThread().getName()+"正常結(jié)束");
            }
        }
    }
    /**
     * Synchronized實(shí)現(xiàn)死鎖
     */
    static class DemoThread1 implements Runnable{
        Object lock1;
        Object lock2;
        public DemoThread1(Object lock1,Object lock2){
            this.lock1=lock1;
            this.lock2=lock2;
        }
        @Override
        public void run() {
            try {
                synchronized (lock1){
                    //睡眠200毫秒，再獲取另一個(gè)鎖，
                    //保證兩個(gè)線程分別已經(jīng)獲取到兩個(gè)鎖，實(shí)現(xiàn)相互的鎖等待
                    TimeUnit.MILLISECONDS.sleep(200);
                    synchronized (lock2){
                    }
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }finally {
                System.out.println("線程"+Thread.currentThread().getName()+"正常結(jié)束");
            }
        }
    }
}

測(cè)試代碼：

package com.teriste.thread;
import org.junit.Test;
public class ThreadInteruptDemoTest {
    /**
     * 測(cè)試ReentrantLock響應(yīng)中斷
     * @throws Exception
     */
    @Test
    public void exeInteruptTest() throws Exception{
        ThreadInteruptDemo demo=new ThreadInteruptDemo();
        demo.exeInterupt();
    }
    /**
     * 測(cè)試Synchronized響應(yīng)中斷
     * @throws Exception
     */
    @Test
    public void exeInteruptSynTest() throws Exception{
        ThreadInteruptDemo demo=new ThreadInteruptDemo();
        demo.exeInteruptSyn();
    }
}

當(dāng)執(zhí)行exeInteruptTest()方法時(shí)，可以看到線程t1立刻響應(yīng)了主線程的interrupt()方法：