草庐IT

atomic_is_lock_free

全部标签

go - 为什么runtime.GC中没有调用atomic.Load加载gcphase?

我想知道为什么gcphase不受atomic.Load保护:n:=atomic.Load(&work.cycles)ifgcphase==_GCmark{//Waituntilsweeptermination,mark,andmark//terminationofcycleNcomplete.gp.schedlink=work.sweepWaiters.headwork.sweepWaiters.head.set(gp)goparkunlock(&work.sweepWaiters.lock,"waitforGCcycle",traceEvGoBlock,1)}else{//We're

go - 有没有办法使用 atomic.AddUint64 重置计数器递增?

我正在为并发Go应用程序实现全局计数器。我的用例是计数器应在x秒后重置并写入数据库。我试过使用互斥量(我可以使用它来重置计数器)此外,当我增加计数器时,我也会记录一些东西。我发现在应用程序运行大约8-9小时后,记录的行数和计数器值不匹配(互斥版本)计数器值总是更少。我还没有找到造成这种情况的原因。我按以下方式使用互斥量func(s*Metrics)AddQps(){s.qpsMu.Lock()s.qps++s.qpsMu.Unlock()}Andtheflushingofmetricsisdoneasfollows.for{ticker:=time.NewTicker(time.Dur

docker - 去构建 : build output "api" already exists and is a directory

我正在尝试使用CompileDaemon热重载使用Docker的go项目。我的文件夹结构如下所示my-api-server-main.go-Dockerfile-docker-compose.yml-Makefile这是我得到的错误:gobuildgithub.com/firstApi/test-platform/lib/my-api/server:构建输出“server”已经存在并且是一个目录这是我的dockerfile的样子FROMgolang:1.12-stretchENVGO111MODULE=onWORKDIR/go/srcCOPYgo.mod.COPYgo.sum.RUNg

gorename : What is a 'DO NOT EDIT' marker?

我正在使用vscode并尝试重命名变量名称。它没有说:Renamefailed:gorename:cannotrenameidentifiersingeneratedfilecontainingDONOTEDITmarker:/home/adam/go/src/hello/hello.go那么什么是DONOTEDIT标记?为什么它在那里,我怎样才能删除它以便gorename可以做它的事情?我的文件是这样开始的:packagemain//#cgoCFLAGS:-g-Wall//#include//#include"c/greet.h"import"C"import("encoding/j

mysql - 无法连接到 DB : database is closed

我有以下项目结构:-main.go-db--dbinit.go在dbinit.go中,我有以下代码:packagedbimport("database/sql"_"github.com/go-sql-driver/mysql")varDb*sql.DBvarerrerrorfuncinit(){Db,err=sql.Open("mysql","myDBCreds")deferDb.Close()}在main.go中我有:packagemainimport(db"./db")funcmain(){deferdb.Db.Close()sqlStatement:=`INSERTINTOtab

go - 错误 "protoc-gen-go: program not found or is not executable"

我正在尝试使用Go构建示例应用程序gRPC,但我无法使用“协议(protocol)”生成代码我已经使用以下方法安装了所需的库和Go包:goget-ugoogle.golang.org/grpcgoget-ugithub.com/golang/protobuf/protoc-gen-go我也试过设置路径,但没有成功。示例“原型(prototype)”文件:syntax="proto3";packagegreet;optiongo_package="greetpb";serviceGreetService{}错误信息:"protoc-gen-go:programnotfoundorisno

转到 : channel is necessary in this case?

http://play.golang.org/p/Xn3Qw7xAi3很难理解channel。我有funcmain(){in:=make(chanint)out:=make(chanint)goQuickSort(in,out)fori:=0;i这使得名为in、out和goroutine的两个channel成为函数Quicksort。1.QuickSort如何将in和out作为参数?它是否从下面的线路接收?in2。这种情况下使用channel是最佳的吗?动态地接收值看起来非常整洁……如果没有channel进行排序会有什么不同?这种情况更快? 最佳答案

xml - Golang rss xml解析 <atom10 :link overrides <link>

以下Go代码返回标记值,如果它在之后标记,否则返回空。我如何获得标记值,如果它出现在之前?或者,我如何同时获得两者?XML:TheJavascripthttp://javascript.comFri,01Mar201323:16:58GMTen-usNewsanddiscussionaboutthelatestinJavascript.javascript,java,news,jquery,prototype,mootools,scriptaculousnojavascript,java,news,jquery,prototype,mootools,scriptaculousTechn

select - golang : channel in select statement is only receiving sometimes (? ??)

我在从两个channel接收的go例程中有一个select语句。for{fmt.Printf("Waitingforselectstatement...\n")select{casereq:=如果调用函数两次发送到第一个channel然后发送到第二个channel一切正常:requestChan控制台输出(正确)是:>Waitingforselectstatement...>Igotarequest:{Loginyaylaswiese}>Waitingforselectstatement...>SendingtruetothedoneChannel>Igotarequest:{Sign

time - 戈朗 : throttle (time delay) function is not working in goroutine (works fine in main thread)

所以我正在编写一个实用程序来查询工作中的API,它们将每10秒限制为20次调用。很简单,我会将我的通话时间限制在自上次通话后至少0.5秒。在我尝试使用goroutine之前,我的Throttle实用程序运行良好。现在我正在使用结构/方法组合:func(c*CTKAPI)Throttle(){ifc.Debug{fmt.Println("\t\t\tEnteringThrottle()")}for{//incasesomethingelsemakesacallwhilewe'resleeping,weneedtore-checkift:=time.Now().Sub(c.LastCall