From 1d2b2b2c7d2daf9c93eaef7089ae2f3b64c0a252 Mon Sep 17 00:00:00 2001 From: pengshiyu <1940607002@qq.com> Date: Tue, 27 Sep 2022 22:43:31 +0800 Subject: [PATCH] fix --- blog/golang/golang-concurrency.md | 417 ++++++++++++++++++++++++++++++ blog/golang/index.md | 2 +- blog/pay/start.md | 4 + 3 files changed, 422 insertions(+), 1 deletion(-) diff --git a/blog/golang/golang-concurrency.md b/blog/golang/golang-concurrency.md index 5c54dc8..fbfe4c9 100644 --- a/blog/golang/golang-concurrency.md +++ b/blog/golang/golang-concurrency.md @@ -127,3 +127,420 @@ step2: https://www.taobao.com/ step3: https://www.taobao.com/ step4: 87347 ``` + +## golang并发编程之channel + +Go提供了一种通道机制，用于goroutine之间`共享数据` + +通道需要指定`数据类型` + +通道分类： +- 无缓冲通道 同步通讯 +- 缓冲通道 异步通讯 + +语法 + +```go +// 整型无缓冲通道，默认零值 +Unbuffered := make(chan int) + +// 整型缓冲通道 +buffered := make(chan int, 10) +``` + +通道数据交换 + +```go +channel := make(chan string, 5) + +// 将值发送到通道 +channel <- "hello" + +// 从通道接收值 +data := <- channel +``` + +通道的发送和接收特性 + +- 同一通道，发送操作之间是互斥的，接收操作之间也是互斥的 +- 发送操作和接收操作中对元素值的处理都是不可分割的 +- 发送操作在完全完成之前会被阻塞，接收操作也是如此 + +示例 + +```go +package main + +import ( + "fmt" + "math/rand" + "time" +) + +// 创建一个int类型的通道 +var value = make(chan int) + +func send() { + + // 向通道发送一个随机值 + rand.Seed(time.Now().UnixNano()) + v := rand.Intn(10) + + time.Sleep(time.Second * 3) + value <- v +} + +func main() { + // 关闭通道 + defer close(value) + + go send() + + fmt.Println("wait...") + + // 从通道接收值 + v := <-value + + fmt.Printf("v: %v\n", v) +} + +``` + +## golang并发编程之WaitGroup实现同步 + +示例1 + +```go +package main + +import ( + "fmt" +) + +func showMessage(i int) { + fmt.Printf("i: %v\n", i) +} + +func main() { + for i := 0; i < 10; i++ { + showMessage(i) + } +} + +``` + +输出 +```go +i: 0 +i: 1 +i: 2 +i: 3 +i: 4 +i: 5 +i: 6 +i: 7 +i: 8 +i: 9 +``` + +示例 2 + +```go +package main + +import ( + "fmt" +) + +func showMessage(i int) { + fmt.Printf("i: %v\n", i) +} + +func main() { + for i := 0; i < 10; i++ { + // 启动协程来执行 + go showMessage(i) + } + + // 主协程执行结束 + fmt.Println("end") +} + +``` + + +输出 +```go +i: 0 +end +``` + +示例 3 + +```go +package main + +import ( + "fmt" + "sync" +) + +var wp sync.WaitGroup + +func showMessage(i int) { + defer wp.Done() + + fmt.Printf("i: %v\n", i) +} + +func main() { + for i := 0; i < 10; i++ { + go showMessage(i) + wp.Add(1) + } + + wp.Wait() + + fmt.Println("end") +} + +``` + +输出 +``` +i: 4 +i: 1 +i: 0 +i: 5 +i: 7 +i: 8 +i: 2 +i: 3 +i: 9 +i: 6 +end +``` + +## golang并发编程之runtime包 + +runtime定义了协程管理的包 + +## Gosched + +让出执行权限 + +示例 + +```go +package main + +import ( + "fmt" +) + +func show() { + for i := 0; i < 2; i++ { + fmt.Printf("show i: %v\n", i) + } +} + +func main() { + go show() + + for i := 0; i < 2; i++ { + fmt.Printf("main i: %v\n", i) + } + + fmt.Println("end") +} + +``` + +输出 + +``` +main i: 0 +main i: 1 +end +``` + +示例 2 + +```go +package main + +import ( + "fmt" + "runtime" +) + +func show() { + for i := 0; i < 2; i++ { + fmt.Printf("show i: %v\n", i) + } +} + +func main() { + go show() + + for i := 0; i < 2; i++ { + + // 让出执行权限，给其他子协程执行 + runtime.Gosched() + + fmt.Printf("main i: %v\n", i) + } + + fmt.Println("end") +} + +``` + +输出 +``` +show i: 0 +main i: 0 +main i: 1 +end +``` + +### Goexit + +退出当前协程 + +示例 + +```go +package main + +import ( + "fmt" + "runtime" + "time" +) + +func show() { + for i := 0; i < 10; i++ { + fmt.Printf("show i: %v\n", i) + if i >= 5 { + runtime.Goexit() + } + } +} + +func main() { + go show() + + time.Sleep(time.Second) + + fmt.Println("end") +} + +``` + +输出 +``` +show i: 0 +show i: 1 +show i: 2 +show i: 3 +show i: 4 +show i: 5 +end +``` + +### GOMAXPROCS + +设置CPU数量 + +```go +package main + +import ( + "fmt" + "runtime" + "time" +) + +func show(name string) { + for i := 0; i < 10; i++ { + fmt.Printf("%v i: %v\n", name, i) + } +} + +func main() { + + // 查看CPU核数 + fmt.Printf("runtime.NumCPU(): %v\n", runtime.NumCPU()) + // runtime.NumCPU(): 8 + + // 设置CPU数量 + runtime.GOMAXPROCS(2) + + go show("A") + go show("B") + + time.Sleep(time.Second) + + fmt.Println("end") +} + +``` + +## golang并发编程之Mutex 互斥锁实现同步 + +示例 + +```go +package main + +import ( + "fmt" + "sync" + "time" +) + +var value = 100 +var wg sync.WaitGroup + +var lock sync.Mutex + +func add() { + defer wg.Done() + + lock.Lock() + time.Sleep(time.Millisecond * 2) + + value += 1 + fmt.Printf("i++: %v\n", value) + lock.Unlock() +} + +func sub() { + defer wg.Done() + + lock.Lock() + + time.Sleep(time.Millisecond * 10) + + value -= 1 + fmt.Printf("i--: %v\n", value) + + lock.Unlock() +} + +func main() { + for i := 0; i < 100; i++ { + wg.Add(1) + go add() + + wg.Add(1) + go sub() + } + + wg.Wait() + fmt.Printf("end: %v\n", value) +} + +``` + diff --git a/blog/golang/index.md b/blog/golang/index.md index a8faa83..41a26d5 100644 --- a/blog/golang/index.md +++ b/blog/golang/index.md @@ -52,4 +52,4 @@ https://www.bilibili.com/video/BV1ME411Y71o?p=27&spm_id_from=pageDriver&vd_source=efbb4dc944fa761b6e016ce2ca5933da -https://www.bilibili.com/video/BV1zR4y1t7Wj/?p=68&spm_id_from=pageDriver&vd_source=efbb4dc944fa761b6e016ce2ca5933da \ No newline at end of file +https://www.bilibili.com/video/BV1zR4y1t7Wj/?p=72&spm_id_from=pageDriver&vd_source=efbb4dc944fa761b6e016ce2ca5933da \ No newline at end of file diff --git a/blog/pay/start.md b/blog/pay/start.md index dbe1017..b26bf25 100644 --- a/blog/pay/start.md +++ b/blog/pay/start.md @@ -13,6 +13,10 @@ 4. 商户证书 - 微信商户平台：https://pay.weixin.qq.com/ + - 文档：https://kf.qq.com/faq/161222NneAJf161222U7fARv.html + - 下载证书工具： + - windows版本 ：https://wx.gtimg.com/mch/files/WXCertUtil.exe + - mac版本 ：https://wx.gtimg.com/mch/files/WXCertUtil.dmg 5. 微信平台证书 - Java命令行下载工具： https://github.com/wechatpay-apiv3/CertificateDownloader -- GitLab