diff --git a/goSTL/data_structure/lru/lru.go b/goSTL/data_structure/lru/lru.go index 66b36ad..f469b85 100644 --- a/goSTL/data_structure/lru/lru.go +++ b/goSTL/data_structure/lru/lru.go @@ -1,16 +1,27 @@ package lru -//最近最少使用 -//相对于仅考虑时间因素的FIFO和仅考虑访问频率的LFU，LRU算法可以认为是相对平衡的一种淘汰算法 -//LRU认为，如果数据最近被访问过，那么将来被访问的概率也会更高 -//LRU 算法的实现非常简单，维护一个队列 -//如果某条记录被访问了，则移动到队尾，那么队首则是最近最少访问的数据，淘汰该条记录即可。 +//@Title lru +//@Description +// LRU-Least Recently Used，最近最少使用链结构 +// 相对于仅考虑时间因素的FIFO和仅考虑访问频率的LFU，LRU算法可以认为是相对平衡的一种淘汰算法 +// LRU认为，如果数据最近被访问过，那么将来被访问的概率也会更高 +// LRU 算法的实现非常简单，维护一个队列 +// 如果某条记录被访问了，则移动到队尾，那么队首则是最近最少访问的数据，淘汰该条记录即可。 +// 可接纳不同类型的元素 +// 使用并发控制锁保证线程安全 +// 使用map加快索引速率 +// 不做定时淘汰 import ( "container/list" "sync" ) //LRU链结构体 +//包含了该LRU结构中能承载的byte数上限和当前已承载的数量 +//以链表的形式存储承载元素 +//使用map建立key索引和链表结点之间的联系,链表结点中存放其value +//onRemove函数是用于在删除时的执行,可用于将数据持久化 +//使用并发控制所保证线程安全 type LRU struct { maxBytes int64 //所能承载的最大byte数量 nowBytes int64 //当前承载的byte数 @@ -20,7 +31,9 @@ type LRU struct { mutex sync.Mutex //并发控制锁 } -//索引结构体, +//索引结构体 +//保存了一个待存储值的索引和值 +//value值为一个interface{},需要实现它的长度函数即Len() type indexes struct { key string //索引 value Value //存储值 @@ -28,10 +41,32 @@ type indexes struct { //存储值的函数 type Value interface { - Len() int//用于计算该存储值所占用的长度 + Len() int //用于计算该存储值所占用的长度 } -func New(maxBytes int64, onRemove func(string, Value)) *LRU { +//lru链容器接口 +//存放了lru容器可使用的函数 +//对应函数介绍见下方 +type lruer interface { + Size() (num int64) //返回lru中当前存放的byte数 + Cap() (num int64) //返回lru能存放的byte树的最大值 + Clear() //清空lru,将其中存储的所有元素都释放 + Empty() (b bool) //判断该lru中是否存储了元素 + Insert(key string, value Value) //向lru中插入以key为索引的value + Erase(key string) //从lru中删除以key为索引的值 + Get(key string) (value Value, ok bool) //从lru中获取以key为索引的value和是否获取成功? +} + +//@title New +//@description +// 新建一个lru链容器并返回 +// 初始的lru不存储元素 +// 需要传入其最大存储的bytes和删除后的执行函数 +//@receiver nil +//@param maxBytes int64 该LRU能存储的最大byte数 +//@param onRemove func(string, Value) 删除元素后的执行函数,一般建议做持久化 +//@return l *LRU 新建的LRU指针 +func New(maxBytes int64, onRemove func(string, Value)) (l *LRU) { return &LRU{ maxBytes: maxBytes, nowBytes: 0, @@ -41,19 +76,94 @@ func New(maxBytes int64, onRemove func(string, Value)) *LRU { mutex: sync.Mutex{}, } } -//向该LRU中插入以key为索引的value -//若已经存在则将其放到队尾 -//若空间充足且不存在则直接插入队尾 -//若空间不足则淘汰队首元素再将其插入队尾 + +//@title Size +//@description +// 以LRU链容器做接收者 +// 返回该LRU链当前所存储的byte数 +//@receiver l *LRU 接受者LRU的指针 +//@param nil +//@return num uint64 该LRU链当前所存储的byte数 +func (l *LRU) Size() (num int64) { + if l == nil { + return 0 + } + return l.nowBytes +} + +//@title Cap +//@description +// 以LRU链容器做接收者 +// 返回该LRU链能存储的最大byte数 +//@receiver l *LRU 接受者LRU的指针 +//@param nil +//@return num uint64 该LRU链所能存储的最大byte数 +func (l *LRU) Cap() (num int64) { + if l == nil { + return 0 + } + return l.maxBytes +} + +//@title Clear +//@description +// 以LRU链容器做接收者 +// 将LRU链中的所有承载的元素清除 +// 同时将map清空,将当前存储的byte数清零 +//@receiver l *LRU 接受者LRU的指针 +//@param nil +//@return nil +func (l *LRU) Clear() { + if l == nil { + return + } + l.mutex.Lock() + l.ll = list.New() + l.cache = make(map[string]*list.Element) + l.nowBytes = 0 + l.mutex.Unlock() +} + +//@title Empty +//@description +// 以LRU链容器做接收者 +// 判断该LRU链中是否存储了元素 +// 没存储则返回true,LRU不存在也返回true +// 否则返回false +//@receiver l *LRU 接受者LRU的指针 +//@param nil +//@return b bool 该容器是空的吗? +func (l *LRU) Empty() (b bool) { + if l == nil { + return true + } + return l.nowBytes <= 0 +} + +//@title Insert +//@description +// 以LRU链容器做接收者 +// 向该LRU中插入以key为索引的value +// 若已经存在则将其放到队尾 +// 若空间充足且不存在则直接插入队尾 +// 若空间不足则淘汰队首元素再将其插入队尾 +// 插入完成后将当前已存的byte数增加 +//@receiver l *LRU 接受者LRU的指针 +//@param key string 待插入结点的索引key +//@param value Value 待插入元素的值value,本质也是个interface{} +//@return nil func (l *LRU) Insert(key string, value Value) { l.mutex.Lock() + //利用map从已存的元素中寻找 if ele, ok := l.cache[key]; ok { + //该key已存在,直接替换即可 l.ll.MoveToFront(ele) kv := ele.Value.(*indexes) //此处是一个替换,即将cache中的value替换为新的value,同时根据实际存储量修改其当前存储的实际大小 l.nowBytes += int64(value.Len()) - int64(kv.value.Len()) kv.value = value } else { + //该key不存在,需要进行插入 ele := l.ll.PushFront(&indexes{key, value}) l.cache[key] = ele //此处是一个增加操作,即原本不存在,所以直接插入即可,同时在当前数值范围内增加对应的占用空间 @@ -61,6 +171,8 @@ func (l *LRU) Insert(key string, value Value) { } //添加完成后根据删除掉尾部一部分数据以保证实际使用空间小于设定的空间上限 for l.maxBytes != 0 && l.maxBytes < l.nowBytes { + //删除队尾元素 + //删除后执行创建时传入的删除执行函数 ele := l.ll.Back() if ele != nil { l.ll.Remove(ele) @@ -76,15 +188,24 @@ func (l *LRU) Insert(key string, value Value) { } l.mutex.Unlock() } -//删除队尾元素 -//删除后执行创建时传入的删除执行函数 -func (l *LRU) Erase() { + +//@title Erase +//@description +// 以LRU链容器做接收者 +// 从LRU链中删除以key为索引的value +// 如果不存在则直接结束 +// 删除完成后将其占用的byte数减去 +// 删除后执行函数回调函数,一般用于持久化 +//@receiver l *LRU 接受者LRU的指针 +//@param key string 待删除的索引key +//@return nil +//以key为索引删除元素 +func (l *LRU) Erase(key string) { l.mutex.Lock() - ele := l.ll.Back() - if ele != nil { + if ele, ok := l.cache[key]; ok { l.ll.Remove(ele) kv := ele.Value.(*indexes) - //删除最末尾的同时将其占用空间减去 + //删除的同时将其占用空间减去 delete(l.cache, kv.key) l.nowBytes -= int64(len(kv.key)) + int64(kv.value.Len()) if l.onRemove != nil { @@ -94,11 +215,21 @@ func (l *LRU) Erase() { } l.mutex.Unlock() } -//从LRU链中寻找以key为索引的value -//找到则返回,否则返回nil和false + +//@title Get +//@description +// 以LRU链容器做接收者 +// 从LRU链中寻找以key为索引的value +// 找到对应的value后将其移到首部,随后返回其value +// 如果没找到以key为索引的value,直接结束即可 +//@receiver l *LRU 接受者LRU的指针 +//@param key string 待查找的索引key +//@return value Value 以key为索引的value,本质是个interface{} +//@return ok bool 查找成功? func (l *LRU) Get(key string) (value Value, ok bool) { l.mutex.Lock() if ele, ok := l.cache[key]; ok { + //找到了value,将其移到链表首部 l.ll.MoveToFront(ele) kv := ele.Value.(*indexes) l.mutex.Unlock() diff --git a/goSTL/data_structure/vector/vector.go b/goSTL/data_structure/vector/vector.go index 6eb16a4..9b3c78d 100644 --- a/goSTL/data_structure/vector/vector.go +++ b/goSTL/data_structure/vector/vector.go @@ -24,7 +24,6 @@ import ( //当添加节点时尾指针大于已分配空间长度,则按照扩容策略进行扩容 //并发控制锁用以保证在高并发过程中不会出现错误 //使用比较器重载了Sort - type Vector struct { data []interface{} //动态数组 len uint64 //当前已用数量 @@ -32,11 +31,12 @@ type Vector struct { mutex sync.Mutex //并发控制锁 } +//vector扩容边界,边界内进行翻倍扩容,边界外进行固定扩容 const bound = 4294967296 + //vector向量容器接口 //存放了vector容器可使用的函数 //对应函数介绍见下方 - type vectorer interface { Iterator() (i *Iterator.Iterator) //返回一个包含vector所有元素的迭代器 Sort(Cmp ...comparator.Comparator) //利用比较器对其进行排序