diff --git a/common/utils/concurrent-swiss-map/concurrent_swiss_map.go b/common/utils/concurrent-swiss-map/concurrent_swiss_map.go index f16767894..ef64ac58a 100644 --- a/common/utils/concurrent-swiss-map/concurrent_swiss_map.go +++ b/common/utils/concurrent-swiss-map/concurrent_swiss_map.go @@ -16,7 +16,6 @@ type CsMap[K comparable, V any] struct { shards []shard[K, V] shardCount uint64 size uint64 - //pool *ants.Pool } type HashShardPair[K comparable, V any] struct { @@ -47,7 +46,7 @@ func New[K comparable, V any](options ...OptFunc[K, V]) *CsMap[K, V] { for i := 0; i < int(m.shardCount); i++ { m.shards[i] = shard[K, V]{items: swiss.NewMap[K, V](uint32((m.size / m.shardCount) + 1)), RWMutex: &sync.RWMutex{}} } - //m.pool, _ = ants.NewPool(-1) + return &m }