aboutsummaryrefslogtreecommitdiff
path: root/modules/sync/status_pool.go
diff options
context:
space:
mode:
authorUnknwon <u@gogs.io>2016-08-14 17:44:20 -0700
committerUnknwon <u@gogs.io>2016-08-14 23:52:24 -0700
commit660e7a178a9d72a03d13f704aca61726b4672232 (patch)
tree0668bcf438c586df14c204625b3829f5a4647267 /modules/sync/status_pool.go
parent15845cb28763c1542556ad61d2aa9735541dbf45 (diff)
modules/sync: move sync objects to independent module
Diffstat (limited to 'modules/sync/status_pool.go')
-rw-r--r--modules/sync/status_pool.go49
1 files changed, 49 insertions, 0 deletions
diff --git a/modules/sync/status_pool.go b/modules/sync/status_pool.go
new file mode 100644
index 00000000..f6a7f949
--- /dev/null
+++ b/modules/sync/status_pool.go
@@ -0,0 +1,49 @@
+// 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"
+)
+
+// StatusTable is a table maintains true/false values.
+//
+// This table is particularly useful for un/marking and checking values
+// in different goroutines.
+type StatusTable struct {
+ lock sync.RWMutex
+ pool map[string]bool
+}
+
+// NewStatusTable initializes and returns a new StatusTable object.
+func NewStatusTable() *StatusTable {
+ return &StatusTable{
+ pool: make(map[string]bool),
+ }
+}
+
+// Start sets value of given name to true in the pool.
+func (p *StatusTable) Start(name string) {
+ p.lock.Lock()
+ defer p.lock.Unlock()
+
+ p.pool[name] = true
+}
+
+// Stop sets value of given name to false in the pool.
+func (p *StatusTable) Stop(name string) {
+ p.lock.Lock()
+ defer p.lock.Unlock()
+
+ p.pool[name] = false
+}
+
+// IsRunning checks if value of given name is set to true in the pool.
+func (p *StatusTable) IsRunning(name string) bool {
+ p.lock.RLock()
+ defer p.lock.RUnlock()
+
+ return p.pool[name]
+}