草庐IT

Spring之异步任务@Async详解分析

全部标签

Go 库 - golang 的 async.auto

在Nodejs中,我们有async.auto(http://caolan.github.io/async/docs.html#.auto),它通过拓扑排序自动管理扇出顺序。Go中是否有类似的库来管理您的请求顺序 最佳答案 你可以试试这个:https://github.com/kamildrazkiewicz/go-flow它基于channel排空(async.auto使用拓扑排序)但它的工作方式类似。 关于Go库-golang的async.auto,我们在StackOverflow上找到

http - 异步 http 请求处理

我正在尝试以这种方式异步处理Go中的HTTP请求:我将处理函数传递给HTTP服务器在处理程序中,我将HttpRequest/HttpResponse对象存储在slice或映射中当从处理函数返回时——响应不会返回给客户端,但连接保持打开状态当从另一个来源接收到“一些”异步输入时,我从内存中获取相关的HttpRequest/HttpResponse对象,写入响应并关闭连接。我的目标与Java中的Jetty-Continuation非常相似。如何在Go语言中实现这样的行为? 最佳答案 在Go中不需要这种行为。JavaHTTP服务器使用线程

go - 如何分析多个 goroutine

我想分析一个用Go编写的服务器。我正在使用“net/http/pprof”,但默认行为完全没用,因为它似乎只分析运行服务器的goroutine,该服务器为分析数据提供服务。 最佳答案 我的服务器被围攻了。对于1000个并发用户,我得到了我想要的分析数据。 关于go-如何分析多个goroutine,我们在StackOverflow上找到一个类似的问题: https://stackoverflow.com/questions/34710112/

go - 无法下载 Go with Visual Studio 所需的分析工具

我是一个完全的新手,刚刚开始了Go的初学者类(class),但在安装使其工作所需的所有位的第一个障碍上失败了,如果这是一个愚蠢的问题,我深表歉意。我已经安装了Go、Git和VisualStudio...在第一次安装VisualStudio之后,我试图为Go安装12个分析工具,但每次我尝试都失败。通常与“权限被拒绝”错误有关。错误信息如下。任何想法为什么?Installing12toolsat/Documents/go/bingocodegopkgsgo-outlinego-symbolsgurugorenamedlvgocode-gomodgodefgodef-gomodgoretur

function - 检查 Go 中首先完成的任务是什么?

我想知道是否有可能同时运行一个任务(比如一个函数,具有不同的参数,例如intmultipliers),并且一个变量接收第一个任务的返回值完成。有人知道吗?:D 最佳答案 这是一个基本示例,尽管互联网上还有很多其他示例...https://play.golang.org/p/R__dk09Ymhpackagemainimport"fmt"import"time"funcmain(){a:=make(chanbool)b:=make(chanbool)goMySleep(5000,a)goMySleep(1000,b)select{ca

unit-testing - 如何确保所有异步函数在执行 defer 之前运行

我有一个函数说Myfunction(){x.RunAsync()//AsyncFunctioncall}我必须为Myfunction()编写一个测试用例。我正在为此使用go-mock。还有mockedx。Test_MyFunction(){mockCtrl:=gomock.NewController(t)defermockCtrl.Finish()//EXPECT()calltostubRunAsync()}现在的问题是我的测试运行成功,但不知何故最后它panic地说,对mockX.RunAsync()的调用丢失了。我认为这是因为在我的RunAsync被stub之前正在执行延迟。如何确

go - 域事件的可靠异步处理

在并发系统中,域事件通常是异步处理的。在Go中,可以通过channels实现一种简单的异步事件处理方法,但问题是如果处理事件发生了一些不好的事情,或者更糟糕的是,对于整个程序来说,事件将会丢失.如何在Go程序中正确处理异步领域事件,即:当事件处理程序失败时,不应从事件队列中清除该事件,以便稍后妥善处理。如果整个程序宕机,则必须恢复事件并进行相应处理。 最佳答案 第一个相对容易;您可以在worker中有一个错误处理程序,在发生错误时将工作重新排队。第二个更难;你的选择是a)推出你自己的防弹机制,将事件写入磁盘并在它们以线程安全的方式完

go - Go 中令人尴尬的并行任务的惯用解决方案是什么?

我目前正在关注以下代码的增强版本:funcembarrassing(data[]string)[]string{resultChan:=make(chanstring)varwaitGroupsync.WaitGroupfor_,item:=rangedata{waitGroup.Add(1)gofunc(itemstring){deferwaitGroup.Done()resultChan这让我大吃一惊。所有这一切都可以用其他语言表达为results=parallelMap(data,doWork)即使在Go中不能这么容易地完成,难道没有比上述更好的方法吗?

java - 用于故障排除的指标模式分析

当我解决一些站点问题时,我需要检查许多指标,例如CPU、内存、应用程序指标等。通常,我想自动了解以下项目(无需人工一一检查所有指标):在此期间有多少指标出现峰值。如果指标X与指标Y具有相同的模式如果度量X具有一些周期性特征。对于第1项和第2项,我想我可以通过计算一些变化率来得到它。对于第3项,我目前还不知道。我的问题是:我们是否已经有一些可以在这里使用的库,语言(Go、Java、Python都可以)。您对需求3有什么建议吗?=====更多背景:我已经设置了Prometheus(监控系统),但我的问题是我想自动分析这些指标。例如:用户输入:这里有1000个时间序列数据,我在时间1到时间2

performance - Go 中异步 TCP 服务器的正确结构是什么?

我有一个客户端发送大约50万个请求(消息)/分钟。每条消息大约为200字节到2KB。每条消息都将保存在数据库中(例如Couchbase)。根据核心、端口、连接和goroutines来构建GoTCP服务器以处理此负载的正确方法是什么? 最佳答案 正如JimB所提到的,TCP服务器应该不难建立并开始针对您的需求进行基准测试。一个简单的布局是等待传入的TCP连接,然后执行一个go例程来处理它。在那个goroutine中,你可以放置任何你想要的阻塞代码,在本例中是写入数据库。这是一个简单示例的链接:Simpleexample一旦你开始工作,