1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
|
package clock
import (
"hash/maphash"
"runtime"
"lindenii.org/go/lgo/intconv"
)
// maxShards bounds the shard count.
//
// Keep it relatively modest
// so the per-shard budget
// stays large enough to admit sizable values.
const maxShards = 16
// WeightFunc reports one entry's weight, used for eviction budgeting.
type WeightFunc[K comparable, V any] func(key K, value V) uint64
// Clock is a concurrent, weight-bounded cache
// with CLOCK eviction.
//
// Reads are lock-free;
// writes lock only the shard that owns the key.
//
// Labels: MT-Safe.
type Clock[K comparable, V any] struct {
shards []*shard[K, V]
seed maphash.Seed
mask uint64
weightFn WeightFunc[K, V]
}
// New returns a cache bounded to maxWeight total weight,
// weighing entries with weightFn.
//
// New panics if weightFn is nil.
func New[K comparable, V any](maxWeight uint64, weightFn WeightFunc[K, V]) *Clock[K, V] {
if weightFn == nil {
panic("internal/clock: nil weight function")
}
count, mask := shardLayout(maxWeight)
perShard := maxWeight / (mask + 1)
shards := make([]*shard[K, V], count)
for i := range shards {
shards[i] = newShard[K, V](perShard)
}
return &Clock[K, V]{
shards: shards,
seed: maphash.MakeSeed(),
mask: mask,
weightFn: weightFn,
}
}
// shardLayout picks a power-of-two shard count and its address mask.
//
// Tracks GOMAXPROCS, capped at maxShards,
// and is shrunk so the per-shard budget
// stays at least one while maxWeight is nonzero.
func shardLayout(maxWeight uint64) (int, uint64) {
count := 1
for count < runtime.GOMAXPROCS(0) && count < maxShards {
count *= 2
}
countU, err := intconv.IntToUint64(count)
if err != nil {
return 1, 0
}
for countU > maxWeight && countU > 1 {
count /= 2
countU /= 2
}
return count, countU - 1
}
// shardFor returns the shard that owns key.
func (clock *Clock[K, V]) shardFor(key K) *shard[K, V] {
return clock.shards[maphash.Comparable(clock.seed, key)&clock.mask]
}
|
