Go 永久阻塞的方法

go 刘宇帅 6年前 阅读量: 2213

我们经常需要让主 goroutine 处于永久阻塞状态,这样其他的 gorotine 就可以一直运行处理信息。下面我总结了几种可以实现永久阻塞的方法,其中大部分实例代码无法直接运行,因为 Go runtime 会检查所有 goroutine 并提示所有的 goroutine 都处于 deadlock,在实际使用中,我们添加具体的业务 goroutien 就可以运行了。

死循环

说到永久阻塞第一个想到的应该就是死循环。

package main

func main() {
    for {}
}

死循环虽然可以实现永久阻塞,但是对于 Go 而言,for 死循环所在的 goroutine 还是一直处于“运行”状态,所以死循环会消耗一定的 CPU,不推荐使用。

sync.Mutex

使用锁,我们可以对已经锁了的锁,再次申请锁。

package main

import (
    "sync"
)

func main() {
    var lock sync.Mutex
    lock.Lock()
    lock.Lock()
}

该实例代码会提示死锁。不推荐使用。

sync.WaitGroup

一个不会减少的 WaitGroup 就实现了永久阻塞

 package main

import "sync"

func main() {
    var wg sync.WaitGroup
    wg.Add(1)
    wg.Wait()
}

该实例代码会提示死锁。

select

空 select 会一直阻塞

package main

func main() {
    select{}
}

该实例代码会提示死锁。

channel

使用 channel 本身会一直阻塞直到接收到信息。

package main

func main() {
    c := make(chan struct{})
    <-c
}

nil channel 会永久阻塞

package main

func main() {
    var c chan struct{}
    <-c
}

os.Signal

使用信号量配合 channel 实现永久阻塞

package main

import (
    "os"
    "os/signal"
    "syscall"
)

func main() {
    sig := make(chan os.Signal, 1)
    signal.Notify(sig, syscall.SIGUSR2)
    <-sig
}

这样只有当我们传递 SIGUSR2 信号(kill -USR2 [pid])的时候阻塞才会停止。sig 要设置为可缓冲的 channel,或者可能如果 goroutine 没有准备好信号会被丢弃。

提示

功能待开通!


暂无评论~