快捷導(dǎo)航

Java線程死鎖的問題解決

更新時(shí)間：2026年03月19日 09:28:30 作者：ZePingPingZe

本文主要介紹了Java線程死鎖的問題解決,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

1. 死鎖案例

死鎖：線程之間互相持有對(duì)方的鎖，并且等待獲取對(duì)方持有的鎖。

案例如下：我這里直接寫的service層代碼，沒寫測(cè)試類（測(cè)試類直接調(diào)用deadLockTest()方法）。

package cn.sh.tools.service.component.lock;
 
import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.stereotype.Component;
 
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.Comparator;
import java.util.List;
import java.util.concurrent.CountDownLatch;
 
/**
 * @Description
 * @Classname LockComponent
 * @Date 2023/4/28
 * @Author sh
 **/
@Component
@Slf4j
public class LockComponent {
 
    // 記得在 yml文件中配置線程池相關(guān)參數(shù)（核心線程數(shù)、工作隊(duì)列大小、最大線程數(shù)）。
    @Resource(name = "applicationTaskExecutor")
    private ThreadPoolTaskExecutor threadPoolTaskExecutor;
 
    // 入?yún)reateThreadNum：要?jiǎng)?chuàng)建的線程數(shù)。盡量設(shè)置個(gè)十幾二十個(gè)，設(shè)置的太小可能程序執(zhí)行太快就發(fā)生不了死鎖。
    public void deadlockTest(int createThreadNum) {
        // 計(jì)數(shù)器
        CountDownLatch sunCdl = new CountDownLatch(createThreadNum);
        // 1- 填充數(shù)據(jù)
        List<DeadLockObj> deadLockObjList = new ArrayList<>(createThreadNum);
        /**
         * for循環(huán) 創(chuàng)建DeadLockObj對(duì)象，這里只創(chuàng)建了兩種對(duì)象。
         * 這里創(chuàng)建兩種對(duì)象的原因是為了 后面創(chuàng)建的線程互相持有鎖。
         */
        for (int i = 0; i < createThreadNum; i++) {
            if (i % 2 != 0) {
                // i 為 奇數(shù)時(shí)，給 DeadLockObj 對(duì)象的 a = 1，b = 2。
                deadLockObjList.add(new DeadLockObj(i, 1, 2));
            } else {
                // i 為 偶數(shù)時(shí)，給 DeadLockObj 對(duì)象的 a = 2，b = 1。
                deadLockObjList.add(new DeadLockObj(i, 2, 1));
            }
        }
        deadLockObjList.sort(Comparator.comparingInt(DeadLockObj::getId));
 
        // 循環(huán)數(shù)據(jù)，調(diào)用 deadLockInternal()方法，展示死鎖情況。
        deadLockObjList.forEach(deadLockObj -> {
            this.threadPoolTaskExecutor.execute(() -> {
                try {
                    sunCdl.await();
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }
 
                // 在高并發(fā)情況下，必然會(huì)出現(xiàn)死鎖。
                this.deadLockInternal(deadLockObj);
            });
        });
 
        // 循環(huán)將 計(jì)數(shù)器 減1，當(dāng)減為0時(shí)，上面的線程就開始 真正的并發(fā)執(zhí)行。
        for (int i = 0; i < createThreadNum; i++) {
            sunCdl.countDown();
        }
    }
 
    private void deadLockInternal(DeadLockObj deadLockObj) {
        /**
         * ① 線程A 持有 Integer.valueOf(1)，線程B 持有 Integer.valueOf(2)
         * ② 線程A 搶占 Integer.valueOf(2)，但是2被線程B持有。
         *   同時(shí)，線程B 搶占 Integer.valueOf(1)，但是1被線程A持有。
         * 線程A 和 線程B 要搶占的鎖都被對(duì)方持有，所以，必然會(huì)出現(xiàn)死鎖。
         */
 
        // 第一把鎖
        synchronized (Integer.valueOf(deadLockObj.getA())) {
            // 第二把鎖
            synchronized (Integer.valueOf(deadLockObj.getB())) {
                System.out.println(deadLockObj.getId());
            }
        }
    }
 
    @Getter
    @AllArgsConstructor
    static class DeadLockObj {
        Integer id;
        int a;
        int b;
    }
 
}