aboutsummaryrefslogtreecommitdiff
path: root/pkg/sync/exclusive_pool.go
diff options
context:
space:
mode:
authorUnknwon <u@gogs.io>2019-10-24 01:51:46 -0700
committerGitHub <noreply@github.com>2019-10-24 01:51:46 -0700
commit01c8df01ec0608f1f25b2f1444adabb98fa5ee8a (patch)
treef8a7e5dd8d2a8c51e1ce2cabb9d33571a93314dd /pkg/sync/exclusive_pool.go
parent613139e7bef81d3573e7988a47eb6765f3de347a (diff)
internal: move packages under this directory (#5836)
* Rename pkg -> internal * Rename routes -> route * Move route -> internal/route * Rename models -> db * Move db -> internal/db * Fix route2 -> route * Move cmd -> internal/cmd * Bump version
Diffstat (limited to 'pkg/sync/exclusive_pool.go')
-rw-r--r--pkg/sync/exclusive_pool.go70
1 files changed, 0 insertions, 70 deletions
diff --git a/pkg/sync/exclusive_pool.go b/pkg/sync/exclusive_pool.go
deleted file mode 100644
index 744cc7c9..00000000
--- a/pkg/sync/exclusive_pool.go
+++ /dev/null
@@ -1,70 +0,0 @@
-// Copyright 2016 The Gogs Authors. All rights reserved.
-// Use of this source code is governed by a MIT-style
-// license that can be found in the LICENSE file.
-
-package sync
-
-import (
- "sync"
-)
-
-// ExclusivePool is a pool of non-identical instances
-// that only one instance with same identity is in the pool at a time.
-// In other words, only instances with different identities can be in
-// the pool the same time. If another instance with same identity tries
-// to get into the pool, it hangs until previous instance left the pool.
-//
-// This pool is particularly useful for performing tasks on same resource
-// on the file system in different goroutines.
-type ExclusivePool struct {
- lock sync.Mutex
-
- // pool maintains locks for each instance in the pool.
- pool map[string]*sync.Mutex
-
- // count maintains the number of times an instance with same identity checks in
- // to the pool, and should be reduced to 0 (removed from map) by checking out
- // with same number of times.
- // The purpose of count is to delete lock when count down to 0 and recycle memory
- // from map object.
- count map[string]int
-}
-
-// NewExclusivePool initializes and returns a new ExclusivePool object.
-func NewExclusivePool() *ExclusivePool {
- return &ExclusivePool{
- pool: make(map[string]*sync.Mutex),
- count: make(map[string]int),
- }
-}
-
-// CheckIn checks in an instance to the pool and hangs while instance
-// with same indentity is using the lock.
-func (p *ExclusivePool) CheckIn(identity string) {
- p.lock.Lock()
-
- lock, has := p.pool[identity]
- if !has {
- lock = &sync.Mutex{}
- p.pool[identity] = lock
- }
- p.count[identity]++
-
- p.lock.Unlock()
- lock.Lock()
-}
-
-// CheckOut checks out an instance from the pool and releases the lock
-// to let other instances with same identity to grab the lock.
-func (p *ExclusivePool) CheckOut(identity string) {
- p.lock.Lock()
- defer p.lock.Unlock()
-
- p.pool[identity].Unlock()
- if p.count[identity] == 1 {
- delete(p.pool, identity)
- delete(p.count, identity)
- } else {
- p.count[identity]--
- }
-}