optimize pubsub.Publish function

Signed-off-by: Shijiang Wei <mountkin@gmail.com>
SerhatG · Feb 15, 2016 · 1e0f1ec · 1e0f1ec
1 parent b1594c5
commit 1e0f1ec
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/pkg/pubsub/publisher.go b/pkg/pubsub/publisher.go
@@ -64,10 +64,14 @@ func (p *Publisher) Evict(sub chan interface{}) {
 // Publish sends the data in v to all subscribers currently registered with the publisher.
 func (p *Publisher) Publish(v interface{}) {
 	p.m.RLock()
+	if len(p.subscribers) == 0 {
+		p.m.RUnlock()
+		return
+	}
+
 	wg := new(sync.WaitGroup)
 	for sub, topic := range p.subscribers {
 		wg.Add(1)
-
 		go p.sendTopic(sub, topic, v, wg)
 	}
 	wg.Wait()