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

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();
        }
    }
}