Ticker Pool

tickpool.go

package tickpool

import (
	"sync"
	"time"
)

func init() {
	mu = &sync.Mutex{}
	pool = &sync.Pool{
		New: func() interface{} {
			return &time.Ticker{}
		},
	}
}

var (
	mu   *sync.Mutex
	pool *sync.Pool
)

func Get(interval time.Duration) (ticker *time.Ticker) {
	mu.Lock()
	defer mu.Unlock()

	ticker = pool.Get().(*time.Ticker)

	if ticker.C == nil {
		ticker = time.NewTicker(interval)
	} else {
		ticker.Reset(interval)
	}

	return ticker
}

func Put(ticker *time.Ticker) {
	mu.Lock()
	defer mu.Unlock()

	ticker.Stop()
	pool.Put(ticker)
}