日本免费高清视频-国产福利视频导航-黄色在线播放国产-天天操天天操天天操天天操|www.shdianci.com

學無先后，達者為師

網(wǎng)站首頁 編程語言 正文

golang?channel管道使用示例解析_Golang

作者：Jeff的技術棧 ? 更新時間： 2022-06-14 編程語言

定義channel管道

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

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

channel管道塞值和取值

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

當capacity=0時，channel管道是無緩沖阻塞讀寫，
當capacity>0時，channel管道有緩沖，是非阻塞的，直到寫滿capacity個元素才阻塞寫入。
?

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

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

package main
import (
	"fmt"
	"time"
)
func main() {
	//創(chuàng)建channel
	ch := make(chan string)
	defer fmt.Println("主協(xié)程也結束")
	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)建一個無緩存的channel
	ch := make(chan int, 0)

	//len(ch)緩沖區(qū)剩余數(shù)據(jù)個數(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)建一個有緩存的channel
	ch := make(chan int, 3)
	//len(ch)緩沖區(qū)剩余數(shù)據(jù)個數(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))
		}
	}()
	//延時
	time.Sleep(2 * time.Second)
	for i := 0; i < 10; i++ {
		num := <-ch //讀管道中內(nèi)容，沒有內(nèi)容前，阻塞
		fmt.Println("num = ", num)
	}
}

關閉channel管道

close(ch)

package main
import (
	"fmt"
)
func main() {
	//創(chuàng)建一個無緩存的channel
	ch := make(chan int, 3)
	//len(ch)緩沖區(qū)剩余數(shù)據(jù)個數(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 { //管道關閉
				break
			}
		}
	}()
	for {

	}
}

單向channel管道,讀寫分離

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

注意：雙向可轉為單向，單向不可轉為雙向

package main
//"fmt"
func main() {
	//創(chuàng)建一個channel, 雙向的
	ch := make(chan int)
	//雙向channel能隱式轉換為單向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)
	//單向無法轉換為雙向
	//var ch3 chan int = writeCh //cannot use writeCh (type chan<- int) as type chan int in assignment

}

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

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

原文鏈接：https://www.cnblogs.com/guyouyin123/p/13986351.html

欄目分類
最近更新