Non Blocking Channel Operations

Non-Blocking Channel Operations #

// Channel တွေပေါ်မှာ အခြေခံ ပို့တာ(send)နဲ့ လက်ခံတာ (receive) တွေက blocking ဖြစ်ပါတယ်။
// ဒါပေမယ့် `select` နဲ့ `default` clause ကိုသုံးပြီး `non-blocking` ပို့တာ၊
// လက်ခံတာ၊ ဒါ့အပြင် non-blocking multi-way `select` တွေကိုတောင်
// implement လုပ်နိုင်ပါတယ်။

package main

import "fmt"

func main() {
	messages := make(chan string)
	signals := make(chan bool)

	// ဒါက non-blocking လက်ခံမှုပါ။ `messages` မှာ တန်ဖိုးတစ်ခု အဆင်သင့်ရှိနေရင်
	// `select` က အဲဒီတန်ဖိုးနဲ့အတူ `<-messages` `case` ကို ယူပါလိမ့်မယ်။
	// မရှိဘူးဆိုရင်တော့ ချက်ချင်း `default` case ကို ယူပါလိမ့်မယ်။
	select {
	case msg := <-messages:
		fmt.Println("received message", msg)
	default:
		fmt.Println("no message received")
	}

	// Non-blocking ပို့မှုကလည်း အပေါ်ကလိုဘဲ အလုပ်လုပ်ပါတယ်။ ဒီမှာ `msg` ကို
	// `messages` channel ဆီ ပို့လို့မရပါဘူး၊ ဘာလို့လဲဆိုတော့
	// channel မှာ buffer မရှိသလို လက်ခံမယ့်သူလည်း မရှိလို့ပါ။
	// ဒါကြောင့် `default` case ကို ရွေးချယ်ပါတယ်။
	msg := "hi"
	select {
	case messages <- msg:
		fmt.Println("sent message", msg)
	default:
		fmt.Println("no message sent")
	}

	// `default` clause ရဲ့အပေါ်မှာ `case` အများကြီးသုံးပြီး
	// multi-way non-blocking select ကို implement လုပ်နိုင်ပါတယ်။
	// ဒီမှာ `messages` နဲ့ `signals` နှစ်ခုလုံးကနေ non-blocking လက်ခံဖို့ ကြိုးစားပါတယ်။
	select {
	case msg := <-messages:
		fmt.Println("received message", msg)
	case sig := <-signals:
		fmt.Println("received signal", sig)
	default:
		fmt.Println("no activity")
	}
}
$ go run non-blocking-channel-operations.go 
no message received
no message sent
no activity