快捷導(dǎo)航

golang?channel管道使用示例解析

更新時(shí)間：2022年04月14日 14:28:37 作者：Jeff的技術(shù)棧

這篇文章主要介紹了golang?channel管道使用示例解析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步早日升職加薪

定義channel管道

定義一個(gè)channel時(shí)，也需要定義發(fā)送到管道的值類型。channel可以使用內(nèi)置的make()函數(shù)來創(chuàng)建：

var ch = make(chan int) //等價(jià)于：make(chan Type,0)
var ch = make(chan Type,capacity)

channel管道塞值和取值

ch &lt;- 666  //向ch管道塞入666
&lt;- ch  // 向ch管道接收值，并丟棄
x := &lt;-ch  //向ch管道中接收數(shù)據(jù)，并復(fù)制給x
x, ok := &lt;-ch  //向ch管道中接收數(shù)據(jù)，并復(fù)制給x,同時(shí)檢查通道是否已關(guān)閉或者是否為空

當(dāng)capacity=0時(shí)，channel管道是無緩沖阻塞讀寫，
當(dāng)capacity>0時(shí)，channel管道有緩沖，是非阻塞的，直到寫滿capacity個(gè)元素才阻塞寫入。

注意：默認(rèn)情況下，channel接收和發(fā)送數(shù)據(jù)都是阻塞的，除非另一端已經(jīng)準(zhǔn)備好，這樣就使得goroutine同步變得更加簡(jiǎn)單，而不需要顯示的lock。

通過channel管道實(shí)現(xiàn)同步，和數(shù)據(jù)交互

package main
import (
	"fmt"
	"time"
)
func main() {
	//創(chuàng)建channel
	ch := make(chan string)
	defer fmt.Println("主協(xié)程也結(jié)束")
	go func() {
		defer fmt.Println("子協(xié)程調(diào)用完畢")
		for i := 0; i < 2; i++ {
			fmt.Println("子協(xié)程 i = ", i)
			time.Sleep(time.Second)
		}
		ch <- "我是子協(xié)程，要工作完畢"
	}()
	str := <-ch //沒有數(shù)據(jù)前，阻塞
	fmt.Println("str = ", str)
}

無緩沖的channel

ch := make(chan int, 0)

package main
import (
	"fmt"
	"time"
)
func main() {
	//創(chuàng)建一個(gè)無緩存的channel
	ch := make(chan int, 0)

	//len(ch)緩沖區(qū)剩余數(shù)據(jù)個(gè)數(shù)， cap(ch)緩沖區(qū)大小
	fmt.Printf("len(ch) = %d, cap(ch)= %d\n", len(ch), cap(ch))
	//新建協(xié)程
	go func() {
		for i := 0; i < 10000; i++ {
			fmt.Printf("子協(xié)程：i = %d\n", i)
			ch <- i //往chan寫內(nèi)容
			time.Sleep(1 * time.Second)
		}
	}()
	go func() {
		for  {
			num := <-ch //讀管道中內(nèi)容，沒有內(nèi)容前，阻塞
			fmt.Println("num = ", num)
		}

	}()
	for {
	}
}

有緩沖的channel管道

ch := make(chan int, 3)

package main
import (
	"fmt"
	"time"
)
func main() {
	//創(chuàng)建一個(gè)有緩存的channel
	ch := make(chan int, 3)
	//len(ch)緩沖區(qū)剩余數(shù)據(jù)個(gè)數(shù)， cap(ch)緩沖區(qū)大小
	fmt.Printf("len(ch) = %d, cap(ch)= %d\n", len(ch), cap(ch))
	//新建協(xié)程
	go func() {
		for i := 0; i < 10; i++ {
			ch <- i //往chan寫內(nèi)容
			fmt.Printf("子協(xié)程[%d]: len(ch) = %d, cap(ch)= %d\n", i, len(ch), cap(ch))
		}
	}()
	//延時(shí)
	time.Sleep(2 * time.Second)
	for i := 0; i < 10; i++ {
		num := <-ch //讀管道中內(nèi)容，沒有內(nèi)容前，阻塞
		fmt.Println("num = ", num)
	}
}

關(guān)閉channel管道

close(ch)

package main
import (
	"fmt"
)
func main() {
	//創(chuàng)建一個(gè)無緩存的channel
	ch := make(chan int, 3)
	//len(ch)緩沖區(qū)剩余數(shù)據(jù)個(gè)數(shù)， cap(ch)緩沖區(qū)大小
	fmt.Printf("len(ch) = %d, cap(ch)= %d\n", len(ch), cap(ch))
	//新建協(xié)程
	go func() {
		for i := 0; i < 10000; i++ {
			fmt.Printf("子協(xié)程：i = %d\n", i)
			ch <- i //往chan寫內(nèi)容
			//time.Sleep(1 * time.Second)
			if i >10 {
				close(ch)
				break
			}
		}
	}()
	go func() {
		for  {
			if num, ok := <-ch; ok == true {
				fmt.Println("num = ", num)
			} else { //管道關(guān)閉
				break
			}
		}
	}()
	for {

	}
}

單向channel管道,讀寫分離

chan<- 表示數(shù)據(jù)進(jìn)入管道，只寫
<-chan 表示數(shù)據(jù)從管道出來，只讀

注意：雙向可轉(zhuǎn)為單向，單向不可轉(zhuǎn)為雙向

package main
//"fmt"
func main() {
	//創(chuàng)建一個(gè)channel, 雙向的
	ch := make(chan int)
	//雙向channel能隱式轉(zhuǎn)換為單向channel
	var writeCh chan<- int = ch //只能寫，不能讀
	var readCh <-chan int = ch  //只能讀，不能寫
	writeCh <- 666 //寫
	//<-writeCh //err,  invalid operation: <-writeCh (receive from send-only type chan<- int)
	<-readCh //讀
	//readCh <- 666 //寫， err,  invalid operation: readCh <- 666 (send to receive-only type <-chan int)
	//單向無法轉(zhuǎn)換為雙向
	//var ch3 chan int = writeCh //cannot use writeCh (type chan<- int) as type chan int in assignment

}

管道消費(fèi)者生產(chǎn)者模型

package main
import (
	"fmt"
)
//此通道只能寫，不能讀
func producer(out chan<- int) {
	for i := 0; i < 10; i++ {
		out <- i * i  //寫入
	}
	close(out)  //關(guān)閉
}
//此channel只能讀，不能寫
func consumer(data <-chan int) {
	for num := range data {
		fmt.Println("num = ", num)
	}
}
func main() {
	//創(chuàng)建一個(gè)雙向通道
	ch := make(chan int)
	//生產(chǎn)者，生產(chǎn)數(shù)字，寫入channel
	//新開一個(gè)協(xié)程
	go producer(ch) //channel傳參，引用傳遞
	//消費(fèi)者，從channel讀取內(nèi)容，打印
	consumer(ch)
}

以上就是golang channel管道的詳細(xì)內(nèi)容，更多關(guān)于channel管道的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: