go 多进程与非缓冲通道

简介: go 多进程与非缓冲通道

go实现了真正的多线程, 既然是真正地多线程,那么什么叫做虚假的多线程

我们知道 python 实现了虚假的线程: 当虚假的线程共享同一个cpu时,大家采用时间分片去执行,但是当 某个线程发出 阻塞信息的时候, 比如 输入函数 ,整个程序就会被挂起 ,导致其他线程也无法被执行


提醒:

chan1 := make(chan int ,[ size])


当没有设定 chan 的 size 的时候,默认 0

什么叫做chan的size 当 size =0称为 非缓冲通道

只有 chan1 <- 和 <- chan1 配对时 才可以继续执行

否则进程阻塞等待


但是在缓冲通道中, 只有 chan1 中 数量为0 时

<- chan1 操作才会被阻塞,但是chan <-不会被阻塞


或者 chan1 数量 = size chan1 <- 会被阻塞,但是 <- chan1 不会被阻塞

来看看go 是否实现了真正的不会被阻塞的线程

func gogetinput(goid int, chan1 chan int) string {
    input1 := ""
    fmt.Scanln(&input1)
    fmt.Println(goid, " 输入是", input1)
    chan1 <- 1
    return input1
}


为什么要创建chan1 因为 go 中 默认不会等待进程的结束

func main() {
    chan1 := make(chan int)
    go gogetinput(1, chan1)
    fmt.Print("没有被阻塞")
    <-chan1
}


输出结果

lmk@pop-os:~/gocode/src/studycolly$ go run usegoprocess.go

没有被阻塞 \nasasas

1 输入是 \nasasas


很明显根据顺序执行的逻辑,应该是先接受 用户的输入 然后进行 打印 没有被阻塞

但是用户输入属于一个阻塞进程,所以无法执行,直到用户输入


但是如果 main 中的 <- chan1 改为 chan1<- 1 ,

gogetinput中的 chan1<-1 改为 <-chan1


则主进程不会等待子进程的结束,我们也就无法看到效果了

Go 很多线程同步 wg

//定义同步变量
var wg sync.WaitGroup
func main(){
for i:=1;i<10;i++{
    wg.Add(1)
    go func(){
            print(i)
            wg.Done()
        }()
    }
//等待所有协程完成
wg.Wait()
}


相关文章
|
2天前
|
供应链 Go
掌握Go语言:利用Go语言的单向通道和select语句,提升库存管理效率(21)
掌握Go语言:利用Go语言的单向通道和select语句,提升库存管理效率(21)
|
2天前
|
安全 Go
掌握Go语言:Go语言通道,并发编程的利器与应用实例(20)
掌握Go语言:Go语言通道,并发编程的利器与应用实例(20)
|
2天前
|
安全 Go 数据处理
Go语言CSP编程实战:通道通信技术
Go语言CSP编程实战:通道通信技术
51 0
|
2天前
|
Go
通道多路复用:Go语言并发编程的黄金法则
通道多路复用:Go语言并发编程的黄金法则
42 0
|
2天前
|
安全 Go
Go语言并发新特性:单向通道的读写控制
Go语言并发新特性:单向通道的读写控制
44 0
|
2天前
|
存储 Go
|
2天前
|
Go 调度 开发者
Go语言并发基础:轻量级线程与通道通信
【2月更文挑战第6天】本文介绍了Go语言在并发编程方面的基础知识和核心概念。我们将深入探讨goroutine(轻量级线程)的创建与调度,以及如何利用channel进行goroutine间的通信与同步。此外,还将简要提及select语句的使用,并解释其在处理多个channel操作时的优势。
|
2天前
|
安全 Go
无缓冲通道:Go语言同步之道
无缓冲通道:Go语言同步之道
39 0
|
2天前
|
Go 开发者
Go语言带缓冲通道:异步通信的艺术
Go语言带缓冲通道:异步通信的艺术
26 0
|
2天前
|
安全 Go
Go语言并发打印:通过通道实现协同输出
Go语言并发打印:通过通道实现协同输出
43 0