并发b+树协议.

2018-04-01  本文已影响134人  SeaRise

    下降方法 {
        获取根节点并锁住根节点(读锁)     
        while (true) {
            if (此节点是叶子节点) {
                if (插入方法调用) {
                    //这里为什么不用锁升级而要这么做,后面会解释.
                    解锁此节点(读锁)
                    此节点加锁(写锁)
                    更新此节点的内容.
                }
                返回此节点(此时此节点加锁,读调用加读锁,插入调用加写锁)
            }           
            int rightPos;
            while (需要右移) {
                获取右节点位置
                此节点解锁(读锁)
                获取右节点并加锁(读锁)
                此节点等于右节点
            }
            
            获取下降位置
            此节点解锁
            获取下一层节点并加锁
        }
    }

   读方法 {
        调用下降方法,获取叶子节点(已加读锁)
        while (true) {
            if (需要右移) {
                获取右节点位置
                此节点解锁(读锁)
                获取右节点并加锁(读锁)
                此节点等于右节点
                continue;
            }
            
            检索叶子节点,查找是否有符合的key.
            解锁此节点.
            返回value;
        }
    }

    插入方法 {
        调用下降方法,获取叶子节点(已加写锁)
        
        while (需要右移) {
            获取右节点位置
            此节点解锁(写锁)
            获取右节点并加锁(写锁)
            此节点等于右节点
        }
        
        if (节点满) {
            调用分裂方法
        } else {
            插入key和value在此节点中.
            此节点解锁(写锁).
        }
    }

    分裂方法 {
        while (此节点满) {
            if (此节点为根节点) {
                创建一个新的根节点(不用加锁)
                分裂当前节点产生一个新节点(不用加锁)
                key等于新节点的最小键值,value等于新节点的位置.
            } else {
                分裂当前节点产生一个新节点,且把key和value插入相应节点(不用加锁)
                key等于新节点的最小键值,value等于新节点的位置.
                获取父节点并加锁(写锁,且需要右移,右移与插入方法中的写法一致)
            }
            
            解锁当前节点(写锁)
            当前节点等于父节点
        }
        把key和value插入当前节点
        解锁当前节点(写锁)
    }

在这里提一下,我实现这个b+树的时候,b+树的节点储存在一个有日志的存储模块,节点写入前会记录在日志,重新启动时会重写日志的内容,所以每个节点要么完全写入了磁盘,要么完全没写入磁盘,
也就是说这个协议不用关注节点本身结构是否会被破坏,只关注节点之间的关系是否会影响b+树的一致性.

上一篇下一篇

猜你喜欢

热点阅读