Heim > Artikel > Backend-Entwicklung > Über die Implementierung des Golang-Kanals
Das Folgende ist eine Einführung in die Implementierung des Golang-Kanals aus der Golang-Tutorial-Kolumne. Ich hoffe, dass es für Freunde in Not hilfreich sein wird!
Kanal ist eine Kommunikationsmethode zwischen Goroutinen, die auf Sprachebene bereitgestellt wird. Kanäle können zum Übertragen von Nachrichten zwischen zwei oder mehr Goroutinen verwendet werden. Der Kanal ist eine prozessinterne Kommunikationsmethode, sodass der Prozess der Übergabe von Objekten über Kanäle mit dem Parameterübergabeverhalten beim Aufrufen von Funktionen übereinstimmt. Beispielsweise können auch Zeiger übergeben werden. Wenn eine prozessübergreifende Kommunikation erforderlich ist, wird empfohlen, zur Lösung des Problems ein verteiltes System zu verwenden, beispielsweise die Verwendung von Kommunikationsprotokollen wie Socket oder HTTP.
Der Kanal ist typbezogen, das heißt, ein Kanal kann nur einen Werttyp übergeben, und dieser Typ muss bei der Kanaldeklaration angegeben werden. Beachten Sie, dass der Kanal selbst auch ein nativer Typ in der Go-Sprache ist und denselben Status wie Typen wie Map hat, sodass der Kanal selbst nach der Definition auch durch den Kanal geleitet werden kann.
type hchan struct { qcount uint // 队列中当前数据的个数 dataqsiz uint // size of the circular queue buf unsafe.Pointer // 数据缓冲区,存放数据的环形数组 elemsize uint16 // channel中数据类型的大小(单个元素的大小) closed uint32 // 表示channel是否关闭标识位 elemtype *_type // 队列中的元素类型 sendx uint // 当前发送元素的索引 recvx uint // 当前接收元素的索引 recvq waitq // 接受等待队列,由recv行为(也就是<-ch)阻塞在channel上的goroutine队列 sendq waitq // 发送等待队列, 由send行为(也就是ch<-)阻塞在channel上的goroutine队列 //lock保护chann中的所有字段,以及在此通道上阻塞的sudoG中的几个字段。 //保持此锁时不要更改另一个G状态(特别是没准备好G),因为这可能会因堆栈收缩而死锁 lock mutex } //发送及接收队列的·1结构体 type waitq struct { first *sudog last *sudog }
3.3 Schreiben Sie den Eintrag Der Prozess ist wie folgt:
Sperren Sie die gesamte Pipeline-Struktur.
Bestätigen Sie den Schreibvorgang, warten Sie auf die Goroutine aus der Warteschlange und schreiben Sie das Element dann direkt in die Goroutine.
Wenn recvq leer ist, ermitteln Sie, ob der Puffer verfügbar ist. Kopiert, sofern verfügbar, Daten aus der aktuellen Goroutine in den Puffer. Wenn der Puffer voll ist, wird das zu schreibende Element in der aktuell ausgeführten Goroutine-Struktur gespeichert und die aktuelle Goroutine wird in sendq in die Warteschlange gestellt und von der Ausführung abgehalten.Die Sperre wird aufgehoben, wenn der Schreibvorgang abgeschlossen ist.
2.2.2 LesevorgangDas obige ist der detaillierte Inhalt vonÜber die Implementierung des Golang-Kanals. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!