Method PurgeLFU

internal/caches/list_memory.go:277–335

(count int, callback func(hash string) error)

}

func (this *MemoryList) PurgeLFU(count int, callback func(hash string) error) error {
	if count <= 0 {
		return nil
	}

	var deletedHashList = []string{}

	var week = currentWeek()
	var round = 0

	this.locker.Lock()

Loop:
	for {
		var found = false
		round++
		for _, itemMap := range this.itemMaps {
			for hash, item := range itemMap {
				found = true

				if week-item.Week <= 1 /** 最近有在使用 **/ && round <= 3 /** 查找轮数过多还不满足数量要求的就不再限制 **/ {
					continue
				}

				if this.onRemove != nil {
					this.onRemove(item)
				}

				atomic.AddInt64(&this.count, -1)
				delete(itemMap, hash)
				deletedHashList = append(deletedHashList, hash)

				count--
				if count <= 0 {
					break Loop
				}

				break
			}
		}
		if !found {
			break
		}
	}

	this.locker.Unlock()

	// 执行外部操作
	for _, hash := range deletedHashList {
		if callback != nil {
			err := callback(hash)
			if err != nil {
				return err
			}
		}
	}

	return nil