go中阻塞以及非阻塞操作实现(goroutine和main goroutine)-kb88凯时官网登录

来自:网络
时间:2024-08-28
阅读:
免费资源网,https://freexyz.cn/

main函数本身也是一个goroutine。

在go语言中,main函数是程序的入口点。当程序启动时,go运行时会创建一个名为main的goroutine,并在其中执行main函数的代码。这个main goroutine 是程序中的主要执行线程,它负责执行main函数中的指令和操作。

与其他用户创建的goroutine类似,main goroutine 也是并发执行的。它可以与其他goroutine同时执行,利用多核处理器的并行性。

main goroutine 的生命周期与程序的生命周期相同。当main函数执行完成或显式调用os.exit函数终止程序时,main goroutine 会随之结束。其他正在执行的goroutine也会被终止,程序会退出。

因此,我们可以把main函数看作是程序中的一个特殊的goroutine,它是程序的入口和控制中心。通过在main函数内部启动其他goroutine,我们可以实现多个任务的并发执行,充分利用go语言的并发能力。

go语言中,阻塞和非阻塞是用来描述对某个操作的等待行为的。

阻塞(blocking):当执行一个操作时,如果该操作无法立即完成,程序会被阻塞,即暂停执行,直到该操作完成或满足某个条件。在阻塞状态下,程序无法继续执行其他任务,直到阻塞的操作完成。例如,当我们读取一个通道(channel)时,如果通道中没有可读取的数据,读取操作将会阻塞,直到有数据可读。

package main
import (
	"fmt"
	"time"
)
func main() {
	ch := make(chan int) // 创建一个通道
	go func() {
		time.sleep(2 * time.second)
		ch <- 42 // 向通道发送数据
	}()
	fmt.println("waiting for data...")
	data := <-ch // 从通道接收数据,如果通道中没有数据,该行会阻塞等待
	fmt.println("received data:", data)
}

在上述示例中,我们创建了一个通道ch,并在一个goroutine中等待2秒后向通道发送了数据(你可以尝试修改time.sleep函数后的数字,分别运行来看效果)。在主goroutine中,我们尝试从通道ch中接收数据。由于通道中没有数据可用,接收操作会被阻塞,直到数据发送到通道为止。

非阻塞(non-blocking):当执行一个操作时,如果该操作无法立即完成,程序不会被阻塞,而是立即返回,不管操作是否成功或者完成。通过使用非阻塞操作,程序可以继续执行其他任务,而不需要等待阻塞的操作完成。例如,使用非阻塞的方式读取通道时,如果通道中没有数据可读,读取操作会立即返回一个错误或默认值。

package main
import (
	"fmt"
	"time"
)
func main() {
	ch := make(chan int) // 创建一个通道
	go func() {
		time.sleep(2 * time.second)
		ch <- 42 // 向通道发送数据
	}()
	fmt.println("waiting for data...")
	select {
	case data := <-ch: // 尝试从通道接收数据
		fmt.println("received data:", data)
	default:
		fmt.println("no data available")
	}
}

在上述示例中,我们使用select语句来尝试从通道ch中接收数据。如果通道中没有可用的数据,select语句会立即执行default分支,输出"no data available",而不会阻塞等待。这样,程序可以继续执行其他任务,而不需要等待数据的到达。

阻塞和非阻塞是用来描述对于某个操作的等待行为的概念。阻塞表示当一个操作无法立即完成时,程序会暂停执行,直到操作完成。非阻塞表示当一个操作无法立即完成时,程序会立即返回,继续执行其他任务。在go语言中,通常使用通道操作来展示阻塞和非阻塞的概念。

免费资源网,https://freexyz.cn/
返回顶部
顶部
网站地图