TRKJ/EdgeNode
2
0
Fork 0
mirror of https://github.com/TeaOSLab/EdgeNode.git synced 2025-11-22 22:40:30 +08:00
Code Issues Packages Projects Releases Wiki Activity

内存缓存去除不必要的lock

Browse Source
This commit is contained in:
GoEdgeLab
2021-03-03 14:28:54 +08:00
parent d52199254a
commit 0b9f37d9c4
1 changed files with 0 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
internal/caches/writer_memory.go
View File

@@ -38,20 +38,14 @@ func NewMemoryWriter(m map[uint64]*MemoryItem, key string, expiredAt int64, stat
// 写入数据 // 写入数据
func (this *MemoryWriter) WriteHeader(data []byte) (n int, err error) { func (this *MemoryWriter) WriteHeader(data []byte) (n int, err error) {
this.headerSize += int64(len(data)) this.headerSize += int64(len(data))
this.locker.Lock()
this.item.HeaderValue = append(this.item.HeaderValue, data...) this.item.HeaderValue = append(this.item.HeaderValue, data...)
this.locker.Unlock()
return len(data), nil return len(data), nil
} }
// 写入数据 // 写入数据
func (this *MemoryWriter) Write(data []byte) (n int, err error) { func (this *MemoryWriter) Write(data []byte) (n int, err error) {
this.bodySize += int64(len(data)) this.bodySize += int64(len(data))
this.locker.Lock()
this.item.BodyValue = append(this.item.BodyValue, data...) this.item.BodyValue = append(this.item.BodyValue, data...)
this.locker.Unlock()
return len(data), nil return len(data), nil
} }