写点什么

Java 架构进阶笔记:一不小心就死锁了,怎么办,java 区块链项目实战百度云

用户头像
极客good
关注
发布于: 刚刚

class Account {


private int balance;


/* 转账 */


void transfer( Account target, int amt )


{


/* 锁定转出账户 */


synchronized (this) { ①


/* 锁定转入账户 */


synchronized (target) { ②


if ( this.balance > amt )


{


this.balance -= amt;


target.balance += amt;


}


} }


}


}


关于这种现象,我们还可以借助资源分配图来可视化锁的占用情况(资源分配图是个有向图,它可以描述资源和线程的状态)。其中,资源用方形节点表示,线程用圆形节点表示;资源中的点指向线程的边表示线程已经获得该资源,线程指向资源的边则表示线程请求资源,但尚未得到。转账发生死锁时的资源分配图就如下图所示,一个“各据山头死等”的尴尬局面。



转账发生死锁时的资源分配图


如何预防死锁


======


并发程序一旦死锁,一般没有特别好的方法,很多时候我们只能重启应用。因此,解决死锁问题最好的办法还是规避死锁。


那如何避免死锁呢?要避免死锁就需要分析死锁发生的条件,有个叫 Coffman 的牛人早就总结过了,只有以下这四个条件都发生时才会出现死锁:


  1. 互斥,共享资源 X 和 Y 只能被一个线程占用;

  2. 占有且等待,线程 T1 已经取得共享资源 X,在等待共享资源 Y 的时候,不释放共享资源 X;

  3. 不可抢占,其他线程不能强行抢占线程 T1 占有的资源;

  4. 循环等待,线程 T1 等待线程 T2 占有的资源,线程 T2 等待线程 T1 占有的资源,就是循环等待。


反过来分析,?也就是说只要我们破坏其中一个,就可以成功避免死锁的发生。


其中,互斥这个条件我们没有办法破坏,因为我们用锁为的就是互斥。不过其他三个条件都是有办法破坏掉的,到底如何做呢?


  1. 对于“占用且等待”这个条件,我们可以一次性申请所有的资源,这样就不存在等待了。

  2. 对于“不可抢占”这个条件,占用部分资源的线程进一步申请其他资源时,如果申请不到,可以主动释放它占有的资源,这样不可抢占这个条件就破坏掉了。

  3. 对于“循环等待”这个条件,可以靠按序申请资源来预防。所谓按序申请,是指资源是有线性顺序的,申请的时候可以先申请资源序号小的,再申请资源序号大的,这样线性化后自然就不存在循环了。


我们已经从理论上解决了如何预防死锁,那具体如何体现在代码上呢?下面我们就来尝试用代码实践一下这些理论。


1. 破坏占用且等待条件


=============


从理论上讲,要破坏这个条件,可以一次性申请所有资源。在现实世界里,就拿前面我们提到的转账操作来讲,它需要的资源有两个,一个是转出账户,另一个是转入账户,当这两个账户同时被申请时,我们该怎么解决这个问题呢?


可以增加一个账本管理员,然后只允许账本管理员从文件架上拿账本,也就是说柜员不能直接在文件架上拿账本,必须通过账本管理员才能拿到想要的账本。例如,张三同时申请账本 A 和 B,账本管理员如果发现文件架上只有账本 A,这个时候账本管理员是不会把账本 A 拿下来给张三的,只有账本 A 和 B 都在的时候才会给张三。这样就保证了“一次性申请所有资源”。



通过账本管理员拿账本


对应到编程领域,“同时申请”这个操作是一个临界区,我们也需要一个角色(Java 里面的类)来管理这个临界区,我们就把这个角色定为 Allocator。它有两个重要功能,分别是:同时申请资源 apply() 和同时释放资源 free()。账户 Account 类里面持有一个 Allocator 的单例(必须是单例,只能由一个人来分配资源)。当账户 Account 在执行转账操作的时候,首先向 Allocator 同时申请转出账户和转入账户这两个资源,成功后再锁定这两个资源;当转账操作执行完,释放锁之后,我们需通知 Allocator 同时释放转出账户和转入账户这两个资源。具体的代码实现如下。


【一线大厂Java面试题解析+核心总结学习笔记+最新架构讲解视频+实战项目源码讲义】
浏览器打开:qq.cn.hn/FTf 免费领取
复制代码


class Allocator {


private List<Object> als =


new ArrayList<>();


/* 一次性申请所有资源 */


synchronized boolean apply(


Object from, Object to )


{


if ( als.contains( from ) ||


als.contains( to ) )


{


return(false);


} else {


als.add( from );


als.add( to );


}


return(true);


}


/* 归还资源 */


synchronized void free(


Object from, Object to )


{


als.remove( from );


als.remove( to );


}


}


class Account {


/* actr 应该为单例 */


private Allocator actr;


private int balance;


/* 转账 */


void transfer( Account target, int amt )


{


/* 一次性申请转出账户和转入账户,直到成功 */


while ( !actr.apply( this, target ) )



try{


/* 锁定转出账户 */


synchronized (this) {


/* 锁定转入账户 */


synchronized (target) {


if ( this.balance > amt )


{


this.balance -= amt;


target.balance += amt;


}


}


}


}


finally {


actr.free( this, target )


}


}


}


2. 破坏不可抢占条件


============


破坏不可抢占条件看上去很简单,核心是要能够主动释放它占有的资源,这一点 synchronized 是做不到的。原因是 synchronized 申请资源的时候,如果申请不到,线程直接进入阻塞状态了,而线程进入阻塞状态,啥都干不了,也释放不了线程已经占有的资源。


你可能会质疑,“Java 作为排行榜第一的语言,这都解决不了?”你的怀疑很有道理,Java 在语言层次确实没有解决这个问题,不过在 SDK 层面还是解决了的,java.util.concurrent 这个包下面提供的 Lock 是可以轻松解决这个问题的。关于这个话题,咱们后面会详细讲。


3. 破坏循环等待条件


============


破坏这个条件,需要对资源进行排序,然后按序申请资源。这个实现非常简单,我们假设每个账户都有不同的属性 id,这个 id 可以作为排序字段,申请的时候,我们可以按照从小到大的顺序来申请。比如下面代码中,①~⑥处的代码对转出账户(this)和转入账户(target)排序,然后按照序号从小到大的顺序锁定账户。这样就不存在“循环”等待了。


class Account {


private int id;


private int balance;


/* 转账 */


void transfer( Account target, int amt )


{


Account left = this ①


Account right = target; ②

用户头像

极客good

关注

还未添加个人签名 2021.03.18 加入

还未添加个人简介

评论

发布
暂无评论
Java架构进阶笔记:一不小心就死锁了,怎么办,java区块链项目实战百度云