सक्रिय goroutines की संख्या को गिनती/प्रदर्शित करें

Question

मेरे पास एक कतार और एक फ़ंक्शन है जो दोनों को हटाने और enqueueing करता है। मैं यह सुनिश्चित करना चाहता हूं कि जब तक सूची में कुछ न हो, तब तक सही मात्रा में goroutines कतार पर काम करते हैं।

इस कोड मैं का उपयोग कर रहा है, लेकिन अगर वहाँ वर्तमान में सक्रिय goroutines

Link to playground

var element int 

func deen(queue chan int) { 

    element := <-queue 
    fmt.Println("element is ", element) 
    if element%2 == 0 { 
     fmt.Println("new element is ", element) 
     queue <- (element*100 + 11) 
     queue <- (element*100 + 33) 
    } 
} 

func main() { 
    queue := make(chan int, 10) 
    queue <- 1 
    queue <- 2 
    queue <- 3 
    queue <- 0 
    for len(queue) != 0 { 
     for i := 0; i < 2; i++ { 
      go deen(queue) 
     } 
    } 
    fmt.Scanln() 
    fmt.Println("list is has len", len(queue)) //this must be 0 

}  

Answer 1

वहाँ runtime.NumGoroutine है, लेकिन आप यह गलत तक पहुंचने वाले हैं की राशि मुद्रण का एक तरीका है मैं सोच रहा था ।

1. आपके लूप goroutines spawning रखेंगे।
2. यह लूप के कारण अनावश्यक रूप से सीपीयू चक्र जला देगा।

एक दृष्टिकोण एक sync.WaitGroup का उपयोग करना है।

func deen(wg *sync.WaitGroup, queue chan int) { 
    for element := range queue { 
     wg.Done() 
     fmt.Println("element is ", element) 
     if element%2 == 0 { 
      fmt.Println("new element is ", element) 
      wg.Add(2) 
      queue <- (element*100 + 11) 
      queue <- (element*100 + 33) 
     } 
    } 
} 

func main() { 
    var wg sync.WaitGroup 
    queue := make(chan int, 10) 
    queue <- 1 
    queue <- 2 
    queue <- 3 
    queue <- 0 
    for i := 0; i < 4; i++ { 
     wg.Add(1) 
     go deen(&wg, queue) 
    } 
    wg.Wait() 
    close(queue) 
    fmt.Println("list is has len", len(queue)) //this must be 0 
} 

playground