Java 利用信号量机制解决线程死锁问题

我不是女神ヾ 2023-08-17 17:08 43阅读 0赞

### 1、解决死锁方案 ###

为了解决多线程死锁问题，不是不使用锁，而是用信号量去控制。

**信号量 **可以控制资源能被多少线程访问，此处指定只能被一个线程访问，就实现了锁的功能；然而，信号量可以指定获取的超时时间，所以，可以根据这个超时时间，去做一个额外处理。

对于无法成功获取的情况，一般就是重复尝试（循环等待），或指定重试次数，或者立刻返回退出。

### 2、解决死锁代码实例 ###

package lock;
    
    import java.text.SimpleDateFormat;
    import java.util.Date;
    import java.util.concurrent.Semaphore;
    import java.util.concurrent.TimeUnit;
    
    public class UnLockTest {
        public static final Semaphore a1 = new Semaphore(1);
        public static final Semaphore a2 = new Semaphore(1);
    
        public static void main(String[] args) {
            LockA la = new LockA();
            new Thread(la).start();
    
            LockB lb = new LockB();
            new Thread(lb).start();
    
        }
    }
    
    class LockA implements Runnable {
        public void run() {
            try {
                SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                System.out.println(sf.format(new Date()) + " LockA 开始执行...");
                boolean flag = false;
                while (true) {
                    if (UnLockTest.a1.tryAcquire(1, TimeUnit.SECONDS)) {
                        System.out.println(sf.format(new Date()) + " LockA 锁住 obj1");
                        if (UnLockTest.a2.tryAcquire(1, TimeUnit.SECONDS)) {
                            System.out.println(sf.format(new Date()) + " LockA 锁住 obj2");
                            Thread.sleep(2000); // do something
                            flag = true;
                        } else {
                            System.out.println(sf.format(new Date()) + "LockA 锁 obj2 失败");
                        }
                    } else {
                        System.out.println(sf.format(new Date()) + "LockA 锁 obj1 失败");
                    }
    
                    UnLockTest.a1.release(); // 释放
                    UnLockTest.a2.release(); // 释放
    
                    if (flag) {
                        System.out.println("LockA 结束....");
                        return;
                    }
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
    
    class LockB implements Runnable {
        public void run() {
            try {
                SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                System.out.println(sf.format(new Date()) + " LockB 开始执行...");
                boolean flag = false;
                while (true) {
                    if (UnLockTest.a2.tryAcquire(1, TimeUnit.SECONDS)) {
                        System.out.println(sf.format(new Date()) + " LockB 锁住 obj2");
                        if (UnLockTest.a1.tryAcquire(1, TimeUnit.SECONDS)) {
                            System.out.println(sf.format(new Date()) + " LockB 锁住 obj1");
                            Thread.sleep(1000); // do something
                            flag = true;
                        } else {
                            System.out.println(sf.format(new Date()) + "LockB 锁 obj1 失败");
                        }
                    } else {
                        System.out.println(sf.format(new Date()) + "LockB 锁 obj2 失败");
                    }
    
                    UnLockTest.a1.release(); // 释放
                    UnLockTest.a2.release(); // 释放
    
                    if (flag) {
                        System.out.println("LockB 结束....");
                        return;
                    }
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }