Go sync.Map.CompareAndDelete 怎样按旧值安全删除

sync.Map.CompareAndDelete 是 Go 标准库 sync 包提供的原子操作接口，要实现按指定旧值安全删除元素，直接传入待操作的键、以及你预期匹配的旧值作为两个入参即可。方法内部会全程以原子态完成校验，只有当当前 sync.Map 里对应键存储的实际值和你传入的旧值完全相等时，才会真正执行删除动作，整个操作过程不会被其他 Goroutine 的并发读写打断，天然解决了普通场景下先取值、再判等、再删除的多步操作竞态问题。

CompareAndDelete 不需要你额外加互斥锁，就能在并发场景下，安全完成「旧值匹配校验+条件删除」的组合操作，确保只有符合预期旧值的元素才会被移除。

我在清理并发缓存时遇到过一个很隐蔽的问题：先 Load 看到旧值，再调用 Delete，中间如果另一个 goroutine 已经写入新值，清理逻辑就可能把新值一起删掉。这个场景适合用 sync.Map.CompareAndDelete，让“当前值仍等于我看到的旧值”成为删除条件。

它的判断结果很直接：返回 true 表示按 key 找到相等的旧值并完成删除，返回 false 表示没有发生删除。本文只讨论这个条件删除方法，不把它扩展成 sync.Map 的全面选型。

先看普通 Delete 为什么有并发窗口

下面的写法把读取和删除拆成了两个独立动作。它能工作，但不能保证删除的仍是刚才读到的那一份值。

package main

import "sync"

func removeIfStale(m *sync.Map, key string) {
	// 先读到旧值；这次读取和后面的删除之间存在并发窗口。
	old, ok := m.Load(key)
	if !ok {
		return
	}
	_ = old

	// 另一个 goroutine 可能已经 Store 了新值，此时 Delete 会无条件删除当前值。
	m.Delete(key)
}

例如缓存清理者读到 token-v1，更新者随后写入 token-v2，清理者再执行 Delete，最终连新值也会消失。问题不是 Delete 本身错误，而是它没有携带“我删除的是哪一个旧值”的条件。

用 CompareAndDelete 绑定 key 和 old

CompareAndDelete(key, old) 会把 key 和 old 一起交给 sync.Map。只有当前映射值与 old 相等时，删除才会发生；因此它把原本的“读后无条件删”变成了“确认还是旧值才删”。

package main

import "sync"

func removeVersion(m *sync.Map, key, version string) bool {
	// old 是本次清理认可的版本，只有当前值仍等于它才允许删除。
	return m.CompareAndDelete(key, version)
}

func main() {
	var cache sync.Map
	cache.Store("profile:42", "v1")

	// 返回 true 表示 v1 仍是当前值，并且已经被条件删除。
	_ = removeVersion(&cache, "profile:42", "v1")

	// 若期间换成 v2，这里返回 false，v2 会被保留下来。
	cache.Store("profile:42", "v2")
	_ = removeVersion(&cache, "profile:42", "v1")
}

这里最值得记住的是返回值，而不是把它当成普通的“删除命令”。true 可以作为清理成功、缓存失效或后续通知的依据；false 则说明当前值已经变化、key 不存在，或条件没有命中，调用方应避免把它误报成删除成功。

处理不可比较旧值和不存在键

CompareAndDelete 需要比较 old，因此 old 必须是可比较类型。字符串、整数、指针和只含可比较字段的结构体可以直接使用；切片、map、函数等不可比较值不应作为 old。把它们装进 any 并不会改变这个限制，实际比较时仍可能触发 panic。

另一个容易忽略的边界是 key 不存在。即使 old 是 nil interface，当前没有这个 key 时仍返回 false，不会凭空产生一次删除。可以把四种结果按下面的方式理解：

把条件删除放进缓存清理路径

在工程代码里，建议把“旧值快照”设计成可比较的版本号、状态字符串或指针，而不是直接把一整份可变对象塞进 old。这样清理动作只关心版本是否仍然匹配，更新者写入新版本后，旧清理请求自然会返回 false。

package main

import "sync"

type Cache struct {
	items sync.Map // key -> 可比较的版本标识
}

func (c *Cache) RemoveVersion(key, expected string) bool {
	// 条件不满足时保留新版本，调用方可记录一次“已被更新”的结果。
	return c.items.CompareAndDelete(key, expected)
}

如果清理失败，通常不应立刻重试同一个 old。先重新读取当前版本，再决定是放弃、重算清理条件，还是让新的失效事件处理。若业务需要严格的多字段原子更新，也要重新评估数据结构；sync.Map 只适合它擅长的并发读写场景，不能替代所有带业务不变量的普通 map 加锁方案。

相关问题

CompareAndDelete 和 Delete 的核心区别是什么？

Delete 只按 key 无条件删除当前值；CompareAndDelete 还要求当前值等于 old，适合防止旧清理请求误删新写入。

返回 false 是不是说明发生了错误？

不一定。它可能表示 key 已不存在，也可能表示值已经变化。是否记录为错误，要看业务把“未命中清理条件”视为正常竞争还是异常状态。