locker

locker/empty_locker.go

@@ -0,0 +1,15 @@
+package locker
+
+import "sync"
+
+var _ sync.Locker = &emptyLocker{}
+
+type emptyLocker struct{}
+
+func NewEmptyLocker() *emptyLocker {
+	return &emptyLocker{}
+}
+
+func (l *emptyLocker) Lock() {}
+
+func (l *emptyLocker) Unlock() {}

locker/locker.go

@@ -0,0 +1,21 @@
+package locker
+
+import "sync"
+
+var locks = make(map[string]sync.Locker)
+
+func Lock(name string) {
+	if l, ok := locks[name]; ok {
+		l.Lock()
+	}
+
+	new := &sync.Mutex{}
+	locks[name] = new
+	new.Lock()
+}
+
+func Unlock(name string) {
+	if l, ok := locks[name]; ok {
+		l.Unlock()
+	}
+}