分类目录归档：golang

2021
01-06

golang中如何真正平滑重启 NEW

背景在业务快速增长中，前期只是验证模式是否可行，初期忽略程序发布重启带来的暂短停机影响。当模式实验成熟之后会逐渐放量，此时我们的发布停机带来的影响就会大很多。我们整个服务都是基于云，请求流量从 四层->七层->机器。要想实现平滑重启大致有三种方案，一种是在流量调度的入口处理，一般的做法是 ApiGateway + CD ，发布的时候自动摘除机器，等待程序处理完现有请求再做发布处理，这样的好处就是程序不需要关心如何做平滑重启。第二种就是程序自己完成平滑重启，保证在重... Read More >

2021
01-05

golang可视化GMP编程 NEW

可视化 GMP 编程有 2 种方式可以查看一个程序的 GMP 的数据。方式 1：go tool tracetrace 记录了运行时的信息，能提供可视化的 Web 页面。简单测试代码：main 函数创建 trace，trace 会运行在单独的 goroutine 中，然后 main 打印”Hello World” 退出。trace.gopackage main import (     "os&quo... Read More >

2021
01-05

Go语言编程GMP调度模型 NEW

并发和并行并发和并行的目的都是为了充分利用 CPU 的多核（多处理器）架构，但两者却有着本质的区别。    并发：在同一时间段内，多条指令在 CPU 上执行。    并行：在同一时刻内，多条指令在 CPU 上执行。并发程序 并不要求 CPU 具备多核计算能力，只要求多个线程在同一个 Core 上进行 “分时轮询” 处理。可以在宏观上实现多线程同时执行的效果。并发程序的执行通常是不确定的，这种不确定性来源于资源之间的相... Read More >

2021
01-04

面试必备(背)--Go语言八股文系列

1. 垃圾回收详情参考：https://phpmianshi.com/?id=5195典藏版： https://phpmianshi.com/?id=51972. GPM 调度 和 CSP 模型详情参考：https://phpmianshi.com/?id=37393. CHAN 原理3.1 结构体   type hchan struct {  qcount   uint&n... Read More >

2021
01-03

[典藏版]Golang三色标记、混合写屏障GC模式图文全分析

概要Golang中的垃圾回收主要应用三色标记法，GC过程和其他用户goroutine可并发运行，但需要一定时间的STW(stop the world)，STW的过程中，CPU不执行用户代码，全部用于垃圾回收，这个过程的影响很大，Golang进行了多次的迭代优化来解决这个问题，本文将逐步推进Golang中GC的每次推进，来理解Gc的原理。文章较长，内容概要如下：G0 V1.3之前的标记-清除(mark and sweep)算法Go V1.3之前的标记-清扫(mark and s... Read More >

2021
01-02

内存分配逃逸分析

堆栈内存分配中的堆和栈    栈（操作系统）：由操作系统自动分配释放 ，存放函数的参数值，局部变量的值等。其操作方式类似于数据结构中的栈。    堆（操作系统）： 一般由程序员分配释放， 若程序员不释放，程序结束时可能由OS回收，分配方式倒是类似于链表。堆栈缓存方式    栈使用的是一级缓存， 他们通常都是被调用时处于存储空间中，调用完毕立即释放。    堆... Read More >

2021
01-01

深入理解GC原理

垃圾定位算法（1）引用计数法 （Reference Counting）。  如 python  php      通常C++通过指针引用计数来回收对象，但是这不能处理循环引用，原理是在每个对象内部维护一个引用计数，当对象被引用时引用计数加一，当对象不被引用时引用计数减一。当引用计数为 0 时，自动销毁对象。      例如：谁想用驴干活的时候，就在驴身上画个... Read More >

2020
08-03

为何需要反射

有时候我们需要编写一个函数能够处理一类并不满足普通公共接口的类型的值，也可能是因为它们并没有确定的表示方式，或者是在我们设计该函数的时候这些类型可能还不存在。一个大家熟悉的例子是fmt.Fprintf函数提供的字符串格式化处理逻辑，它可以用来对任意类型的值格式化并打印，甚至支持用户自定义的类型。让我们也来尝试实现一个类似功能的函数。为了简单起见，我们的函数只接收一个参数，然后返回和fmt.Sprint类似的格式化后的字符串。我们实现的函数名也叫Sprint。我们首先用swit... Read More >

2020
08-02

golang反射详解

反射反射是指在程序运行期对程序本身进行访问和修改的能力1.1.1. 变量的内在机制    变量包含类型信息和值信息 var arr [10]int arr[0] = 10    类型信息：是静态的元信息，是预先定义好的    值信息：是程序运行过程中动态改变的1.1.2. 反射的使用    reflect包封装了反射相... Read More >

2020
08-01

golang标准库之context

在 Go http包的Server中，每一个请求在都有一个对应的 goroutine 去处理。请求处理函数通常会启动额外的 goroutine 用来访问后端服务，比如数据库和RPC服务。用来处理一个请求的 goroutine 通常需要访问一些与请求特定的数据，比如终端用户的身份认证信息、验证相关的token、请求的截止时间。 当一个请求被取消或超时时，所有用来处理该请求的 goroutine 都应该迅速退出，然后系统才能释放这些 goroutine 占用的资源。为什么需要Co... Read More >

2020
07-30

golang原子操作atomic包详解

sync/atomic 介绍当我们想要对某个变量并发安全的修改，除了使用官方提供的 mutex，还可以使用 sync/atomic 包的原子操作，它能够保证对变量的读取或修改期间不被其他的协程所影响。atomic 包的原子操作是通过 CPU 指令，也就是在硬件层次去实现的，性能较好，不需要像 mutex 那样记录很多状态。 当然，mutex 不止是对变量的并发控制，更多的是对代码块的并发控制，2 者侧重点不一样。sync/atomic 操作atomic 包有几种原子操作，主要... Read More >

2020
07-29

详尽解析go中的fatal error: concurrent map writes

背景多个协程同时修改同一个map时报错fatal error: concurrent map writes原因go中的map不是并发安全的，所以当多个goroutine同时对map执行写操作的时候，就会报刚刚的错误。package main import (     "math/rand"     "... Read More >

2020
07-28

golang中sync包实现并发任务的同步

1.1.1. sync.WaitGroup在代码中生硬的使用time.Sleep肯定是不合适的，Go语言中可以使用sync.WaitGroup来实现并发任务的同步。 sync.WaitGroup有以下几个方法：方法名功能(wg * WaitGroup) Add(delta int)计数器+delta(wg *WaitGroup) Done()计数器-1(wg *WaitGroup) Wait()阻塞直到计数器变为0sync.WaitGroup内部维护着一个计数器，计数器的值可... Read More >

2020
07-27

golang并发安全和锁

背景有时候在Go代码中可能会存在多个goroutine同时操作一个资源（临界区），这种情况会发生竞态问题（数据竞态）。类比现实生活中的例子有十字路口被各个方向的的汽车竞争；还有火车上的卫生间被车厢里的人竞争。举个例子：var x int64 var wg sync.WaitGroup func add() {     for i := 0... Read More >

2020
07-26

go语言select详解

select1.1.1. select多路复用在某些场景下我们需要同时从多个通道接收数据。通道在接收数据时，如果没有数据可以接收将会发生阻塞。你也许会写出如下代码使用遍历的方式来实现：for{     // 尝试从ch1接收值     data, ok := <-ch1     // 尝试从ch2... Read More >

2020
07-25

go定时器

定时器1.1.1. 定时器    Timer：时间到了，执行只执行1次package main import (     "fmt"     "time" ) func main() {     // 1.ti... Read More >

2020
07-24

go goroutine池

Goroutine池1.1.1. worker pool（goroutine池）    本质上是生产者消费者模型    可以有效控制goroutine数量，防止暴涨    需求：        计算一个数字的各个位数之和，例如数字123，结果为1+2+3=6  ... Read More >

2020
07-23

go channel

Channel1.1.1. channel单纯地将函数并发执行是没有意义的。函数与函数间需要交换数据才能体现并发执行函数的意义。虽然可以使用共享内存进行数据交换，但是共享内存在不同的goroutine中容易发生竞态问题。为了保证数据交换的正确性，必须使用互斥量对内存进行加锁，这种做法势必造成性能问题。Go语言的并发模型是CSP（Communicating Sequential Processes），提倡通过通信共享内存而不是通过共享内存而实现通信。如果说goroutine是G... Read More >

2020
07-22

go runtime包

runtime包1.1.1. runtime.Gosched()让出CPU时间片，重新等待安排任务(大概意思就是本来计划的好好的周末出去烧烤，但是你妈让你去相亲,两种情况第一就是你相亲速度非常快，见面就黄不耽误你继续烧烤，第二种情况就是你相亲速度特别慢，见面就是你侬我侬的，耽误了烧烤，但是还馋就是耽误了烧烤你还得去烧烤)package main import (     "fmt" &n... Read More >

2020
07-21

Goroutine

Goroutinegoroutine的概念类似于线程，但 goroutine是由Go的运行时（runtime）调度和管理的。Go程序会智能地将 goroutine 中的任务合理地分配给每个CPU。Go语言之所以被称为现代化的编程语言，就是因为它在语言层面已经内置了调度和上下文切换的机制。在Go语言编程中你不需要去自己写进程、线程、协程，你的技能包里只有一个技能–goroutine，当你需要让某个任务并发执行的时候，你只需要把这个任务包装成一个函数，开启一个gorout... Read More >