浅析Go语言中的同步与异步处理

 更新时间:2023年11月07日 09:23:19   作者:洛天枫  
在开发过程中,当需要同时处理多个操作时,开发者经常面临同步和异步两种处理方式的选择,下面小编就来和大家详细介绍一下Go语言中的同步与异步处理吧

同步处理

在同步处理方式中,任务按顺序一个接一个地执行。每个任务必须在下一个任务开始之前完成。这意味着如果某个任务需要花费大量时间来完成,它可能会阻塞后续任务的执行,导致潜在的性能瓶颈。

一个简单的现实生活中的例子是两个人在喝啤酒时进行对话。一个人说一些话并提问,另一个人根据情况回应,然后反过来...

在下面的示例中,每个URL调用必须完成其整个请求-响应周期并提供响应或错误,以便可以进行后续的URL调用。

package main

import (
	"fmt"
	"net/http"
)

func makeUrlCall(url string) {
	_, err := http.Get(url)
	if err != nil {
		fmt.Println("Got error in connecting to url: ", url)
	}

	fmt.Println("Got the response from our url: ", url)
}

func main() {

	fmt.Println("Welcome here !!")
	fmt.Println()

	//slice of urls
	urlSlice := []string{
		"https://www.baidu.com",
		"https://www.csdn.net",
		"https://www.runoob.com",
	}

	for idx, url := range urlSlice {
		fmt.Println("Calling url on index: ", idx)
		makeUrlCall(url)
	}

	fmt.Println()
	fmt.Println("End of sync processing !!")

	return
}

输出:

Welcome here !!

Calling url on index:  0
Got the response from our url:  https://www.baidu.com
Calling url on index:  1
Got the response from our url:  https://www.csdn.net
Calling url on index:  2
Got the response from our url:  https://www.runoob.com

End of sync processing !!

异步处理

在异步处理方式中,任务独立并同时执行。这意味着程序在一个任务完成之前不会等待它继续下一个任务。在Golang中,可以使用Goroutines和Go运行时来实现异步编程。

一个简单的现实生活中的例子是去汽车修理店。一旦工程师处理完其他任务,他们会处理你的任务。在此期间,你可以做其他重要的事情,直到你的汽车被取走并修好。

在下面的示例中,每个URL调用将通过goroutine在自己的线程中进行,并根据需要处理响应。

package main

import (
	"fmt"
	"net/http"
	"sync"
)

func makeUrlCall(url string) {
	_, err := http.Get(url)
	if err != nil {
		fmt.Println("Got error in connecting to url: ", url)
	}

	fmt.Println("Got the response from our url: ", url)
}

func main() {
	fmt.Println("Welcome here !!")
	fmt.Println()

	//slice of urls
	urlSlice := []string{
		"https://www.baidu.com",
		"https://www.csdn.net",
		"https://www.runoob.com",
	}

	var wg sync.WaitGroup

	for _, u := range urlSlice {
		wg.Add(1)
		//all the url's to get error/response are called in their own separate thread via goroutines
		go func(url string) {
			defer wg.Done()

			makeUrlCall(url)
		}(u)
	}

	wg.Wait()

	fmt.Println()
	fmt.Println("End of sync processing !!")

	return
}

输出:

Welcome here !!

Got the response from our url:  https://www.baidu.com
Got the response from our url:  https://www.runoob.com
Got the response from our url:  https://www.csdn.net

End of sync processing !!

如果我们在切片中添加更多的URL并进行更多的HTTP get请求,比较两种方式的性能。

到此这篇关于浅析Go语言中的同步与异步处理的文章就介绍到这了,更多相关Go同步与异步处理内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • Go集成swagger实现在线接口文档的教程指南

    Go集成swagger实现在线接口文档的教程指南

    wagger是一个用于设计,构建和文档化API的开源框架,在Go语言中,Swagger可以帮助后端开发人员快速创建和定义RESTful API,并提供自动生成接口文档的功能,所以本文给大家介绍了Go集成swagger实现在线接口文档的方法,需要的朋友可以参考下
    2024-11-11
  • go 字符串修改的操作代码

    go 字符串修改的操作代码

    这篇文章主要介绍了go 字符串修改,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2022-06-06
  • golang操作mongodb的方法

    golang操作mongodb的方法

    这篇文章主要介绍了golang操作mongodb的方法,涉及Go语言操作mongodb的连接、读取及显示的方法,具有一定参考借鉴价值,需要的朋友可以参考下
    2015-02-02
  • prometheus client_go为应用程序自定义监控指标

    prometheus client_go为应用程序自定义监控指标

    这篇文章主要为大家介绍了prometheus client_go为应用程序自定义监控指标详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-02-02
  • go实现限流功能示例

    go实现限流功能示例

    这篇文章主要为大家介绍了go实现限流功能示例详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-08-08
  • Go语言Elasticsearch数据清理工具思路详解

    Go语言Elasticsearch数据清理工具思路详解

    这篇文章主要介绍了Go语言Elasticsearch数据清理工具思路详解,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2021-10-10
  • Golang实现自定义recovery中间件

    Golang实现自定义recovery中间件

    在 Golang 的 Web 项目中,自定义 recovery 中间件是一种常见的做法,用于捕获并处理应用程序的运行时错误,下面我们就来看看具体如何实现吧
    2023-09-09
  • Go语言字符串常见操作的使用汇总

    Go语言字符串常见操作的使用汇总

    这篇文章主要为大家总结了Go语言中常见的几种字符串操作,例如:位置索引、替换、统计次数等,文中的示例代码讲解详细,感兴趣的可以了解一下
    2022-04-04
  • Golang查询MongoDB的实现步骤

    Golang查询MongoDB的实现步骤

    本文介绍了如何使用Golang操作MongoDB数据库,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2025-12-12
  • gorm RowsAffected()返回0的问题及解决

    gorm RowsAffected()返回0的问题及解决

    在gorm中,`RowsAffected()`方法用于获取更新操作的受影响行数,如果在执行更新操作后立即调用`RowsAffected()`,可能会得到0,因为该方法在内部已经执行了数据库操作并更新了数据,正确的使用方法是在执行更新操作后,通过返回的`db`对象来获取受影响的行数
    2025-12-12

最新评论