👔 up: update some for EnableLock options

README.md

@@ -122,7 +122,7 @@ will trigger the execution of the `dbListener1` listener.
 - `**` matches any number of characters and can only be used at the beginning or end
 
 ```go
-em := event.NewManager("test", event.UsePathMode, event.EnableLock)
+em := event.NewManager("test", event.UsePathMode)
 ```
 
 ## Async fire events

README.zh-CN.md

@@ -121,7 +121,7 @@ func doUpdate() {
 - `**` 则匹配任意多个字符,并且只能用于开头或结尾
 
 ```go
-em := event.NewManager("test", event.UsePathMode, event.EnableLock)
+em := event.NewManager("test", event.UsePathMode)
 ```
 
 ## 异步消费事件

event.go

@@ -44,7 +44,7 @@ type ManagerFace interface {
 
 // Options event manager config options
 type Options struct {
-	// EnableLock enable lock on fire event.
+	// EnableLock enable lock on fire event. default is TRUE.
 	EnableLock bool
 	// ChannelSize for fire events by goroutine
 	ChannelSize int
@@ -62,8 +62,10 @@ func UsePathMode(o *Options) {
 }
 
 // EnableLock enable lock on fire event.
-func EnableLock(o *Options) {
-	o.EnableLock = true
+func EnableLock(enable bool) OptionFn {
+	return func(o *Options) {
+		o.EnableLock = enable
+	}
 }
 
 // Event interface

manager.go

@@ -56,6 +56,7 @@ func NewManager(name string, fns ...OptionFn) *Manager {
 		listenedNames: make(map[string]int),
 	}
 
+	em.EnableLock = true
 	// for async fire by goroutine
 	em.ConsumerNum = defaultConsumerNum
 	em.ChannelSize = defaultChannelSize

manager_test.go

@@ -224,7 +224,7 @@ func TestManager_Fire_WithWildcard(t *testing.T) {
 
 func TestManager_Fire_usePathMode(t *testing.T) {
 	buf := new(bytes.Buffer)
-	em := event.NewManager("test", event.UsePathMode, event.EnableLock)
+	em := event.NewManager("test", event.UsePathMode, event.EnableLock(true))
 
 	em.Listen("db.user.*", event.ListenerFunc(func(e event.Event) error {
 		_, _ = buf.WriteString("db.user.*|")
@@ -302,7 +302,7 @@ func TestManager_Fire_usePathMode(t *testing.T) {
 }
 
 func TestManager_Fire_AllNode(t *testing.T) {
-	em := event.NewManager("test", event.UsePathMode, event.EnableLock)
+	em := event.NewManager("test", event.UsePathMode, event.EnableLock(false))
 
 	buf := new(bytes.Buffer)
 	em.Listen("**.add", event.ListenerFunc(func(e event.Event) error {
@@ -318,7 +318,7 @@ func TestManager_Fire_AllNode(t *testing.T) {
 }
 
 func TestManager_FireC(t *testing.T) {
-	em := event.NewManager("test", event.UsePathMode, event.EnableLock)
+	em := event.NewManager("test", event.UsePathMode, event.EnableLock(true))
 	defer func(em *event.Manager) {
 		_ = em.Close()
 	}(em)
@@ -361,7 +361,7 @@ func TestManager_FireC(t *testing.T) {
 }
 
 func TestManager_Wait(t *testing.T) {
-	em := event.NewManager("test", event.UsePathMode, event.EnableLock)
+	em := event.NewManager("test", event.UsePathMode)
 
 	buf := new(bytes.Buffer)
 	em.Listen("db.user.*", event.ListenerFunc(func(e event.Event) error {