Java线程死锁的问题解决

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文件中配置线程池相关参数（核心线程数、工作队列大小、最大线程数）。
    @Resource(name = "applicationTaskExecutor")
    private ThreadPoolTaskExecutor threadPoolTaskExecutor;
 
    // 入参createThreadNum：要创建的线程数。尽量设置个十几二十个，设置的太小可能程序执行太快就发生不了死锁。
    public void deadlockTest(int createThreadNum) {
        // 计数器
        CountDownLatch sunCdl = new CountDownLatch(createThreadNum);
        // 1- 填充数据
        List<DeadLockObj> deadLockObjList = new ArrayList<>(createThreadNum);
        /**
         * for循环 创建DeadLockObj对象，这里只创建了两种对象。
         * 这里创建两种对象的原因是为了 后面创建的线程互相持有锁。
         */
        for (int i = 0; i < createThreadNum; i++) {
            if (i % 2 != 0) {
                // i 为 奇数时，给 DeadLockObj 对象的 a = 1，b = 2。
                deadLockObjList.add(new DeadLockObj(i, 1, 2));
            } else {
                // i 为 偶数时，给 DeadLockObj 对象的 a = 2，b = 1。
                deadLockObjList.add(new DeadLockObj(i, 2, 1));
            }
        }
        deadLockObjList.sort(Comparator.comparingInt(DeadLockObj::getId));
 
        // 循环数据，调用 deadLockInternal()方法，展示死锁情况。
        deadLockObjList.forEach(deadLockObj -> {
            this.threadPoolTaskExecutor.execute(() -> {
                try {
                    sunCdl.await();
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }
 
                // 在高并发情况下，必然会出现死锁。
                this.deadLockInternal(deadLockObj);
            });
        });
 
        // 循环将 计数器 减1，当减为0时，上面的线程就开始 真正的并发执行。
        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持有。
         *   同时，线程B 抢占 Integer.valueOf(1)，但是1被线程A持有。
         * 线程A 和 线程B 要抢占的锁都被对方持有，所以，必然会出现死锁。
         */
 
        // 第一把锁
        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;
    }
 
}