golang?channel管道使用示例解析

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

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

定義channel管道

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

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

channel管道塞值和取值

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

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

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

通過channel管道實現同步，和數據交互

package main
import (
	"fmt"
	"time"
)
func main() {
	//創(chuàng)建channel
	ch := make(chan string)
	defer fmt.Println("主協(xié)程也結束")
	go func() {
		defer fmt.Println("子協(xié)程調用完畢")
		for i := 0; i < 2; i++ {
			fmt.Println("子協(xié)程 i = ", i)
			time.Sleep(time.Second)
		}
		ch <- "我是子協(xié)程，要工作完畢"
	}()
	str := <-ch //沒有數據前，阻塞
	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ū)剩余數據個數， 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寫內容
			time.Sleep(1 * time.Second)
		}
	}()
	go func() {
		for  {
			num := <-ch //讀管道中內容，沒有內容前，阻塞
			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ū)剩余數據個數， 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寫內容
			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 //讀管道中內容，沒有內容前，阻塞
		fmt.Println("num = ", num)
	}
}

關閉channel管道

close(ch)

package main
import (
	"fmt"
)
func main() {
	//創(chuàng)建一個無緩存的channel
	ch := make(chan int, 3)
	//len(ch)緩沖區(qū)剩余數據個數， 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寫內容
			//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<- 表示數據進入管道，只寫
<-chan 表示數據從管道出來，只讀

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

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

}

管道消費者生產者模型

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)
	//生產者，生產數字，寫入channel
	//新開一個協(xié)程
	go producer(ch) //channel傳參，引用傳遞
	//消費者，從channel讀取內容，打印
	consumer(ch)
}

以上就是golang channel管道的詳細內容，更多關于channel管道的資料請關注腳本之家其它相關文章！

您可能感興趣的文章:

手把手帶你走進Go語言之類型轉換
每個函數都可以強制將一個表達式轉換成某種特定數據類型，本文給大家介紹了在Go語言中類型轉換的具體用法，講述的非常詳細，對大家的學習或工作具有一定的參考借鑒價值
2021-09-09
詳解Go語言中Goroutine退出機制的原理及使用
goroutine是Go語言提供的語言級別的輕量級線程，在我們需要使用并發(fā)時，我們只需要通過?go?關鍵字來開啟?goroutine?即可。本文就來詳細講講Goroutine退出機制的原理及使用，感興趣的可以了解一下
2022-07-07
GoLang?channel底層代碼分析詳解
Channel和goroutine的結合是Go并發(fā)編程的大殺器。而Channel的實際應用也經常讓人眼前一亮，通過與select，cancel，timer等結合，它能實現各種各樣的功能。接下來，我們就要梳理一下GoLang?channel底層代碼實現
2022-10-10
Go語言中普通函數與方法的區(qū)別分析
這篇文章主要介紹了Go語言中普通函數與方法的區(qū)別,以實例形式對比分析了普通函數與方法使用時的區(qū)別與相關技巧,需要的朋友可以參考下
2015-02-02
使用Go語言實現簡單聊天系統(tǒng)
本文介紹了如何使用Go語言和WebSocket技術構建一個簡單的多人聊天室系統(tǒng),包括客戶端連接管理、消息廣播和并發(fā)處理,最后,通過編寫main.go、hub.go和client.go等核心代碼模塊,具有一定的參考價值,感興趣的可以了解一下
2024-10-10
Golang使用原生http實現中間件的代碼詳解
中間件（middleware）：常被用來做認證校驗、審計等,家常用的Iris、Gin等web框架,都包含了中間件邏輯,但有時我們引入該框架顯得較為繁重,本文將介紹通過golang原生http來實現中間件操作,需要的朋友可以參考下
2024-05-05
一文帶你了解Go語言如何解析JSON
本文將說明如何利用?Go?語言將?JSON?解析為結構體和數組，如果解析?JSON?的嵌入對象，如何將?JSON?的自定義屬性名稱映射到結構體，如何解析非結構化的?JSON?字符串
2023-01-01
go 迭代string數組操作 go for string[]
這篇文章主要介紹了go 迭代string數組操作 go for string[]，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧
2020-12-12
Go語言range關鍵字循環(huán)時的坑
今天小編就為大家分享一篇關于Go語言range關鍵字循環(huán)時的坑，小編覺得內容挺不錯的，現在分享給大家，具有很好的參考價值，需要的朋友一起跟隨小編來看看吧
2019-03-03
Go語言依賴管理三要素示例解析
這篇文章主要介紹了Go語言依賴管理三要素及示例解析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪
2023-01-01