scheduler.go RawHistoryFolder

1package favicon
2
3import (
4	"context"
5	"sync"
6
7	"github.com/bnema/dumber/internal/domain/favicon"
8)
9
10type RefreshScheduler struct {
11	mu      sync.Mutex
12	running map[favicon.Key]struct{}
13}
14
15func NewRefreshScheduler() *RefreshScheduler {
16	return &RefreshScheduler{running: make(map[favicon.Key]struct{})}
17}
18
19func (s *RefreshScheduler) Schedule(ctx context.Context, key favicon.Key, work func(context.Context)) bool {
20	if s == nil || key == "" || work == nil {
21		return false
22	}
23	s.mu.Lock()
24	if _, ok := s.running[key]; ok {
25		s.mu.Unlock()
26		return false
27	}
28	s.running[key] = struct{}{}
29	s.mu.Unlock()
30
31	go func() {
32		defer func() {
33			s.mu.Lock()
34			delete(s.running, key)
35			s.mu.Unlock()
36		}()
37		work(ctx)
38	}()
39	return true
40}