Browse Source

Merge remote-tracking branch 'origin/develop' into develop

develop
娄文智 1 year ago
parent
commit
48745148d0
1 changed files with 4 additions and 4 deletions
  1. +4
    -4
      models/channel/ReleaseTask.go

+ 4
- 4
models/channel/ReleaseTask.go View File

@ -6,7 +6,7 @@ import (
) )
type TaskChannel struct { type TaskChannel struct {
name string
name string
c chan interface{} c chan interface{}
closed bool closed bool
mutex sync.Mutex mutex sync.Mutex
@ -14,7 +14,7 @@ type TaskChannel struct {
func NewTaskChannel(name string) *TaskChannel { func NewTaskChannel(name string) *TaskChannel {
return &TaskChannel{ return &TaskChannel{
c: make(chan interface{}, 100),
c: make(chan interface{}, 200),
name: name, name: name,
} }
} }
@ -54,7 +54,7 @@ func (c *TaskChannel) Read() (data interface{}, ok bool, err error) {
return return
} }
c.mutex.Unlock() c.mutex.Unlock()
data, ok = <- c.c
data, ok = <-c.c
return return
} }
@ -68,4 +68,4 @@ func (c *TaskChannel) ResetChannel() (err error) {
c.closed = false c.closed = false
c.c = make(chan interface{}, 50) c.c = make(chan interface{}, 50)
return return
}
}

Loading…
Cancel
Save