concurrency

Documentation

Index

• Variables
• func CleanUrlMutexes(now time.Time)
• func GetOrCreateUrlMutex(url string) *mutexWithTime

Variables

var UrlMutexes = make(map[string]*mutexWithTime)

mutexes to queue mass simultaneous requests of same url

var UrlMutexesLock sync.Mutex

Functions

func CleanUrlMutexes

func CleanUrlMutexes(now time.Time)

cleans up the UrlMutexes map by removing mutexes that have not been accessed in the last minute.

func GetOrCreateUrlMutex

func GetOrCreateUrlMutex(url string) *mutexWithTime

creates or retrieves a mutex for a given URL from the urlMutexes map