sweeper.go

type evictor interface {
	Run(*shard)
	Stop()
}

func newSweeper(interval time.Duration) evictor {
	return &sweeper{
		interval: interval,
		stopC:    make(chan bool),
	}
}

type sweeper struct {
	interval time.Duration
	stopC    chan bool
}

func (s *sweeper) Run(c *shard) {
	<-time.After(startupDelay())
	ticker := time.NewTicker(s.interval)
	for {
		select {
		case <-ticker.C:
			c.Evict()
		case <-s.stopC:
			ticker.Stop()
			return
		}
	}
}

func (s *sweeper) Stop() {
	s.stopC <- true
}


func newShardWithSweeper(sweepTime time.Duration) *shard {
	nc := &shard{
		data: make(map[string]item),
	}
	if sweepTime > 0 {
		runSweeper(nc, sweepTime)
		runtime.SetFinalizer(nc, stopSweeper)
	}
	return nc
}