[ā§Ē.ā§¨] āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ (Channels)
āĻāĻ āĻĒāĻ°ā§āĻ¯āĻžā§ā§ āĻāĻŽāĻ°āĻž Go āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻ¨āĻŋā§ā§ āĻāĻĨāĻž āĻŦāĻ˛āĻŦā§āĨ¤ āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻ¸āĻŽā§āĻĒāĻ°ā§āĻā§ āĻāĻžāĻ¨āĻ¤ā§ āĻšāĻ˛ā§ āĻāĻā§ āĻāĻŽāĻžāĻĻā§āĻ° āĻāĻžāĻ¨āĻ¤ā§ āĻšāĻŦā§ āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻā§, āĻā§āĻāĻžāĻŦā§ āĻāĻžāĻ āĻāĻ°ā§ āĻāĻŦāĻ āĻā§āĻ¨āĻ āĻŦāĻž āĻāĻŽāĻ°āĻž āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻŦā§āĻ¯āĻŦāĻšāĻžāĻ° āĻāĻ°āĻŦā§āĨ¤ āĻŦāĻŋāĻāĻŋāĻ¨ā§āĻ¨ āĻāĻĻāĻžāĻšāĻ°āĻŖā§āĻ° āĻŽāĻžāĻ§ā§āĻ¯āĻŽā§ āĻŦāĻŋāĻˇā§āĻā§āĻ˛ā§ āĻĻā§āĻāĻž āĻ¯āĻžāĻāĨ¤
[ā§Ē.ā§¨.ā§§] āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻā§ ?
Go āĻ¤ā§ āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻšāĻ˛ āĻĒāĻžāĻāĻĒ āĻ˛āĻžāĻāĻ¨ā§āĻ° āĻŽāĻ¤ā§ āĻ¯āĻžāĻā§ āĻŦā§āĻ¯āĻŦāĻšāĻžāĻ° āĻāĻ°ā§ āĻāĻ āĻŦāĻž āĻāĻāĻžāĻ§āĻŋāĻ āĻā§-āĻ°ā§āĻāĻŋāĻ¨ āĻ¨āĻŋāĻā§āĻĻā§āĻ° āĻŽāĻ§ā§āĻ¯ā§ āĻ¯ā§āĻāĻžāĻ¯ā§āĻ āĻāĻ°ā§āĨ¤ āĻŦāĻžāĻ¸ā§āĻ¤āĻŦā§ āĻ¯āĻĻāĻŋ āĻāĻŽāĻ°āĻž āĻĒāĻžāĻāĻĒ āĻ˛āĻžāĻāĻ¨ā§āĻ° āĻĻāĻŋāĻā§ āĻ¤āĻžāĻāĻžāĻ āĻ¤āĻžāĻšāĻ˛ā§ āĻĻā§āĻāĻ¤ā§ āĻĒāĻžāĻŦā§ āĻĒāĻžāĻāĻĒ āĻ˛āĻžāĻāĻ¨ā§āĻ° āĻŽāĻžāĻ§ā§āĻ¯āĻŽā§ āĻĒāĻžāĻ¨āĻŋ āĻāĻ āĻĒā§āĻ°āĻžāĻ¨ā§āĻ¤ āĻĨā§āĻā§ āĻ āĻ¨ā§āĻ¯ āĻĒā§āĻ°āĻžāĻ¨ā§āĻ¤ā§ āĻĒā§āĻ°āĻŦāĻžāĻšāĻŋāĻ¤ āĻšāĻā§āĻā§, āĻāĻāĻāĻāĻžāĻŦā§ āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻŦā§āĻ¯āĻŦāĻšāĻžāĻ° āĻāĻ°ā§ āĻāĻ āĻĒā§āĻ°āĻžāĻ¨ā§āĻ¤ āĻĨā§āĻā§ āĻĄāĻžāĻāĻž āĻĒāĻžāĻ āĻžāĻ¨ā§ āĻšā§ āĻāĻŦāĻ āĻ āĻ¨ā§āĻ¯ āĻĒā§āĻ°āĻžāĻ¨ā§āĻ¤ āĻĨā§āĻā§ āĻĄāĻžāĻāĻž āĻā§āĻ°āĻšāĻŖ āĻāĻ°āĻž āĻšā§āĨ¤Â Go āĻ¤ā§ āĻĻā§āĻ āĻ§āĻ°āĻ¨ā§āĻ° āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻ°ā§ā§āĻā§, buffered āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻāĻŦāĻ unbuffered āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛āĨ¤ āĻĒāĻ°āĻŦāĻ°ā§āĻ¤ā§āĻ¤ā§ āĻāĻŽāĻ°āĻž buffered āĻāĻŦāĻ unbuffered āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻ¨āĻŋā§ā§ āĻāĻ˛ā§āĻāĻ¨āĻž āĻāĻ°āĻŦā§āĨ¤
[ā§Ē.ā§¨.ā§¨] āĻā§āĻ¨ āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻŦā§āĻ¯āĻŦāĻšāĻžāĻ° āĻāĻ°āĻŦā§ ?
- āĻāĻāĻžāĻ§āĻŋāĻ āĻā§-āĻ°ā§āĻāĻŋāĻ¨ā§āĻ° āĻŽāĻ§ā§āĻ¯ā§ āĻ¯ā§āĻāĻžāĻ¯ā§āĻ āĻ¸āĻšāĻ āĻāĻ°āĻžāĻ° āĻāĻ¨ā§āĻ¯ āĻ Â āĻĄāĻžāĻāĻž āĻā§āĻ°āĻžāĻ¨ā§āĻ¸āĻĢāĻžāĻ°ā§āĻ° āĻāĻ¨ā§āĻ¯ āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻŦā§āĻ¯āĻŦāĻšāĻžāĻ° āĻāĻ°āĻž āĻšā§āĨ¤
- Go āĻ¤ā§ āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ā§āĻ° āĻŦā§āĻ¯āĻŦāĻšāĻžāĻ° āĻ ā§āĻ¯āĻžāĻ¸āĻŋāĻā§āĻā§āĻ°ā§āĻ¨āĻžāĻ¸ āĻĒā§āĻ°ā§āĻā§āĻ°āĻžāĻŽāĻŋāĻāĻā§ āĻ¸āĻšāĻ āĻāĻ°ā§ āĻ¤ā§āĻ˛ā§āĨ¤
- Go āĻ¤ā§ āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ā§āĻ° āĻŦā§āĻ¯āĻŦāĻšāĻžāĻ° āĻāĻāĻžāĻ§āĻŋāĻ āĻĢāĻžāĻāĻļāĻ¨ āĻŦāĻž āĻŽā§āĻĨāĻĄāĻā§ āĻāĻāĻāĻ¸āĻžāĻĨā§ āĻ°āĻžāĻ¨ āĻāĻ°āĻ¤ā§ āĻ¸āĻžāĻšāĻžāĻ¯ā§āĻ¯ āĻāĻ°ā§āĨ¤
[ā§Ē.ā§¨.ā§Š] āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻĄāĻŋāĻā§āĻ˛ā§ā§āĻžāĻ°
āĻĒā§āĻ°āĻ¤ā§āĻ¯ā§āĻāĻāĻŋ āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻāĻ° āĻ¸āĻžāĻĨā§ āĻāĻāĻāĻŋ āĻ¨āĻŋāĻ°ā§āĻĻāĻŋāĻˇā§āĻ āĻāĻžāĻāĻĒ āĻāĻ¸ā§āĻ¸āĻŋā§ā§āĻā§āĻĄ āĻĨāĻžāĻā§āĨ¤ āĻāĻāĻāĻŋ āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ā§ āĻļā§āĻ§ā§ āĻāĻāĻ āĻāĻžāĻāĻĒā§āĻ° āĻĄāĻžāĻāĻž āĻā§āĻ°āĻžāĻ¨ā§āĻ¸āĻĒā§āĻ°ā§āĻ āĻāĻ°āĻ¤ā§ āĻĒāĻžāĻ°ā§ āĻ āĻ¨ā§āĻ¯ āĻāĻžāĻāĻĒā§āĻ° āĻĄāĻžāĻāĻžāĻā§ āĻāĻ˛āĻžāĻ āĻāĻ°ā§ āĻ¨āĻžāĨ¤ āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻ āĻā§āĻ¯āĻžāĻ˛ā§ āĻ°āĻŋāĻ¸āĻŋāĻ āĻāĻŦāĻ āĻ¸ā§āĻ¨ā§āĻĄā§āĻ° āĻāĻ¨ā§āĻ¯ <- āĻ āĻĒāĻžāĻ°ā§āĻāĻ° āĻŦā§āĻ¯āĻŦāĻšāĻžāĻ° āĻāĻ°āĻž āĻšā§āĨ¤
āĻ¸āĻŋāĻ¨āĻā§āĻ¯āĻžāĻā§āĻ¸ :
myChannel := make(chan datatype)
āĻ¯āĻĻāĻŋ āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ā§ āĻā§āĻ¨ āĻŽāĻžāĻ¨ āĻ¨āĻž āĻĨāĻžāĻā§ āĻ¤āĻžāĻšāĻ˛ā§ āĻ¸ā§āĻ āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛āĻā§ nil āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻŦāĻ˛ā§āĨ¤ nil āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻā§āĻ¨ āĻāĻžāĻā§ āĻŦā§āĻ¯āĻŦāĻšāĻžāĻ° āĻāĻ°āĻž āĻšā§ āĻ¨āĻžāĨ¤ āĻ¤āĻžāĻ āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛āĻā§Â maps āĻāĻŦāĻ āĻ¸ā§āĻ˛āĻžāĻāĻ¸ āĻāĻ° āĻŽāĻ¤ make āĻŦā§āĻ¯āĻŦāĻšāĻžāĻ° āĻāĻ°ā§ āĻĄāĻŋāĻĢāĻžāĻāĻ¨ āĻāĻ°āĻž āĻšā§āĨ¤
āĻāĻāĻāĻŋ āĻāĻĻāĻžāĻšāĻ°āĻŖ āĻĻā§āĻāĻž āĻ¯āĻžāĻ :
package main
import "fmt"
func main() {
var ch chan int
if ch == nil {
fmt.Println("channel ch is nil, Going to define it")
ch = make(chan int)
fmt.Printf("Type of a is %T", ch)
}
}
Output :
channel ch is nil, Going to define it
Type of ch is chan int
āĻāĻĒāĻ°ā§āĻ° āĻāĻĻāĻžāĻšāĻ°āĻŖā§, āĻāĻŽāĻ°āĻž āĻāĻāĻāĻŋ nil āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ ch āĻĄāĻŋāĻĢāĻžāĻāĻ¨ āĻāĻ°ā§āĻāĻŋ, āĻ¤āĻžāĻ°āĻĒāĻ° āĻā§āĻ āĻāĻ°ā§āĻāĻŋ ch nil āĻāĻŋāĻ¨āĻžāĨ¤ āĻ¯ā§āĻšā§āĻ¤ā§ ch āĻāĻāĻāĻž nil āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻ¤āĻžāĻ if āĻāĻ° āĻāĻŋāĻ¤āĻ°ā§ āĻĒā§āĻ°āĻŦā§āĻļ āĻāĻ°ā§āĻā§ âchannel ch is nil, Going to define itâ āĻĒā§āĻ°āĻŋāĻ¨ā§āĻ āĻšā§ā§āĻā§, āĻ¤āĻžāĻ°āĻĒāĻ° make āĻĻāĻŋā§ā§ āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ ch āĻā§ āĻĄāĻŋāĻĢāĻžāĻāĻ¨ āĻāĻ°āĻž āĻšā§ā§āĻā§ āĻāĻŦāĻ āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ ch āĻāĻ° āĻāĻžāĻāĻĒ āĻĒā§āĻ°āĻŋāĻ¨ā§āĻ āĻāĻ°āĻž āĻšā§ā§āĻā§āĨ¤Â
 āĻ¨āĻŋāĻŽā§āĻ¨ā§āĻ° āĻ¸āĻŋāĻ¨āĻā§āĻ¯āĻžāĻā§āĻ¸ā§āĻ° āĻŽāĻžāĻ§ā§āĻ¯āĻŽā§ āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ā§ āĻĄāĻžāĻāĻž āĻ¸ā§āĻ¨ā§āĻĄ āĻāĻŦāĻ āĻ°āĻŋāĻ¸āĻŋāĻ āĻšā§ā§ āĻĨāĻžāĻā§ :Â
