/
githubmirror
/
gogs
Обзор
Документация
Войти
/
githubmirror
/
gogs
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
main
internal/sync/unique_queue.go
66 строк
1 KB
Copilot
Replace github.com/unknwon/com with stdlib and internal helpers (#8148)
06 фев 2026, 06:08
Не верифицирован
06 фев 2026, 06:08
bf17cc6
Код
Авторство
О чём код?
package sync import ( "fmt" ) // UniqueQueue is a queue which guarantees only one instance of same // identity is in the line. Instances with same identity will be // discarded if there is already one in the line. // // This queue is particularly useful for preventing duplicated task // of same purpose. type UniqueQueue struct { table *StatusTable queue chan string } // NewUniqueQueue initializes and returns a new UniqueQueue object. func NewUniqueQueue(queueLength int) *UniqueQueue { if queueLength <= 0 { queueLength = 100 } return &UniqueQueue{ table: NewStatusTable(), queue: make(chan string, queueLength), } } // Queue returns channel of queue for retrieving instances. func (q *UniqueQueue) Queue() <-chan string { return q.queue } // Exist returns true if there is an instance with given identity // exists in the queue. func (q *UniqueQueue) Exist(id any) bool { return q.table.IsRunning(fmt.Sprintf("%v", id)) } // AddFunc adds new instance to the queue with a custom runnable function, // the queue is blocked until the function exits. func (q *UniqueQueue) AddFunc(id any, fn func()) { if q.Exist(id) { return } idStr := fmt.Sprintf("%v", id) q.table.Lock() q.table.pool[idStr] = true if fn != nil { fn() } q.table.Unlock() q.queue <- idStr } // Add adds new instance to the queue. func (q *UniqueQueue) Add(id any) { q.AddFunc(id, nil) } // Remove removes instance from the queue. func (q *UniqueQueue) Remove(id any) { q.table.Stop(fmt.Sprintf("%v", id)) }