// Γράψτε υλοποιήσεις cache με TTL (time to live) για τη δομή User. // Μπορείτε να χρησιμοποιήσετε το User.ID ως κλειδί // Θέλουμε να είναι ασφαλές για νήματα // Δεν θέλουμε να λαμβάνουμε εγγραφές με ληγμένο TTL κατά την ανάγνωση // Θέλουμε οι εγγραφές με ληγμένο TTL να διαγράφονται και να μην αποθηκεύονται // API get/set/del
sobes.tech AI
Απάντηση από AI
go package main
import ( "sync" "time" )
type User struct { ID string // άλλα πεδία }
type cacheItem struct { user User expiresAt time.Time }
type UserCache struct { mu sync.RWMutex items map[string]cacheItem }
func NewUserCache() *UserCache { c := &UserCache{ items: make(map[string]cacheItem), } // Ξεκινάμε μια goroutine για την περιοδική καθαριότητα των λογαριασμών που έχουν λήξει go func() { for { time.Sleep(time.Minute) // διάστημα καθαρισμού c.cleanup() } }() return c }
func (c *UserCache) Set(user User, ttl time.Duration) { c.mu.Lock() defer c.mu.Unlock() c.items[user.ID] = cacheItem{ user: user, expiresAt: time.Now().Add(ttl), } }
func (c *UserCache) Get(id string) (User, bool) { c.mu.RLock() item, found := c.items[id] c.mu.RUnlock() if !found { return User{}, false } if time.Now().After(item.expiresAt) { // λογαριασμός λήξει, διαγραφή c.mu.Lock() delete(c.items, id) c.mu.Unlock() return User{}, false } return item.user, true }
func (c *UserCache) Del(id string) { c.mu.Lock() defer c.mu.Unlock() delete(c.items, id) }
func (c *UserCache) cleanup() { c.mu.Lock() defer c.mu.Unlock() now := time.Now() for id, item := range c.items { if now.After(item.expiresAt) { delete(c.items, id) } } }
// Παράδειγμα χρήσης // func main() { // cache := NewUserCache() // user := User{ID: "123"} // cache.Set(user, 5*time.Minute) // u, ok := cache.Get("123") // if ok { // fmt.Println("Βρέθηκε χρήστης:", u) // } // }