21-Go语言并发编程 - Go语言中文社区

21-Go语言并发编程


并发编程基本概念

  • 什么是串行?
    • 在计算机中, 同一时刻, 只能有一条指令, 在一个CPU上执行, 后面的指令
      必须等到前面指令执行完才能执行, 就是串行
  • 什么是并行?
    • 在计算机中, 同一时刻, 有多条指令, 在多个CPU上执行, 就是并行
    • 并行的速度优于串行
  • 什么是并发?
    • 在计算机中, 同一时刻, 只能有一条指令, 在一个CPU上执行, 但是CPU会
      快速的在多条指令之间轮询执行就是并发
  • 总结
    • 多线程程序在单核上运行, 就是并发
    • 多线程程序在多核上运行,就是并行

  • 什么是程序?

    • 程序是指编译之后存储在磁盘上的一个二进制文件, 会占用磁盘空间,
      但不会占用系统资源
  • 什么是进程?
    +进程是指程序在操作系统中的一次执行过程, 是系统进行资源分配和调
    度的基本单位

    • 例如:
      • 启动记事本这个程序, 在系统中就会创建一个记事本进程
      • 再次启动记事本这个程序, 又会在系统中创建一个记事本进程
    • 程序和进程的关系是1:N, 所以多个进程的空间是独立的
  • 什么是线程?

    • 线程是指进程中的一个执行实例, 是程序执行的最小单元, 它是比进程
      更小的能独立运行的基本单位
    • 一个进程中至少有一个线程, 这个线程我们称之为主线程
    • 一个进程中除了主线程以外, 我们还可以创建和销毁多个线程


  • 什么是协程?

    • 协程是一种用户态的轻量级线程,又称微线程,英文名Coroutine
    • 与传统的系统级别进程和线程相比, 协程最大的优势在于"轻量级". 可
      以轻松创建上万个不会导致系统资源衰竭. 而线程和进程通常很难超过
      1万个.这也是协程称之为"轻量级线程"的原因
    • 一个线程中可以有任意多个协程, 但某一时刻只能有一个协程在运行,
      多个协程分享所在线程分配到的计算机资源
    • 在协程中, 调用一个任务就像调用一个函数一样, 消耗系统资源极少, 但能达到进程、线程相同的并发效果

Go语言并发

  • go并发案例
package main

import "fmt"

func sing()  {
    for i := 0 ;i < 100 ; i++  {
        fmt.Println("我在唱歌")
    }
}

func dance()  {
    for i := 0 ;i < 100 ; i++  {
        fmt.Println("-----我在跳舞")
    }
}
func main() {
    // 需求: 边唱歌边跳舞
    // 既然要边唱歌边跳舞, 是不是意味着执行singer函数的时候, 也要执行dance函数
    go sing()
    go dance()
    // 注意点: 开启协程之后, 主线程(进程)不能结束
    // 一旦主线程结束了, 那么程序就关闭了, 那么进程就不见了, 那么协程就不会被执行了
    for{
        ;
    }
}
  • runtime包中常用的函数
    • Gosched:使当前go程放弃处理器,以让其它go程运行
    package main
    import (
        "fmt"
        "runtime"
    )
    
      func sing()  {
        for i:=0; i< 10; i++{
            fmt.Println("我在唱歌")
            // Gosched使当前go程放弃处理器,以让其它go程运行。
            // 它不会挂起当前go程,因此当前go程未来会恢复执行
            runtime.Gosched()
        }
    }
      func dance() {
        for i:=0; i< 10; i++{
            fmt.Println("我在跳舞---")
            runtime.Gosched()
        }
    }
    
      func main() {
    
        go sing()
        go dance()
        for{
            ;
        }
    }
    
    • Goexit: 终止调用它的go程, 其它go程不会受影响
    package main
    
    import (
      "fmt"
      "runtime"
    )
    
    func sing()  {
      for i := 0;i < 50 ; i++  {
          fmt.Println("我在唱歌", i)
          if i == 5 {
              // 终止调用它的go程。其它go程不会受影响
              runtime.Goexit()
          }
      }
    }
    
    func dance()  {
      for i := 0;i < 50 ; i++  {
          fmt.Println("-----我在跳舞", i)
      }
    }
    func main() {
      //开启go程
      go dance()
      go sing()
    
    
    for  {
          ;
      }
    }
    
版权声明:本文来源简书,感谢博主原创文章,遵循 CC 4.0 by-sa 版权协议,转载请附上原文出处链接和本声明。
原文链接:https://www.jianshu.com/p/b71581ec64ff
站方申明:本站部分内容来自社区用户分享,若涉及侵权,请联系站方删除。
  • 发表于 2020-01-09 21:56:30
  • 阅读 ( 680 )
  • 分类:Go

0 条评论

请先 登录 后评论

官方社群

GO教程

猜你喜欢