coopgo-platform
/
gorush
7
0
Fork 0
Code Issues Pull Requests Projects Releases 1 Wiki Activity

chore: rename once to startOnce 

Signed-off-by: Bo-Yi Wu <appleboy.tw@gmail.com>
This commit is contained in:
Bo-Yi Wu 2021-07-24 11:00:04 +08:00
parent 6db9768758
commit a210abd323
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
queue/nsq/nsq.go
View File

@ -21,7 +21,7 @@ type Option func(*Worker)
type Worker struct { type Worker struct {
q *nsq.Consumer q *nsq.Consumer
p *nsq.Producer p *nsq.Producer
once sync.Once startOnce sync.Once
maxInFlight int maxInFlight int
addr string addr string
topic string topic string
@ -116,7 +116,7 @@ func (s *Worker) BeforeRun() error {
// AfterRun run script after start worker // AfterRun run script after start worker
func (s *Worker) AfterRun() error { func (s *Worker) AfterRun() error {
s.once.Do(func() { s.startOnce.Do(func() {
time.Sleep(100 * time.Millisecond) time.Sleep(100 * time.Millisecond)
err := s.q.ConnectToNSQD(s.addr) err := s.q.ConnectToNSQD(s.addr)
if err != nil { if err != nil {