欢迎来到我们 [Golang 系列教程](https://studygolang.com/subject/2)的第 20 篇。 **Go 是并发式语言，而不是并行式语言**。在讨论 Go 如何处理并发之前，我们必须理解何为并发，以及并发与并行的区别。 ## 并发是什么？ 并发是指立即处理多个任务的能力。一个例子就能很好地说明这一点。 我们可以想象一个人正在跑步。假如在他晨跑时，鞋带突然松了。于是他停下来，系一下鞋带，接下来继续跑。这个例子就是典型的并发。这个人能够一下搞定跑步和系鞋带两件事，即立即处理多个任务。 ## 并行是什么？并行和并发有何区别？ 并行是指同时处理多个任务。这听起来和并发差不多，但其实完全不同。 我们同样用这个跑步的例子来帮助理解。假如这个人在慢跑时，还在用他的 iPod...阅读全文
# pholcus [](https://godoc.org/github.com/henrylee2cn/pholcus) [](https://github.com/henrylee2cn/pholcus/releases) Pholcus（幽灵蛛）是一款纯Go语言编写的高并发、分布式、重量级爬虫软件，支持单机、服务端、客户端三种运行模式，拥有Web、GUI、命令行三种操作界面；规则简单灵活、批...阅读全文
在我的本地机器上，都是请求输出同样字符串的页面。都是输出"yoyo"字符串 测试： ab -n10000 -c100 url golang结果报告: QPS达到5333.83 PHP7.1.5+nginx1.10.2结果报告: QPS仅为359.42 这个对比真是太恐怖了吧，10倍以上的差距。Golang果然是为并发而生...阅读全文
fasthttp 是 Go 的快速 HTTP 实现，当前在 1M 并发的生产环境使用非常成功，可以从单个服务器进行 100K qps 的持续连接。 HTTP 服务器性能与 net/http 比较 总而言之，fasthttp 比 net/http 快 10 倍 GOMAXPROCS=1 net/http: $ GOMAXPROCS=1 go test -bench=NetHTTPServerGet -benchmem PASS BenchmarkNetHTTPServerGet1ReqPerConn 100000 21211 ns/op 2407 B/op 30 allocs/op BenchmarkNe...阅读全文
"并发 (concurrency)" 和 "并行 ( parallelism)" 是不同的。在单个 CPU 核上，线程通过时间片或者让出控制权来实现任务切换，达到 "同时" 运⾏多个任务的⺫的，这就是所谓的并发。但实际上任何时刻都只有一个任务被执行，其他任务通过某种算法来排队。多核 CPU 可以让同⼀进程内的 "多个线程" 做到真正意义上的同时运，它们之间不需要排队 (依然会发生排队，因为线程数量可能超出 CPU 核数量，还有其他的进程等等。这里说的是一个理想状况)，这才是并行。除了多核，并行计算还可能是多台机器上部署运行。 package main import ( "fmt" "runtime" ) func test(c chan bool, n int) { x := 0 for i...阅读全文
函数time.Since() 计算golang运行的时间是非常有用的性能衡量指标，特别是在并发基准测试中。下面将介绍如何简单地使用Go语言来计算程序运行的时间。 简单地使用Golang的time.Since()函数即可。下面有一个完整例子展示这个用法。 package main import ( "fmt" "time" ) func StartCac() { t1 := time.Now() // get current time //logic handlers for i := 0; i < 1000; i++ { fmt.Print("*") } elapsed := time.Since(t1) fmt.Println("App elapsed: ", elapsed) } fun...阅读全文
仓库地址：https://github.com/zhangwei412827/ImageSpider 欢迎sta...阅读全文
golang 高性能异步工作池。并发限制goroutine池，限制任务执行的并发性，而不是排队的任务数。无论排队多少任务，都不会阻止提交任务...阅读全文
package main import ( "flag" "fmt" "io/ioutil" "net/http" "sync/atomic" "time" ) func main() { connection := flag.Int("c", 200, "-c N") timeout := flag.Int("o", 5, "-o N") timeover := flag.Int("t", 5, "-t N") printresult := flag.Bool("p", false, "-p false") method := flag.String("m", "GET", "-m GET") url := flag.String("u", "http://127.0.0.1", "-u ...阅读全文
imooc golang电商实战下载链接：https://pan.baidu.com/s/1N5nO7OVKlesjfKU8OIOA4g 提取码：3zri 加油学...阅读全文
先看一段代码 ackage main import ( "fmt" "sync" ) func main() { var wg sync.WaitGroup s := make([]int, 0, 1000) for i := 0; i < 1000; i++ { v := i wg.Add(1) go func() { s = append(s, v) wg.Done() }() } wg.Wait() fmt.Printf("%v\n", len(s)) } 结果 第一次：928 第二次：945 第三次：986 …… 多运行几次你就会发现，slice长度并不是1000，而是不停的在变，为什么呢？ 因为append并不是并发安全的。 我们举一个简单例子，比如，当A和B两个协程运行appen...阅读全文
金融类项目招聘，需要具有处理过一定并发量的工程师，具有Java丰富经验，愿意转Go的也可...阅读全文
http://gochannel.org/ 不定期更...阅读全文
一直是这个问题困扰着哦我，为什么越来越多连接，到爆掉，换作postgresql驱动也是，还是我理解go语言并发有错呢 package main import ( "database/sql" "fmt" _ "github.com/go-sql-driver/mysql" "strconv" "time" ) var xiancheng = 10 var over = make(chan bool) var sem = make(chan int, xiancheng) func checkErr(err error, hh int) { if err != nil { fmt.Printf("er...阅读全文
高并发&高性能 Go语言开发企业级抽奖项目 链接：https://pan.baidu.com/s/1qGWRjhtW4ON_1pGMzWYjQw 提取码：odji...阅读全文
慕课网是国内最大垂直类IT教育平台，目前有用户1100W+。 #用户基础好，流量高、持续分成，分成丰厚，没有时间地点限制。 #职位要求# 1.基础扎实，熟悉常用结构和算法。三年以上Golang使用经验。 2.精通Golang设计原理、源码分析和使用 3.有使用GO语言开发高并发、高可靠、可扩展的后端程序经验 4.热爱分享，逻辑清晰，语言表达能力强，有技术博客者优先。 contact：lirui@imooc.com QQ:154699251 慕课网BD经理 Gig...阅读全文
大部分用过Go语言的人都认可其是一种非常不错的生产力工具，有人总结其优点如下： 部署简单 并发性好 语言设计良好 执行性能...阅读全文
我加了锁，可还是报错。 fatal error: concurrent map iteration and map write 这是为何呢？百度的各种方法也都试了，都不行。 ```go package main import ( "fmt" "sync" ) func main() { var counter = struct{ sync.RWMutex m map[string]int }{m: make(map[string]int)} for i := 0; i < 2; i++ { go func() { for j := 0; j < 1000000; j++ { counter.Lock()...阅读全文
golang并没有在语言层次上提供超时操作，但可以通过一些小技巧实现超时。 原理： 并发一个函数，等待1s后向timeout写入数据，在select中如果1s之内有数据向其他channel写入则会顺利执行，如果没有，这是timeout写入了数据，则我们知道超时了。 package main import "fmt" import "time" func main() { ch := make(chan int, 1) timeout := make(chan bool, 1) // 并发执行一个函数，等待1s后向timeout写入true go func() { time.Sleep(1000) timeout <- true }() // 这里会等待ch或timeout读出数据 // 因为...阅读全文
下载地址:http://sharevip.org/2015/07/24/Mastering-Concurrency-in-Go...阅读全文
用go写了一个web程序，测了一把性能，发现结果如下： 并发数 响应时间（每100000个请求） 10 16.489387 100 20.43609 1000 51.357626 而php的同样程序，在fastcgi方式下，测试结果如下： 并发数 响应时间（每100000个请求） 10 62.194685 100 81.103587 1000 103.441608 结论：随着并发数的增大，go的处理能力波动比php还大。 看来go语言还需要很长的时间来完善呀。 如果利用runtime.GOMAXPROCESS将最大处理器数设置为2 那么处理时间实际上比默认的情况还糟糕...阅读全文
链接：https://pan.baidu.com/s/1N5nO7OVKlesjfKU8OIOA4g 提取码：3zri ...阅读全文
package main import ( "fmt" "math/rand" "os" "strconv" "strings" "time" "github.com/Shopify/sarama" "github.com/bsm/sarama-cluster" //support automatic consumer-group rebalancing and offset tracking "github.com/sdbaiguanghe/glog" ) var ( topics = "test0" ) // consumer 消费者 func consumer() { groupID := "group-1" config := cluster.NewConfig() config.G...阅读全文
GoLang中控制并发有两种方式: sync.WaitGroup 和 channel 下面是两种方法的对比 sync.WaitGroup，该方法最大优点是Wait()可以阻塞到队列中的所有任务都执行完才解除阻塞，但是它的缺点是不能够指定并发协程数量． channel优点：能够利用带缓存的channel指定并发协程goroutine，比较灵活．但是它的缺点是如果使用不当容易造成死锁；并且他还需要自己判定并发goroutine是否执行完． 但是相对而言，channel更加灵活，使用更加方便，同时通过超时处理机制可以很好的避免channel造成的程序死锁，因此利用channel实现程序并发，更加方便，更加易用...阅读全文
来自 How I Start 的一篇文章。主要包括以下内容： - 设置Go语言环境 - 创建一个新工程 - 构建一个Web Server - 为 Web Server 增加更多路由 - 查询 multiple APIs - 并发 - Simplicity - 进一步实践 [猛击这里阅读原文](http://howistart.org/posts/go/1...阅读全文
下面这代码同时打开两个页面访问，第二个要等第一个输出1,2后才会输出1，http不是并发的么