脚本之家,脚本语言编程技术及教程分享平台!
分类导航

Python|VBS|Ruby|Lua|perl|VBA|Golang|PowerShell|Erlang|autoit|Dos|bat|

服务器之家 - 脚本之家 - Golang - golang goroutine顺序输出方式

golang goroutine顺序输出方式

2021-06-09 00:47浩闻城 Golang

这篇文章主要介绍了golang goroutine顺序输出方式,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧

range字符串,使用goroutine打印

因为goroutine随机执行

 

?
1
2
3
4
5
for _, v := range str {
        go func() {
            fmt.Println(string(v))
        }()
}

输出:

5

5

5

5

5

可以使用chan顺序输出

 

?
1
2
3
4
5
6
7
8
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

补充:golang goroutine顺序循环打印ABC

分别使用sync.WaitGroup和context

使用sync.WaitGroup, 可控制循环次数

 

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
package main
import (
    "fmt"
    "sync"
)
//控制循环次数
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,通过time.Sleep控制打印数量

 

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
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") // 不会输出
            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") // 不会输出
            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") // 不会输出
            return
        case <-chanC:
            fmt.Println("C")
            chanA <- struct{}{}
        }
    }
}

以上为个人经验,希望能给大家一个参考,也希望大家多多支持服务器之家。如有错误或未考虑完全的地方,望不吝赐教。

原文链接:https://blog.csdn.net/chenwenhao0304/article/details/78725692

延伸 · 阅读

精彩推荐
  • Golanggolang 通过ssh代理连接mysql的操作

    golang 通过ssh代理连接mysql的操作

    这篇文章主要介绍了golang 通过ssh代理连接mysql的操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...

    a165861639710342021-03-08
  • Golanggo日志系统logrus显示文件和行号的操作

    go日志系统logrus显示文件和行号的操作

    这篇文章主要介绍了go日志系统logrus显示文件和行号的操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...

    SmallQinYan12302021-02-02
  • GolangGolang通脉之数据类型详情

    Golang通脉之数据类型详情

    这篇文章主要介绍了Golang通脉之数据类型,在编程语言中标识符就是定义的具有某种意义的词,比如变量名、常量名、函数名等等,Go语言中标识符允许由...

    4272021-11-24
  • Golanggo语言制作端口扫描器

    go语言制作端口扫描器

    本文给大家分享的是使用go语言编写的TCP端口扫描器,可以选择IP范围,扫描的端口,以及多线程,有需要的小伙伴可以参考下。 ...

    脚本之家3642020-04-25
  • Golanggolang的httpserver优雅重启方法详解

    golang的httpserver优雅重启方法详解

    这篇文章主要给大家介绍了关于golang的httpserver优雅重启的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,...

    helight2992020-05-14
  • GolangGolang中Bit数组的实现方式

    Golang中Bit数组的实现方式

    这篇文章主要介绍了Golang中Bit数组的实现方式,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...

    天易独尊11682021-06-09
  • Golanggolang如何使用struct的tag属性的详细介绍

    golang如何使用struct的tag属性的详细介绍

    这篇文章主要介绍了golang如何使用struct的tag属性的详细介绍,从例子说起,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看...

    Go语言中文网11352020-05-21
  • Golanggolang json.Marshal 特殊html字符被转义的解决方法

    golang json.Marshal 特殊html字符被转义的解决方法

    今天小编就为大家分享一篇golang json.Marshal 特殊html字符被转义的解决方法,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧 ...

    李浩的life12792020-05-27