GoRoutines高性能同时进行多个Api调用实现

 更新时间:2023年03月03日 16:17:07   作者:janrs_com  
这篇文章主要为大家介绍了GoRoutines高性能同时进行多个Api调用实现示例,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪

正文

Golang是高效的,非常高效。这种效率在很大程度上要归功于它在处理并发性问题时的独特抽象。例如,Java将其线程映射为操作系统线程,而Go使用自己的goroutines调度器将其轻量级goroutines从操作系统线程中进一步抽象出来。简而言之,Golang在使用操作系统线程方面非常节俭;如果一个goroutine被阻塞了,Go的调度器会在它的位置上切换另一个goroutine,以尽可能地保持线程的忙碌。由于每个CPU核心处理的线程数量有限(而且产生新的线程是很昂贵的),保持这些线程的工作是一件很好的事情。

那么,我们如何使用Golang来并发地进行多个http调用呢?如果你使用过C#或现代JavaScript,你可能使用过async/await来进行多个api调用。Golang并不那么容易,但这都是以效率为名义的。Go总是至少有一个goroutine在运行,它负责运行main()。我们可以在函数调用前用关键字go催生新的例程。如果你从事过Java/C#的异步调用,那么goroutine可能会让你想起上下文的概念。[文章来源:janrs.com] Go Scheduler允许开发者制作成千上万个这种轻量级的goroutines,并为我们管理每个goroutines所花费的CPU时间。每当一个以go为前缀的函数被执行时,就会创建一个新的goroutine来运行该函数,主goroutine在生成一个新的goroutine后立即继续前进,直到它遇到一个阻塞操作符(类似于C#或Js中的await)。

原始调用

让我们从一个简单的控制台应用开始,它调用了几个GitHub配置文件,并检查连接是否成功。起初,这里没有goroutines,所有的调用都是连续进行的,效率不高。

// Auth: janrs.com
package main
import "fmt"
import "net/http"
func main() {
	links := []string{
		"https://github.com/fabpot",
		"https://github.com/andrew",
		"https://github.com/taylorotwell",
		"https://github.com/egoist",
		"https://github.com/HugoGiraudel",
	}
	checkUrls(links)
}
func checkUrls(urls []string) {
	for _, link := range urls {
		checkUrl(link)
	}
}
func checkUrl(url string) {
	_, err := http.Get(url)
	if err != nil {
		fmt.Println("We could not reach:", url)
	} else {
		fmt.Println("Success reaching the website:", url)
	}
}

高性能调用

首先,我们需要添加一个叫做通道的东西。由于在自己的goroutine中运行的Golang函数只是简单的函数,我们需要一种方法,通过它内部的goroutine可以把它们的结果告诉外部的goroutine;这就是使用通道来实现的。我们通过以下方式初始化它们: c := make(chan string) 我们能够使用<- 箭头将结果值发送到我们的通道,我们也可以使用这个箭头将通道的值分配出去。

第二,我们需要添加一个跟 踪 器,来跟踪我们应该期待多少个值从这个通道出来。这可以通过使用sync.WaitGroup.WaitGroup的类型来完成。

落实这两个想法,代码如下。

import (
	"fmt"
	"net/http"
	"sync"
)
func main() {
	links := []string{
		"https://github.com/fabpot",
		"https://github.com/andrew",
		"https://github.com/taylorotwell",
		"https://github.com/egoist",
		"https://github.com/HugoGiraudel",
	}
	checkUrls(links)
}
func checkUrls(urls []string) {
	c := make(chan string)
	var wg sync.WaitGroup
	for _, link := range urls {
		wg.Add(1)   // 这告诉wg,现在这里有一个待处理的操作。
		go checkUrl(link, c, &wg)
	}
	go func() {
		wg.Wait()	// 这将阻止Goroutine,直到WaitGroup计数器为零。#janrs.com
		close(c)    // 通道需要被关闭,否则下面的循环将永远持续下去
	}() 
    // 这个简略的循环是一个无休止的循环的语法糖,它只是在等待结果通过'c'通道进入。
	for msg := range c {
		fmt.Println(msg)
	}
}
func checkUrl(url string, c chan string, wg *sync.WaitGroup) {
	defer (*wg).Done()
	_, err := http.Get(url)
	if err != nil {
		c <- "#janrs.com#We could not reach:" + url    // 将结果输入通道
	} else {
		c <- "Success reaching the website:" + url    // 将结果输入通道
	}
}

以上就是GoRoutines高性能同时进行多个Api调用实现的详细内容,更多关于GoRoutines多个Api同时调用的资料请关注脚本之家其它相关文章!

相关文章

  • Go语言学习笔记之错误和异常详解

    Go语言学习笔记之错误和异常详解

    Go语言采用返回值的形式来返回错误,这一机制既可以让开发者真正理解错误处理的含义,也可以大大降低程序的复杂度,下面这篇文章主要给大家介绍了关于Go语言学习笔记之错误和异常的相关资料,需要的朋友可以参考下
    2022-07-07
  • GO语言协程创建使用并通过channel解决资源竞争

    GO语言协程创建使用并通过channel解决资源竞争

    这篇文章主要为大家介绍了GO语言协程创建使用并通过channel解决资源竞争,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步早日升职加薪
    2022-04-04
  • Go语言中基本数据类型的相互转换详解

    Go语言中基本数据类型的相互转换详解

    Go在不同类型的变量之间赋值时需要显示转换,不能自动转换。这篇文章主要和大家介绍了Go语言中基本数据类型的相互转换,感兴趣的小伙伴可以了解一下
    2022-10-10
  • golang中对

    golang中对"引用传递"的误解

    这篇文章主要介绍了golang中对“引用传递”的误解,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2021-06-06
  • Golang rabbitMQ生产者消费者实现示例

    Golang rabbitMQ生产者消费者实现示例

    这篇文章主要为大家介绍了Golang rabbitMQ生产者消费者实现的示例,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步早日升职加薪
    2022-04-04
  • Go语言配置数据库连接池的实现

    Go语言配置数据库连接池的实现

    本文内容我们将解释连接池背后是如何工作的,并探索如何配置数据库能改变或优化其性能。文中通过示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2021-12-12
  • 使用Golang调用摄像头并进行图像处理

    使用Golang调用摄像头并进行图像处理

    近年来,摄像头成为了我们生活中不可或缺的设备之一,从智能手机到安全监控系统,无处不在的摄像头给我们带来了便利和安全,在开发摄像头相关的应用程序时,选择一种高效和易用的编程语言是非常重要的,本文将介绍如何使用Golang调用摄像头并进行图像处理
    2023-11-11
  • Golang中 import cycle not allowed 问题的解决方法

    Golang中 import cycle not allowed 问题

    这篇文章主要介绍了Golang中 import cycle not allowed 问题的解决方法,问题从描述到解决都非常详细,需要的小伙伴可以参考一下
    2022-03-03
  • Golang实现基于时间的一次性密码TOTP

    Golang实现基于时间的一次性密码TOTP

    基于时间的一次性密码 TOTP 是 OTP 的一种实现方式,这种方法的优点是不依赖网络,因此即使在没有网络的情况下,用户也可以生成密码,下面我们就来看看如何使用golang实现一次性密码TOTP吧
    2023-11-11
  • Golang连接池的几种实现案例小结

    Golang连接池的几种实现案例小结

    这篇文章主要介绍了Golang连接池的几种实现案例小结,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-03-03

最新评论