首先就是進(jìn)程、線程、協(xié)程講解老三樣。

進(jìn)程: 本質(zhì)上是一個(gè)獨(dú)立執(zhí)行的程序，進(jìn)程是操作系統(tǒng)進(jìn)行資源分配和調(diào)度的基本概念，操作系統(tǒng)進(jìn)行資源分配和調(diào)度的一個(gè)獨(dú)立單位。

線程: 是操作系統(tǒng)能夠進(jìn)行運(yùn)算調(diào)度的最小單位。它被包含在進(jìn)程之中，是進(jìn)程中的實(shí)際運(yùn)作單位。一個(gè)進(jìn)程中可以并發(fā)多個(gè)線程，每條線程執(zhí)行不同的任務(wù)，切換受系統(tǒng)控制。

協(xié)程:  又稱為微線程，是一種用戶態(tài)的輕量級(jí)線程，協(xié)程不像線程和進(jìn)程需要進(jìn)行系統(tǒng)內(nèi)核上的上下文切換，協(xié)程的上下文切換是由用戶自己決定的，有自己的上下文，所以說是輕量級(jí)的線程，也稱之為用戶級(jí)別的線程就叫協(xié)程，一個(gè)線程可以多個(gè)協(xié)程,線程進(jìn)程都是同步機(jī)制，而協(xié)程則是異步Java的原生語法中并沒有實(shí)現(xiàn)協(xié)程,目前python、Lua和GO等語言支持。

關(guān)系：一個(gè)進(jìn)程可以有多個(gè)線程，它允許計(jì)算機(jī)同時(shí)運(yùn)行兩個(gè)或多個(gè)程序。線程是進(jìn)程的最小執(zhí)行單位，CPU
的調(diào)度切換的是進(jìn)程和線程，進(jìn)程和線程多了之后調(diào)度會(huì)消耗大量的CPU，CPU上真正運(yùn)行的是線程，線程可
以對(duì)應(yīng)多個(gè)協(xié)程。

MPG模型

Go協(xié)程中有三個(gè)關(guān)鍵實(shí)體：

• M(machine): 工作線程，由操作系統(tǒng)調(diào)度。應(yīng)該就是通常所說的內(nèi)核線程。
• P(processor): 處理器（非CPU），代表著運(yùn)行Go代碼的必要資源，以及調(diào)度goroutine的能力。個(gè)人覺得可以當(dāng)作擁有自主調(diào)度權(quán)的算法模塊，用于工作竊取（work stealing）。
• G(gooutine): Go協(xié)程，輕量級(jí)用戶線程。主要包含執(zhí)行棧和調(diào)度管理器。這里的調(diào)度管理器指的是，統(tǒng)一并管理調(diào)度資源，等待被調(diào)度。

Go協(xié)程的特點(diǎn)

（1）有獨(dú)立的棧空間

（2）共享程序的堆空間

（3）協(xié)程調(diào)度由用戶控制（進(jìn)程的控制是有操作系統(tǒng)控制，程序員不能控制）

（4）協(xié)程是輕量級(jí)的線程

通道的特性

Go語言中的通道（channel）是一種特殊的類型。在任何時(shí)候，同時(shí)只能有一個(gè) goroutine 訪問通道進(jìn)行發(fā)送和獲取數(shù)據(jù)。goroutine 間通過通道就可以通信。

通道像一個(gè)傳送帶或者隊(duì)列，總是遵循先入先出（First In First Out）的規(guī)則，保證收發(fā)數(shù)據(jù)的順序。

當(dāng)然協(xié)程的輕量性并不代表可以隨意濫用，畢竟還是存在資源的消耗。本文主要講解go的協(xié)程池的實(shí)現(xiàn)原理，利用select來監(jiān)聽任務(wù)?！敬a僅用作實(shí)現(xiàn)原理，想更優(yōu)雅可以在該原理基礎(chǔ)上自行優(yōu)化】

廢話不多說直接上代碼！

package main
 
import (
	"strconv"
	"time"
)
 
/**
協(xié)程池
 */
//全局任務(wù)管道地址數(shù)組
var arr []*chan func()
//啟動(dòng)任務(wù)數(shù)量
var num = 10
//默認(rèn)管道下標(biāo)0
var index = 0
//任務(wù)開關(guān)
var static = false
func run(f *chan func()){
	println("等待咯")
	for static == true {
		select {
			case fu:=<-*f :     // 檢測有沒有數(shù)據(jù)可讀
				// 一旦成功讀取到數(shù)據(jù)，則進(jìn)行該case處理語句
				fu()
			default:
				//println(f)
				//println("無數(shù)據(jù)")
		}
		time.Sleep(time.Duration(1)*time.Second)
	}
}
//啟動(dòng)任務(wù)函數(shù)
func Start(){
	static = true
	for i:=0;i<num;i++ {
		//make一個(gè)管道地址
		c:=make(chan func(),1)
		println(&c)
		//將該地址存入全局?jǐn)?shù)組中
		arr = append(arr,&c)
		//地址傳入任務(wù)函數(shù)
		go run(&c)
	}
}
//插入任務(wù)
func add(str string) {
	//此處不是很優(yōu)雅，自行優(yōu)化實(shí)現(xiàn)。
	if(index >= num-1){
		index = 0
	}else{
		index++
	}
	//向地址管道傳入函數(shù)
	*arr[index] <- func() {
		println(str)
	}
}
//停止任務(wù)
func stop()  {
	//終止任務(wù)for
	static = false
	//清空管道數(shù)組
	arr = []*chan func(){}
}
func main() {
	Start()
	println("開始執(zhí)行寫入管道")
	println(len(arr))
	for i:=0;i<1000000000;i++ {
		add("傳入的i:"+strconv.Itoa(i))
	}
	time.Sleep(time.Duration(2)*time.Second)
	stop()
	//time.Sleep(time.Duration(100)*time.Second)
}

原理很簡單，就是合理使用select來監(jiān)聽管道是否有數(shù)據(jù)，協(xié)程池的實(shí)現(xiàn)就是合理利用管道?？梢愿鶕?jù)該思路來進(jìn)行優(yōu)化封裝一個(gè)屬于自己的協(xié)程池哦~

到此這篇關(guān)于Go簡單實(shí)現(xiàn)協(xié)程池的實(shí)現(xiàn)示例的文章就介紹到這了,更多相關(guān)Go 協(xié)程池內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論