ch <- data // write or send to channel a
data := <- ch // read or receive from channel a
āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻ āĻĄāĻžāĻāĻž āĻ¸ā§āĻ¨ā§āĻĄ āĻāĻŦāĻ āĻ°āĻŋāĻ¸āĻŋāĻ āĻŦāĻžāĻ āĻĄāĻŋāĻĢāĻ˛ā§āĻ āĻŦā§āĻ˛āĻāĻŋāĻ āĻšā§ā§ āĻĨāĻžāĻā§āĨ¤ āĻ āĻ°ā§āĻĨāĻžā§ āĻ¯āĻāĻ¨ āĻĄāĻžāĻāĻž āĻ¸ā§āĻ¨ā§āĻĄ āĻāĻ°āĻž āĻšā§ āĻā§-āĻ°ā§āĻāĻŋāĻ¨ āĻ¸ā§āĻāĻž āĻ°āĻŋāĻ¸āĻŋāĻ āĻāĻ°āĻžāĻ° āĻāĻ āĻĒāĻ°ā§āĻ¯āĻ¨ā§āĻ¤ āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻāĻŋ āĻŦā§āĻ˛āĻ āĻĨāĻžāĻā§āĨ¤ āĻāĻāĻ āĻāĻžāĻŦā§ āĻĄāĻžāĻāĻž āĻ°āĻŋāĻ¸āĻŋāĻ āĻ¨āĻž āĻšāĻā§āĻž āĻĒāĻ°ā§āĻ¯āĻ¨ā§āĻ¤ āĻĄāĻžāĻāĻž āĻ¸ā§āĻ¨ā§āĻĄ āĻŦāĻ¨ā§āĻ§ āĻĨāĻžāĻā§ āĻ āĻ°ā§āĻĨāĻžā§Â āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻŦā§āĻ˛āĻ āĻĨāĻžāĻā§āĨ¤ āĻ āĻāĻ¨ā§āĻ¯āĻ āĻŦāĻ˛āĻž āĻšā§ āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻŦāĻžāĻ āĻĄāĻŋāĻĢāĻ˛ā§āĻ āĻŦā§āĻ˛āĻāĻŋāĻāĨ¤
āĻāĻāĻ¨ āĻāĻŋāĻā§ āĻāĻĻāĻžāĻšāĻ°āĻŖā§āĻ° āĻŽāĻžāĻ§ā§āĻ¯āĻŽā§ āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻŦā§āĻ¯āĻŦāĻšāĻžāĻ° āĻāĻ°ā§ āĻā§-āĻ°ā§āĻāĻŋāĻ¨ āĻāĻ° āĻāĻŽāĻŋāĻāĻ¨āĻŋāĻā§āĻļāĻ¨ āĻŦā§āĻāĻžāĻ° āĻā§āĻˇā§āĻāĻž āĻāĻ°āĻŋāĨ¤ [4.1.2] āĻāĻ° āĻĻā§āĻŦāĻŋāĻ¤ā§ā§ āĻāĻĻāĻžāĻšāĻ°āĻŖāĻāĻž āĻāĻŦāĻžāĻ° āĻāĻŽāĻ°āĻž āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻāĻ° āĻ¸āĻžāĻšāĻžāĻ¯ā§āĻ¯ā§ āĻāĻ°āĻŦā§ :Â
package main
import (
"fmt"
)
func hello(done chan bool) {
fmt.Println("Hello world Goroutine")
done <- true // signal that the work is done
}
func main() {
done := make(chan bool)
go hello(done)
<-done // wait for the Goroutine to finish
fmt.Println("main function")
}
// Output :
// Hello world Goroutine
// main function
āĻāĻĒāĻ°ā§āĻ° āĻāĻĻāĻžāĻšāĻ°āĻŖā§, done bool āĻ¨āĻžāĻŽā§ āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻ¤ā§āĻ°āĻŋ āĻāĻ°ā§āĻāĻŋ āĻ¸ā§āĻāĻž hello āĻā§-āĻ°ā§āĻāĻŋāĻ¨ āĻ āĻĒā§āĻ¯āĻžāĻ°āĻžāĻŽāĻŋāĻāĻžāĻ° āĻšāĻŋāĻ¸ā§āĻŦā§ āĻĒāĻžāĻ¸ āĻāĻ°ā§āĻāĻŋ, āĻĒāĻ°ā§āĻ° āĻ˛āĻžāĻāĻ¨ā§ hello() āĻĨā§āĻā§ āĻĒāĻžāĻ āĻžāĻ¨ā§ āĻĄāĻžāĻāĻž <-done āĻāĻ° āĻ¸āĻžāĻšāĻžāĻ¯ā§āĻ¯ā§ āĻ°āĻŋāĻ¸āĻŋāĻ āĻāĻ°āĻ¤ā§āĻāĻŋ āĻ¯āĻž done <- āĻāĻ° āĻ¸āĻžāĻšāĻžāĻ¯ā§āĻ¯ā§ āĻĒāĻžāĻ āĻžāĻ¨ā§ āĻšā§ā§āĻāĻŋāĻ˛āĨ¤ āĻ āĻ°ā§āĻĨāĻžā§ āĻā§-āĻ°ā§āĻāĻŋāĻ¨ āĻĄāĻžāĻāĻž āĻ¸ā§āĻ¨ā§āĻĄ āĻ¨āĻž āĻāĻ°āĻž āĻĒāĻ°ā§āĻ¯āĻ¨ā§āĻ¤ āĻŽā§āĻāĻ¨ āĻĢāĻžāĻāĻļāĻ¨ āĻŦā§āĻ˛āĻ āĻ āĻŦāĻ¸ā§āĻĨāĻžā§ āĻĨāĻžāĻāĻŦā§āĨ¤ āĻāĻ¤ā§ āĻāĻ°ā§ āĻāĻŽāĻžāĻĻā§āĻ° āĻāĻ° time.Sleep() āĻ˛āĻŋāĻā§ āĻ āĻĒā§āĻā§āĻˇāĻž āĻāĻ°āĻ¤ā§ āĻŦāĻ˛āĻž āĻ˛āĻžāĻā§āĻ¨āĻŋ āĻāĻŦāĻ āĻŽā§āĻāĻ¨ āĻĢāĻžāĻāĻļāĻ¨ āĻ¤āĻžāĻ° āĻāĻā§āĻ¸āĻŋāĻāĻŋāĻāĻļāĻ¨ āĻļā§āĻˇ āĻāĻ°ā§ āĻĻā§ā§āĻ¨āĻŋāĨ¤Â Â
āĻāĻĒāĻ°ā§āĻ° āĻāĻĻāĻžāĻšāĻ°āĻŖāĻāĻŋ āĻāĻāĻā§ āĻŽāĻĄāĻŋāĻĢāĻžāĻ āĻāĻ°āĻž āĻ¯āĻžāĻ :Â
package main
import (
"fmt"
"time"
)
func hello(done chan bool) {
fmt.Println("hello Go routine is Going to sleep")
time.Sleep(4 * time.Second)
fmt.Println("hello Go routine awake and Going to write to done")
done <- true // signal that the work is done
}
func main() {
done := make(chan bool)
fmt.Println("Main Going to call hello Go Goroutine")
go hello(done)
<-done // wait for the Goroutine to finish
fmt.Println("Main received data")
}
// Output :
// Main Going to call hello Go Goroutine
// hello Go routine is Going to sleep
// hello Go routine awake and Going to write to done
// Main received data
āĻāĻŦāĻžāĻ° āĻ˛āĻā§āĻˇ āĻāĻ°āĻž āĻ¯āĻžāĻ, āĻāĻ āĻĒā§āĻ°ā§āĻā§āĻ°āĻžāĻŽā§ āĻĒā§āĻ°āĻĨāĻŽā§ âMain Going to call hello Go Goroutineâ āĻĒā§āĻ°āĻŋāĻ¨ā§āĻ āĻšā§ā§āĻā§,āĻ¤āĻžāĻ°āĻĒāĻ° āĻā§-āĻ°ā§āĻāĻŋāĻ¨ āĻ¸ā§āĻāĻžāĻ°ā§āĻ āĻšā§ā§āĻā§ āĻāĻŦāĻ âhello Go routine is Going to sleepâ āĻĒā§āĻ°āĻŋāĻ¨ā§āĻ āĻšā§ā§āĻā§āĨ¤ āĻāĻāĻŋ āĻĒā§āĻ°āĻŋāĻ¨ā§āĻ āĻšāĻāĻ¯āĻŧāĻžāĻ° āĻĒāĻ°ā§, hello āĻā§-āĻ°ā§āĻāĻŋāĻ¨ 4 āĻ¸ā§āĻā§āĻ¨ā§āĻĄā§āĻ° āĻāĻ¨ā§āĻ¯ Sleep āĻ āĻ¯āĻžāĻŦā§ āĻāĻŦāĻ āĻāĻ āĻ¸āĻŽāĻ¯āĻŧā§āĻ° āĻŽāĻ§ā§āĻ¯ā§ āĻŽā§āĻāĻ¨ āĻā§-āĻ°ā§āĻāĻŋāĻ¨ āĻŦā§āĻ˛āĻ āĻšāĻ¯āĻŧā§ āĻ¯āĻžāĻŦā§ āĻāĻžāĻ°āĻŖ āĻāĻāĻŋ āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻĨā§āĻā§ āĻ°ā§āĻ¸āĻĒāĻ¨ā§āĻ¸ā§āĻ° āĻāĻ¨ā§āĻ¯ āĻ āĻĒā§āĻā§āĻˇāĻž āĻāĻ°āĻā§āĨ¤ 4 āĻ¸ā§āĻā§āĻ¨ā§āĻĄ āĻĒāĻ° âhello Go routine awake and Going to write to doneâ āĻĒā§āĻ°āĻŋāĻ¨ā§āĻ āĻšāĻŦā§ āĻāĻŦāĻ āĻ°ā§āĻ¸āĻĒāĻ¨ā§āĻ¸ āĻāĻ¸āĻŦā§ āĻ¤āĻāĻ¨ âMain received dataâ āĻĒā§āĻ°āĻŋāĻ¨ā§āĻ āĻšāĻŦā§ āĻ¸āĻžāĻĨā§ āĻ¸āĻžāĻĨā§ āĻŽā§āĻāĻ¨ āĻĢāĻžāĻāĻļāĻ¨āĻ āĻŦāĻ¨ā§āĻ§ āĻšā§ā§ āĻ¯āĻžāĻŦā§āĨ¤
[ā§Ē.ā§¨.ā§Ē] Unbuffered āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛Â āĻā§ ?
āĻāĻŽāĻ°āĻž āĻāĻā§āĻ āĻŦāĻ˛ā§āĻāĻŋ āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻĻā§āĻ āĻĒā§āĻ°āĻāĻžāĻ° Unbuffered āĻāĻŦāĻ Buffered āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĨ¤ āĻāĻāĻ¨ āĻāĻŽāĻ°āĻž āĻāĻžāĻ¨āĻŦ Unbuffered āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻ¸āĻŽā§āĻĒāĻ°ā§āĻā§ āĨ¤ āĻāĻ¸āĻ˛ā§ āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻŦāĻžāĻ āĻĄāĻŋāĻĢāĻ˛ā§āĻ Unbuffered āĻĨāĻžāĻā§āĨ¤ Unbuffered āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻ āĻā§āĻ¯āĻžāĻ˛ā§ āĻ¸ā§āĻ¨ā§āĻĄāĻŋāĻ (chan <- )Â āĻāĻ° āĻāĻ°ā§āĻ¸ā§āĻĒāĻ¨ā§āĻĄāĻŋāĻ āĻā§āĻ¯āĻžāĻ˛ā§ āĻ°āĻŋāĻ¸āĻŋāĻāĻžāĻ° (<- chan) āĻĨāĻžāĻāĻŦā§āĨ¤
package main
import (
"fmt"
"time"
)
// ---send data into a channel---
func sendData(ch chan string) {
fmt.Println("Sending a string into channel...")
ch <- "Hello"
fmt.Println("String has been retrieved from channel...")
}
// ---getting data from the channel---
func getData(ch chan string) {
time.Sleep(2 * time.Second)
fmt.Println("String retrieved from channel:", <-ch)
}
func main() {
ch := make(chan string)
go sendData(ch)
go getData(ch)
fmt.Scanln()
}
// Output :
// Sending a string into channel...
// String retrieved from channel: Hello
// String has been retrieved from channelâĻ
[ā§Ē.ā§¨.ā§Ģ] Buffered āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛Â āĻā§ ?
Buffered āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛Â āĻāĻ āĻ§āĻ°āĻ¨ā§āĻ° āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻ¯āĻžāĻ° āĻāĻāĻāĻŋ āĻ¨āĻŋāĻ°ā§āĻĻāĻŋāĻˇā§āĻ Buffer āĻĨāĻžāĻāĻŦā§ āĻ¯ā§āĻāĻžāĻ¨ā§ āĻ¨āĻŋāĻ°ā§āĻĻāĻŋāĻˇā§āĻ āĻ¸āĻāĻā§āĻ¯āĻ āĻā§āĻ¯āĻžāĻ˛ā§ āĻˇā§āĻā§āĻ° āĻāĻ°ā§ āĻ°āĻžāĻāĻ¤ā§ āĻĒāĻžāĻ°ā§ āĻāĻ°ā§āĻ¸ā§āĻĒāĻ¨ā§āĻĄāĻŋāĻ āĻā§āĻ¨ āĻ°āĻŋāĻ¸āĻŋāĻāĻžāĻ° āĻāĻžā§āĻžāĻāĨ¤ āĻ¯āĻāĻ¨ āĻāĻŽāĻžāĻĻā§āĻ° āĻāĻāĻāĻŋ Go āĻ°ā§āĻāĻŋāĻ¨ā§ āĻĄā§āĻāĻž āĻĒā§āĻ°āĻ¸ā§āĻ¤ā§āĻ¤ āĻāĻ°āĻ¤ā§ āĻšā§ āĻāĻŦāĻ āĻ āĻ¨ā§āĻ¯ Go āĻ°ā§āĻāĻŋāĻ¨ā§ āĻĄā§āĻāĻž āĻ¸āĻ°āĻŦāĻ°āĻžāĻš āĻāĻ°āĻ¤ā§ āĻšā§ āĻ¤āĻāĻ¨ āĻāĻŽāĻ°āĻž āĻŦāĻžāĻĢāĻžāĻ° āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛āĻā§āĻ˛āĻŋ āĻŦā§āĻ¯āĻŦāĻšāĻžāĻ° āĻāĻ°āĻ¤ā§ āĻĒāĻžāĻ°āĻŋāĨ¤Â Â
Â
Buffered āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻ¸āĻŋāĻ¨āĻā§āĻ¯āĻžāĻā§āĻ¸ :Â
āĻāĻĻāĻžāĻšāĻ°āĻŖ :Â
package main
import (
"fmt"
)
func main() {
linkChannel := make(chan string, 5)
go ping(linkChannel)
fmt.Println(<-linkChannel)
fmt.Println(<-linkChannel)
fmt.Println(<-linkChannel)
}
func ping(c chan string) {
links := []string{"https://www.golinuxcloud.com/", "https://www.tesla.com/", "https://www.google.com/"}
for _, link := range links {
c <- link
}
}
// Output :
// https://www.golinuxcloud.com/
// https://www.tesla.com/
// https://www.google.com/
āĻāĻĒāĻ°ā§āĻ° āĻāĻĻāĻžāĻšāĻ°āĻŖā§, āĻāĻāĻāĻŋ buffered āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ linkChannel āĻ¯āĻž āĻā§-āĻ°ā§āĻāĻŋāĻ¨ ping āĻāĻ° āĻ¸āĻžāĻĨā§ āĻĒāĻžāĻ āĻžāĻ¨ā§ āĻšā§ā§āĻā§āĨ¤ ping() āĻĢāĻžāĻāĻļāĻ¨ āĻĨā§āĻā§ āĻĒāĻžāĻ āĻžāĻ¨ā§ āĻā§āĻ¯āĻžāĻ˛ā§ main() āĻĢāĻžāĻāĻļāĻ¨ āĻ°āĻŋāĻ¸āĻŋāĻ āĻāĻ°ā§āĻā§ āĨ¤Â
[ āĻ¨ā§āĻ – buffered āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻĒā§āĻ¯āĻžāĻ¨āĻŋāĻ āĻāĻŦāĻ āĻāĻ°āĻ° āĻ°āĻŋāĻāĻžāĻ°ā§āĻ¨ āĻāĻ°ā§ āĻ¯āĻāĻ¨ āĻ°āĻŋāĻ¸āĻŋāĻāĻžāĻ°(<- link Channel ) āĻāĻŽā§āĻĒāĻāĻŋ āĻĨāĻžāĻā§ ]Â
[ā§Ē.ā§¨.ā§Ŧ] āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻ SelectÂ
Go-āĻ¤ā§, āĻ¸āĻŋāĻ˛ā§āĻā§āĻ āĻ¸ā§āĻā§āĻāĻŽā§āĻ¨ā§āĻ āĻ āĻ¨ā§āĻ āĻā§āĻˇā§āĻ¤ā§āĻ°ā§āĻ āĻŦā§āĻ¯āĻŦāĻšāĻžāĻ° āĻāĻ°āĻž āĻšā§, āĻŦāĻŋāĻļā§āĻˇ āĻāĻ°ā§ āĻŽāĻžāĻ˛ā§āĻāĻŋāĻĒāĻ˛ āĻā§-āĻ°ā§āĻāĻŋāĻ¨ āĻŦā§āĻ¯āĻŦāĻšāĻžāĻ° āĻāĻ°āĻž āĻšāĻ˛ā§ āĻ¤āĻāĻ¨ āĻ āĻ¨ā§āĻ āĻĄāĻžāĻāĻž āĻļā§ā§āĻžāĻ° āĻšā§, āĻ¤āĻāĻ¨ āĻāĻā§āĻ˛ā§ āĻ¸āĻŋāĻā§ā§ā§āĻ¨ā§āĻ¸ āĻ āĻ¨ā§āĻ¸āĻžāĻ°ā§ āĻĒāĻžāĻā§āĻžāĻ° āĻāĻ¨ā§āĻ¯ āĻ¸āĻŋāĻ˛ā§āĻā§āĻ āĻ¸ā§āĻā§āĻāĻŽā§āĻ¨ā§āĻ āĻŦā§āĻ¯āĻŦāĻšāĻžāĻ° āĻāĻ°āĻž āĻšā§āĨ¤ āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ā§ āĻŽāĻžāĻ˛ā§āĻāĻŋāĻĒāĻ˛ āĻĄāĻžāĻāĻž āĻ¸āĻŋāĻā§ā§ā§āĻ¨ā§āĻ¸ āĻ āĻ¨ā§āĻ¸ā§āĻŦāĻžāĻ°ā§ āĻĒāĻžāĻā§āĻžāĻ° āĻāĻ¨ā§āĻ¯āĻ āĻāĻŽāĻ°āĻž āĻ¸āĻŋāĻ˛ā§āĻā§āĻ āĻ¸ā§āĻā§āĻāĻŽā§āĻ¨ā§āĻ āĻŦā§āĻ¯āĻŦāĻšāĻžāĻ° āĻāĻ°āĻ¤ā§ āĻĒāĻžāĻ°āĻŋāĨ¤ āĻ¸āĻŋāĻ˛ā§āĻā§āĻ āĻ¸ā§āĻā§āĻāĻŽā§āĻ¨ā§āĻ āĻ āĻ¨ā§āĻāĻāĻžāĻ switch āĻ¸ā§āĻā§āĻāĻŽā§āĻ¨ā§āĻā§āĻ° āĻŽāĻ¤ā§āĻ āĻ¯āĻžāĻ° āĻ¸āĻžāĻšāĻžāĻ¯ā§āĻ¯ā§ āĻŽāĻžāĻ˛ā§āĻāĻŋāĻĒāĻ˛ āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻāĻ° āĻ¸āĻžāĻĨā§ āĻāĻŽāĻŋāĻāĻ¨āĻŋāĻā§āĻļāĻ¨ āĻāĻ°āĻž āĻ¯āĻžā§āĨ¤
āĻ¸āĻŋāĻ˛ā§āĻā§āĻ āĻ¸ā§āĻā§āĻāĻŽā§āĻ¨ā§āĻā§āĻ° āĻ¸āĻŋāĻ¨āĻā§āĻ¯āĻžāĻā§āĻ¸ :Â
select {
case <-ch1: // Discard received value
fmt.Println("Got something")
case x := <-ch2: // Assign received value to x
fmt.Println(x)
case ch3 <- y: // Send y to channel
fmt.Println(y)
default:
fmt.Println("None of the above")
}
āĻāĻĒāĻ°ā§āĻ° āĻāĻĻāĻžāĻšāĻ°āĻŖā§, āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ ch1 āĻ¯āĻĻāĻŋ āĻ°āĻŋāĻ¸āĻŋāĻ āĻ¸ā§āĻāĻžāĻā§ āĻĨāĻžāĻā§ āĻ¤āĻžāĻšāĻ˛ā§ āĻ¸ā§ âGot somethingâ āĻĒā§āĻ°āĻŋāĻ¨ā§āĻ āĻāĻ°āĻŦā§,
āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ ch2 āĻā§āĻ¯āĻžāĻ˛ā§ āĻ°āĻŋāĻ¸āĻŋāĻ āĻāĻ°ā§ x āĻ ā§āĻ¯āĻžāĻ¸āĻžāĻāĻ¨ āĻāĻ°ā§ āĻ¤āĻžāĻ°āĻĒāĻ° āĻĒā§āĻ°āĻŋāĻ¨ā§āĻ āĻāĻ°āĻŦā§, āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ ch3, y āĻāĻ° āĻā§āĻ¯āĻžāĻ˛ā§Â āĻ¸ā§āĻ¨ā§āĻĄ āĻāĻ°āĻŦā§ āĻāĻ° āĻāĻ āĻāĻ¨ā§āĻĄāĻŋāĻļāĻā§āĻ˛ā§ āĻ¸āĻ¤ā§āĻ¯ āĻ¨āĻž āĻšāĻ˛ā§ default āĻ âNone of the aboveâ āĻĒā§āĻ°āĻŋāĻ¨ā§āĻ āĻšāĻŦā§āĨ¤
[ā§Ē.ā§¨.ā§] āĻā§āĻ˛ā§āĻāĻŋāĻ āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛(Closing Channel )
āĻĒā§āĻ°ā§āĻā§āĻ°āĻžāĻŽā§āĻ° āĻ¯ā§āĻāĻžāĻ¨ā§ āĻ¯ā§ āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻŦā§āĻ¯āĻŦāĻšā§āĻ¤ āĻšā§, āĻ¸ā§ āĻāĻžā§āĻāĻž āĻšāĻ¤ā§āĻ āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛āĻāĻŋ āĻŦāĻ¨ā§āĻ§ āĻāĻ°āĻž āĻ¸āĻŽā§āĻāĻŦ, close() āĻĢāĻžāĻāĻļāĻ¨ āĻŦā§āĻ¯āĻŦāĻšāĻžāĻ° āĻāĻ°ā§āĨ¤ āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛āĻāĻŋ āĻŦāĻ¨ā§āĻ§ āĻāĻ°āĻž āĻšāĻ¯āĻŧā§āĻā§ āĻāĻŋāĻ¨āĻž āĻ¤āĻž āĻĒāĻ°ā§āĻā§āĻˇāĻž āĻāĻ°āĻ¤ā§ āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻĨā§āĻā§ āĻĄāĻžāĻāĻž āĻā§āĻ°āĻšāĻŖ āĻāĻ°āĻžāĻ° āĻ¸āĻŽāĻ¯āĻŧ āĻ°āĻŋāĻ¸āĻŋāĻāĻžāĻ° āĻāĻāĻāĻŋ āĻ āĻ¤āĻŋāĻ°āĻŋāĻā§āĻ¤ āĻāĻžāĻ°āĻŋā§āĻžāĻŦāĻ˛ āĻā§āĻāĻžāĻ° āĻšāĻŋāĻ¸ā§āĻŦā§ āĻŦā§āĻ¯āĻŦāĻšāĻžāĻ° āĻāĻ°āĻ¤ā§ āĻĒāĻžāĻ°ā§āĨ¤ āĻ¯ā§āĻŽāĻ¨ –Â
v, ok := <- ch
āĻ¯āĻĻāĻŋ ok āĻ¸ā§āĻā§āĻāĻŽā§āĻ¨ā§āĻ true āĻšā§ āĻ¤āĻžāĻšāĻ˛ā§ āĻ°āĻŋāĻ¸āĻŋāĻāĻžāĻ° āĻŦā§āĻāĻŦā§ āĻāĻāĻž āĻ¸āĻ āĻŋāĻ āĻ¸ā§āĻ¨ā§āĻĄāĻžāĻ° āĻĨā§āĻā§ āĻĄāĻžāĻāĻž āĻāĻ¸ā§āĻā§ āĻāĻ° ok āĻ¸ā§āĻā§āĻāĻŽā§āĻ¨ā§āĻ false āĻšāĻ˛ā§ āĻ°āĻŋāĻ¸āĻŋāĻāĻžāĻ° āĻŦā§āĻāĻŦā§ āĻāĻāĻž āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻŦāĻ¨ā§āĻ§ āĻāĻ°āĻž āĻšā§ā§āĻā§āĨ¤ āĻāĻ° āĻāĻāĻāĻž āĻŦāĻ¨ā§āĻ§ āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻĨā§āĻā§ āĻ¸āĻ°ā§āĻŦāĻĻāĻžāĻ 0 āĻ āĻĨāĻŦāĻž nil āĻŽāĻžāĻ¨ āĻāĻ¸āĻŦā§āĨ¤
Â
āĻ¨āĻŋāĻā§āĻ° āĻāĻĻāĻžāĻšāĻ°āĻŖāĻāĻŋ āĻĻā§āĻāĻž āĻ¯āĻžāĻ –
package main
import (
"fmt"
)
func producer(chnl chan int) {
for i := 0; i < 10; i++ {
chnl <- i
}
close(chnl)
}
func main() {
ch := make(chan int)
go producer(ch)
for {
v, ok := <-ch
if ok == false {
break
}
fmt.Println("Received ", v, ok)
}
}
// Output:
// Received 0 true
// Received 1 true
// Received 2 true
// Received 3 true
// Received 4 true
// Received 5 true
// Received 6 true
// Received 7 true
// Received 8 true
// Received 9 true
āĻāĻāĻžāĻ¨ā§ 0 āĻĨā§āĻā§ 9 āĻĒāĻ°ā§āĻ¯āĻ¨ā§āĻ¤ āĻĒā§āĻ°āĻŋāĻ¨ā§āĻ āĻšā§ā§āĻā§, āĻ¯āĻāĻ¨ ok āĻā§āĻ¯āĻžāĻ˛ā§ āĻŽāĻŋāĻĨā§āĻ¯āĻž āĻĒā§ā§ā§āĻā§ āĻ¤āĻāĻ¨āĻ āĻā§āĻ¯āĻžāĻ¨ā§āĻ˛ āĻŦāĻ¨ā§āĻ§ āĻāĻ°ā§ āĻĻāĻŋā§ā§āĻā§āĨ¤ main() āĻĢāĻžāĻāĻļāĻ¨ā§ ok āĻŽāĻŋāĻĨā§āĻ¯āĻž āĻšāĻā§āĻžāĻ° āĻ¸āĻžāĻĨā§ āĻ¸āĻžāĻĨā§āĻ break āĻāĻ°ā§ āĻĻāĻŋā§ā§āĻā§āĨ¤Â
