golang goroutine順序輸出方式
range字符串,使用goroutine打印
因?yàn)間oroutine隨機(jī)執(zhí)行
for _, v := range str {
go func() {
fmt.Println(string(v))
}()
}
輸出:
5
5
5
5
5
可以使用chan順序輸出
for _, c := range str{
ch := make(chan rune)
go func(ch <-chan rune) {
key := <-ch
fmt.Println(string(key))
}(ch)
ch <- c
}
輸出:
1
2
3
4
5
補(bǔ)充:golang goroutine順序循環(huán)打印ABC
分別使用sync.WaitGroup和context
使用sync.WaitGroup, 可控制循環(huán)次數(shù)
package main
import (
"fmt"
"sync"
)
//控制循環(huán)次數(shù)
var count = 5
func main() {
wg := sync.WaitGroup{}
chanA := make(chan struct{}, 1)
chanB := make(chan struct{}, 1)
chanC := make(chan struct{}, 1)
chanA <- struct{}{}
wg.Add(3)
go printA(&wg, chanA, chanB)
go printB(&wg, chanB, chanC)
go printC(&wg, chanC, chanA)
wg.Wait()
}
func printA(wg *sync.WaitGroup, chanA, chanB chan struct{}) {
defer wg.Done()
for i := 0; i < count; i++ {
<-chanA
fmt.Println("A")
chanB <- struct{}{}
}
}
func printB(wg *sync.WaitGroup, chanB, chanC chan struct{}) {
defer wg.Done()
for i := 0; i < count; i++ {
<-chanB
fmt.Println("B")
chanC <- struct{}{}
}
}
func printC(wg *sync.WaitGroup, chanC, chanA chan struct{}) {
defer wg.Done()
for i := 0; i < count; i++ {
<-chanC
fmt.Println("C")
chanA <- struct{}{}
}
}
使用context.WithCancel,通過(guò)time.Sleep控制打印數(shù)量
package main
import (
"context"
"fmt"
"time"
)
func main() {
chanA := make(chan struct{}, 1)
chanB := make(chan struct{}, 1)
chanC := make(chan struct{}, 1)
chanA <- struct{}{}
ctx1, cancel1 := context.WithCancel(context.Background())
ctx2, cancel2 := context.WithCancel(context.Background())
ctx3, cancel3 := context.WithCancel(context.Background())
go printA(ctx1, chanA, chanB)
go printB(ctx2, chanB, chanC)
go printC(ctx3, chanC, chanA)
time.Sleep(100 * time.Microsecond)
cancel1()
cancel2()
cancel3()
}
func printA(ctx context.Context, chanA, chanB chan struct{}) {
for {
select {
case <-ctx.Done():
fmt.Println("cancel by parent") // 不會(huì)輸出
return
case <-chanA:
fmt.Println("A")
chanB <- struct{}{}
}
}
}
func printB(ctx context.Context, chanB, chanC chan struct{}) {
for {
select {
case <-ctx.Done():
fmt.Println("cancel by parent") // 不會(huì)輸出
return
case <-chanB:
fmt.Println("B")
chanC <- struct{}{}
}
}
}
func printC(ctx context.Context, chanC, chanA chan struct{}) {
for {
select {
case <-ctx.Done():
fmt.Println("cancel by parent") // 不會(huì)輸出
return
case <-chanC:
fmt.Println("C")
chanA <- struct{}{}
}
}
}
以上為個(gè)人經(jīng)驗(yàn),希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教。
- Go語(yǔ)言輕量級(jí)線程Goroutine用法實(shí)例
- go獲取協(xié)程(goroutine)號(hào)的實(shí)例
- go中控制goroutine數(shù)量的方法
- Golang 探索對(duì)Goroutine的控制方法(詳解)
- Go 防止 goroutine 泄露的方法
- 淺析Golang中的協(xié)程(goroutine)
- Go語(yǔ)言死鎖與goroutine泄露問(wèn)題的解決
- Go語(yǔ)言CSP并發(fā)模型goroutine及channel底層實(shí)現(xiàn)原理
- Go語(yǔ)言之使用pprof工具查找goroutine(協(xié)程)泄漏
- go語(yǔ)言面試之Goroutine詳解
相關(guān)文章
Golang小數(shù)操作指南之判斷小數(shù)點(diǎn)位數(shù)與四舍五入
這篇文章主要給大家介紹了關(guān)于Golang小數(shù)操作指南之判斷小數(shù)點(diǎn)位數(shù)與四舍五入的相關(guān)資料,文中通過(guò)實(shí)例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2022-03-03
Go語(yǔ)言實(shí)現(xiàn)JSON解析的神器詳解
php轉(zhuǎn)go是大趨勢(shì),越來(lái)越多公司的php服務(wù)都在用go進(jìn)行重構(gòu),重構(gòu)過(guò)程中,會(huì)發(fā)現(xiàn)php的json解析操作是真的香。本文和大家分享了一個(gè)Go語(yǔ)言實(shí)現(xiàn)JSON解析的神器,希望對(duì)大家有所幫助2023-01-01
淺析Go語(yǔ)言bitset的實(shí)現(xiàn)原理
bitset包是一個(gè)將非負(fù)整數(shù)映射到布爾值的位的集合,這篇文章主要通過(guò)開(kāi)源包bitset來(lái)為大家分析一下位集合的設(shè)計(jì)和實(shí)現(xiàn),感興趣的可以學(xué)習(xí)一下2023-08-08
利用Golang解析json數(shù)據(jù)的方法示例
Go提供了原生的JSON庫(kù),并且與語(yǔ)言本身有效的集成在了一起。下面這篇文章將給大家介紹關(guān)于利用Golang解析json數(shù)據(jù)的方法,文中給出了詳細(xì)的示例代碼供大家參考學(xué)習(xí),需要的朋友們下面跟著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧。2017-07-07
golang常用庫(kù)之字段參數(shù)驗(yàn)證庫(kù)-validator使用詳解
這篇文章主要介紹了golang常用庫(kù):字段參數(shù)驗(yàn)證庫(kù)-validator使用,本文給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借價(jià)值,需要的朋友可以參考下2020-10-10
Golang channel關(guān)閉的實(shí)現(xiàn)示例
channel關(guān)閉不當(dāng)或不關(guān)閉會(huì)引發(fā)很多問(wèn)題,本文主要介紹了Golang channel關(guān)閉的實(shí)現(xiàn)示例,具有一定的參考價(jià)值,感興趣的可以了解一下2024-01-01

