背景:
线程同步(就是加锁)会有一个问题,就是产生死锁
所谓死锁: 是指两个或两个以上的进程在执行过程中,因争夺资源而造成的一种互相等待的现象,若无外力作用,它们都将无法推进下去。
帮助理解:
地上放着两个桶泡面,一个老坛酸菜,一个小鸡炖磨茹。有两个人:一个产品
(线程1),一个测试
(线程2),同时扑向抢老坛酸菜
(锁A)和小鸡炖磨茹
(锁B),产品拿到老坛酸菜,测试拿到小鸡炖磨茹,同一时刻,产品伸要去拽测试怀里的小鸡炖磨茹,测试伸手去拽产品的老坛酸菜,互使剪刀脚两个僵持不下,就卡死在那了,叫这就死锁。如果没有一个开发
将他们各打一顿解救出来(中断状态),它们将无法推进下去。
发生死锁的具体原因如下:
- 因为系统资源不足。
- 进程运行推进的顺序不合适。
- 资源分配不当。
举列说明场景:
死锁是因为多线程访问共享资源,由于访问的顺序不当所造成的,通常是一个线程锁定了一个资源A,而又想去锁定资源B;在另一个线程中,锁定了资源B,而又想去锁定资源A以完成自身的操作,两个线程都想得到对方的资源,而不愿释放自己的资源,造成两个线程都在等待,而无法执行的情况。
死锁预防
如果只使用一个锁就不会有死锁的问题,不过复杂场景下不太理实。
1.以确定的顺序获得锁
1 2 3
| 线程A ---> 锁定 A ----> 偿试锁定 B 线程B ---> 锁定 A ----> 偿试锁定 B 这样就不会发生死锁
|
2.超时放弃
Lock接口提供了boolean tryLock(long time, TimeUnit unit) throws InterruptedException方法,该方法可以按照固定时长等待锁,因此线程可以在获取锁超时以后,主动释放之前已经获得的所有的锁。通过这种方式,也可以很有效地避免死锁。
死锁示列:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50
| packag com.liukai.thread.daed_locl;
public class SyncDeadLock{ private static Object locka = new Object(); private static Object lockb = new Object();
public static void main(String[] args){ new SyncDeadLock().deadLock(); }
private void deadLock(){
Thread thread1 = new Thread(()->{ synchronized (locka){ try{ System.out.println(Thread.currentThread().getName()+" 拿到 lock-A!"); Thread.sleep(500); System.out.println(Thread.currentThread().getName()+" 睡眠 500ms 后续继执行...!"); }catch(Exception e){ e.printStackTrace(); } System.out.println(Thread.currentThread().getName()+" 偿试获取 lock-B!"); synchronized (lockb){ System.out.println(Thread.currentThread().getName()+" 已获得 lock-B!"); } } }, "thread1");
Thread thread2 = new Thread(()->{ synchronized (lockb){ try{ System.out.println(Thread.currentThread().getName()+" 拿到 lock-B!"); Thread.sleep(500); System.out.println(Thread.currentThread().getName()+" 睡眠 500ms 后续继执行...!"); }catch(Exception e){ e.printStackTrace(); } System.out.println(Thread.currentThread().getName()+" 偿试获取 lock-A!"); synchronized (locka){ System.out.println(Thread.currentThread().getName()+" 已获得 lock-A!"); } } },"thread2");
thread1.start(); thread2.start(); } }
|