stdout के लिए प्रिंटिंग अवरुद्ध goroutine चलाने के कारणों का कारण बनता है?

Question

मूर्खतापूर्ण मूल थ्रेडिंग अभ्यास के रूप में, मैं गोलांग में sleeping barber problem को लागू करने का प्रयास कर रहा हूं। चैनलों के साथ यह काफी आसान होना चाहिए, लेकिन मैं एक heisenbug में चला गया है। यही है, जब मैं इसका निदान करने की कोशिश करता हूं, तो समस्या गायब हो जाती है!

निम्नलिखित पर विचार करें। main() फ़ंक्शन shop चैनल पर पूर्णांक (या "ग्राहक") को धक्का देता है। barber() "ग्राहकों" बाल को काटने के लिए shop चैनल पढ़ता है। यदि मैं कथन customer() फ़ंक्शन में डालता हूं, तो प्रोग्राम अपेक्षित के रूप में चलता है। अन्यथा, barber() कभी भी किसी के बाल को काट नहीं देता है।

package main 

import "fmt" 

func customer(id int, shop chan<- int) { 
    // Enter shop if seats available, otherwise leave 
    // fmt.Println("Uncomment this line and the program works") 
    if len(shop) < cap(shop) { 
     shop <- id 
    } 
} 

func barber(shop <-chan int) { 
    // Cut hair of anyone who enters the shop 
    for { 
     fmt.Println("Barber cuts hair of customer", <-shop) 
    } 
} 

func main() { 
    shop := make(chan int, 5) // five seats available 
    go barber(shop) 
    for i := 0; ; i++ { 
     customer(i, shop) 
    } 
} 

कोई विचार क्या चल रहा है?

Answer 1

समस्या यह है कि गो का शेड्यूलर लागू किया गया है। वर्तमान goroutine केवल अन्य goroutines के लिए पैदा कर सकते हैं जब यह एक सिस्टम कॉल या एक अवरुद्ध चैनल ऑपरेशन करता है। fmt.Println एक सिस्टम कॉल करता है, जिससे गोरौटाइन को पैदा करने का मौका मिलता है। अन्यथा इसमें कोई नहीं है।

अभ्यास में यह अक्सर कोई फर्क नहीं पड़ता है, लेकिन इस तरह की छोटी समस्याओं के लिए कभी-कभी यह फसल हो सकती है।

इसके अलावा

, एक और अधिक मुहावरेदार, एक गैर अवरुद्ध एक चैनल पर भेज रहा है ऐसा करने का कम सुरम्य रास्ता: नाई की

func customer(id int, shop chan<- int) { 
    // Enter shop if seats available, otherwise leave 
    select { 
    case shop <- id: 
    default: 
    } 
} 

जिस तरह से आप कर रहे हैं, एक ग्राहक हो सकते हैं इंतज़ार कर बाहर जब तक आप वास्तव में भेजते हैं तब तक खरीदारी करें, len(shop) बदल सकता है।

Answer 2

क्या मुख्य हल की शुरुआत में runtime.GOMAXPROCS(2) जोड़ना है?