Method Put

internal/caches/open_file_pool.go:59–82

(file *OpenFile)

}

func (this *OpenFilePool) Put(file *OpenFile) bool {
	// 如果已关闭，则不接受新的文件
	if this.isClosed {
		_ = file.Close()
		return false
	}

	// 检查文件版本号
	if this.version > 0 && file.version > 0 && file.version != this.version {
		_ = file.Close()
		return false
	}

	// 加入Pool
	select {
	case this.c <- file:
		this.usedSize += file.size
		return true
	default:
		// 多余的直接关闭
		_ = file.Close()
		return false
	}
}

func (this *OpenFilePool) Len() int {
	return len(this.c)