{"id":478436,"date":"2026-05-04T07:17:21","date_gmt":"2026-05-04T07:17:21","guid":{"rendered":"https:\/\/savepearlharbor.com\/?p=478436"},"modified":"-0001-11-30T00:00:00","modified_gmt":"-0001-11-29T21:00:00","slug":"","status":"publish","type":"post","link":"https:\/\/savepearlharbor.com\/?p=478436","title":{"rendered":"Code Review Horror Stories. \u0427\u0430\u0441\u0442\u044c 1: Concurrency & Memory \u0432 Go-\u0441\u0435\u0440\u0432\u0438\u0441\u0435"},"content":{"rendered":"
\n

\u041f\u0440\u043e\u0434\u043e\u043b\u0436\u0435\u043d\u0438\u0435 <\/em>\u043f\u0440\u043e\u0448\u043b\u043e\u0439 \u0441\u0442\u0430\u0442\u044c\u0438 \u043f\u0440\u043e \u043e\u0448\u0438\u0431\u043a\u0438 \u043d\u0430 Go-\u0441\u043e\u0431\u0435\u0441\u0430\u0445<\/em><\/a>. \u0412 \u0442\u043e\u0442 \u0440\u0430\u0437 \u2014 \u043f\u0440\u043e \u043b\u0430\u0439\u0432-\u043a\u043e\u0434\u0438\u043d\u0433. \u0422\u0435\u043f\u0435\u0440\u044c \u2014 \u043f\u0440\u043e code review: \u043a\u043e\u0433\u0434\u0430 \u0434\u0430\u044e\u0442 \u0433\u043e\u0442\u043e\u0432\u044b\u0439 \u0441\u0435\u0440\u0432\u0438\u0441 \u043d\u0430 ~150 \u0441\u0442\u0440\u043e\u043a \u0438 \u0433\u043e\u0432\u043e\u0440\u044f\u0442 \u201c\u043d\u0430\u0439\u0434\u0438 \u0447\u0442\u043e \u043d\u0435 \u0442\u0430\u043a, \u0443 \u0442\u0435\u0431\u044f 30 \u043c\u0438\u043d\u0443\u0442\u201d.<\/em><\/p>\n

\u0420\u0430\u0437\u0431\u0435\u0440\u0451\u043c \u043f\u043e \u043a\u043e\u0441\u0442\u043e\u0447\u043a\u0430\u043c \u0440\u0435\u0430\u043b\u044c\u043d\u044b\u0439 \u043a\u043e\u0434 \u0441 \u0441\u043e\u0431\u0435\u0441\u0435\u0434\u043e\u0432\u0430\u043d\u0438\u044f \u2014 \u043c\u0438\u043a\u0440\u043e\u0441\u0435\u0440\u0432\u0438\u0441 \u0442\u0440\u0435\u043a\u0438\u043d\u0433\u0430 \u0440\u0435\u043a\u043b\u0430\u043c\u043d\u044b\u0445 \u043a\u043b\u0438\u043a\u043e\u0432. \u0411\u0430\u0433\u043e\u0432 \u043d\u0430\u0431\u0440\u0430\u043b\u043e\u0441\u044c 21, \u043f\u043e\u044d\u0442\u043e\u043c\u0443 \u0434\u0435\u043b\u044e \u043d\u0430 \u0434\u0432\u0435 \u0447\u0430\u0441\u0442\u0438. \u041f\u0435\u0440\u0432\u0430\u044f \u2014 \u043f\u0440\u043e \u0441\u0430\u043c\u043e\u0435 \u0441\u0442\u0440\u0430\u0448\u043d\u043e\u0435: concurrency, \u0433\u043e\u043d\u043a\u0438, \u0443\u0442\u0435\u0447\u043a\u0438 \u043f\u0430\u043c\u044f\u0442\u0438 \u0438 \u0433\u043e\u0440\u0443\u0442\u0438\u043d. \u042d\u0442\u043e \u0442\u043e, \u0447\u0442\u043e \u0440\u043e\u043d\u044f\u0435\u0442 \u0441\u0435\u0440\u0432\u0438\u0441 \u0432 \u043f\u0440\u043e\u0434\u0435. \u0427\u0430\u0441\u0442\u044c 2 \u2014 \u043f\u0440\u043e API design, \u043e\u0448\u0438\u0431\u043a\u0438 \u0438 graceful shutdown \u2014 \u0432\u044b\u0439\u0434\u0435\u0442 \u0441\u043b\u0435\u0434\u043e\u043c. \u0410\u043a\u0442\u0443\u0430\u043b\u044c\u043d\u043e \u0434\u043b\u044f Go 1.26.<\/em><\/p>\n

\u0418\u0437 21 \u0431\u0430\u0433\u0430 \u043d\u0430 \u0441\u043e\u0431\u0435\u0441\u0435 \u044f \u043d\u0430\u0448\u0451\u043b 18. \u0422\u0440\u0438 \u0441\u0430\u043c\u044b\u0445 \u0442\u043e\u043d\u043a\u0438\u0445 \u043f\u0440\u043e\u043f\u0443\u0441\u0442\u0438\u043b \u2014 \u043f\u043e\u0442\u043e\u043c, \u0434\u043e\u043c\u0430, \u043f\u0435\u0440\u0435\u0447\u0438\u0442\u0430\u043b \u0441\u043f\u043e\u043a\u043e\u0439\u043d\u043e \u0438 \u0432\u044b\u043f\u0438\u0441\u0430\u043b. \u0412 \u044d\u0442\u043e\u0439 \u0447\u0430\u0441\u0442\u0438 \u043f\u0440\u043e concurrency \u043f\u0440\u043e\u043f\u0443\u0441\u0442\u0438\u043b \u043e\u0434\u0438\u043d \u2014 TOCTOU race \u0432 \u0434\u0435\u0434\u0443\u043f\u043b\u0438\u043a\u0430\u0446\u0438\u0438. \u041e\u0441\u0442\u0430\u043b\u044c\u043d\u044b\u0435 \u0441\u0435\u043c\u044c \u2014 \u043f\u043e\u0439\u043c\u0430\u043b. \u0420\u0430\u0441\u0441\u043a\u0430\u0436\u0443 \u043a\u0430\u043a \u0438\u0441\u043a\u0430\u043b \u0438 \u043a\u0430\u043a\u0438\u043c\u0438 \u043a\u0440\u0430\u0441\u043d\u044b\u043c\u0438 \u0444\u043b\u0430\u0433\u0430\u043c\u0438 \u0437\u0430\u0446\u0435\u043f\u0438\u043b\u0441\u044f.<\/em><\/p>\n\n

\u041a\u043e\u043d\u0442\u0435\u043a\u0441\u0442: \u0447\u0442\u043e \u0437\u0430 \u043a\u043e\u0434?<\/h3>\n

\u0414\u0430\u043b\u0438 \u0442\u0438\u043f\u043e\u0432\u043e\u0439 ad-tech \u0441\u0435\u0440\u0432\u0438\u0441: HTTP endpoint \u043f\u0440\u0438\u043d\u0438\u043c\u0430\u0435\u0442 \u043a\u043b\u0438\u043a \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u044f \u043f\u043e \u0431\u0430\u043d\u043d\u0435\u0440\u0443, \u0433\u0435\u043d\u0435\u0440\u0438\u0440\u0443\u0435\u0442 tracking link, \u043a\u043b\u0430\u0434\u0451\u0442 \u0432 in-memory storage, \u043f\u0430\u0431\u043b\u0438\u0448\u0438\u0442 \u0432 \u043e\u0447\u0435\u0440\u0435\u0434\u044c. \u0414\u0435\u0434\u0443\u043f\u043b\u0438\u043a\u0430\u0446\u0438\u044f \u043f\u043e (user_uuid, campaign_uuid)<\/code> \u0437\u0430 \u043f\u043e\u0441\u043b\u0435\u0434\u043d\u0438\u0435 5 \u0441\u0435\u043a\u0443\u043d\u0434 (\u0447\u0442\u043e\u0431\u044b \u043e\u0434\u0438\u043d \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u044c \u043d\u0435 \u043d\u0430\u043a\u0440\u0443\u0447\u0438\u0432\u0430\u043b \u043a\u043b\u0438\u043a\u0438).<\/p>\n

Stack: Gin, sync.RWMutex, \u0447\u0438\u0441\u0442\u044b\u0439 Go \u0431\u0435\u0437 \u0411\u0414. \u0412\u0440\u043e\u0434\u0435 \u0431\u044b \u043f\u0440\u043e\u0441\u0442\u0435\u043d\u044c\u043a\u043e. \u0412\u043e\u0442 \u043e\u0441\u043d\u043e\u0432\u043d\u044b\u0435 \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u044b:<\/p>\n

type CampaignClick struct {    ClickUUID    string    UserUUID     string    CampaignUUID string    Country      string    TrackingLink string    CreatedAt    time.Time}type InMemoryClickRepository struct {    mu     sync.RWMutex    clicks []*CampaignClick}type Publisher struct {    topic string    out   chan *CampaignClick}<\/code>
<\/a><\/div><\/pre>\n
\u0418\u043d\u0442\u0435\u0440\u0432\u044c\u044e\u0435\u0440 \u043c\u043d\u0435 \u0442\u0430\u043a\u043e\u0439: \u201c\u0422\u0443\u0442 \u0435\u0441\u0442\u044c \u043d\u0435\u0441\u043a\u043e\u043b\u044c\u043a\u043e \u043f\u0440\u043e\u0431\u043b\u0435\u043c. \u041d\u0430\u0439\u0434\u0438 \u043a\u0430\u043a \u043c\u043e\u0436\u043d\u043e \u0431\u043e\u043b\u044c\u0448\u0435 \u0437\u0430 30 \u043c\u0438\u043d\u0443\u0442\u201d. \u042f \u0434\u0443\u043c\u0430\u044e \u2014 \u043d\u0443 \u0441\u0435\u0439\u0447\u0430\u0441 \u043f\u043e\u043a\u0430\u0436\u0443 \u043a\u043b\u0430\u0441\u0441. \u0418, \u043a \u043c\u043e\u0435\u043c\u0443 \u0441\u043e\u0431\u0441\u0442\u0432\u0435\u043d\u043d\u043e\u043c\u0443 \u0443\u0434\u0438\u0432\u043b\u0435\u043d\u0438\u044e, \u0434\u0435\u0439\u0441\u0442\u0432\u0438\u0442\u0435\u043b\u044c\u043d\u043e \u043f\u043e\u043a\u0430\u0437\u0430\u043b: 18 \u0438\u0437 21. \u0414\u0430\u043b\u044c\u0448\u0435 \u2014 \u043a\u0430\u043a \u0438\u043c\u0435\u043d\u043d\u043e \u044f \u0438\u0445 \u0438\u0441\u043a\u0430\u043b, \u0438 \u043a\u0430\u043a\u0438\u0435 \u0442\u0440\u0438 \u0432\u0441\u0451-\u0442\u0430\u043a\u0438 \u043f\u0440\u043e\u043f\u0443\u0441\u0442\u0438\u043b.<\/p>\n\n
1. \u201cMutex \u0435\u0441\u0442\u044c, \u043d\u043e \u043e\u043d \u043d\u0435 \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442\u201d<\/h3>\n
\u041e\u0442\u043a\u0440\u044b\u0432\u0430\u044e \u043a\u043e\u0434, \u0432\u0438\u0436\u0443:<\/p>\n
type InMemoryClickRepository struct {    mu     sync.RWMutex    clicks []*CampaignClick}func (r *InMemoryClickRepository) Save(c *CampaignClick) error {    r.clicks = append(r.clicks, c)    return nil}<\/code>
<\/a><\/div><\/pre>\n
\u041f\u0435\u0440\u0432\u043e\u0435, \u043d\u0430 \u0447\u0442\u043e \u044f \u0432\u0441\u0435\u0433\u0434\u0430 \u0441\u043c\u043e\u0442\u0440\u044e \u0432 \u0440\u0435\u043f\u043e\u0437\u0438\u0442\u043e\u0440\u0438\u0438, \u2014 \u0432\u0441\u0435 \u043b\u0438 write-\u043c\u0435\u0442\u043e\u0434\u044b \u0431\u0435\u0440\u0443\u0442 Lock. \u041f\u0440\u043e\u0432\u0435\u0440\u044f\u044e Save<\/code> \u2014 \u0442\u0430\u043c \u043f\u0443\u0441\u0442\u043e. \u041d\u0438\u043a\u0430\u043a\u043e\u0433\u043e r.mu<\/code><\/a>.Lock()<\/code>. Mutex \u043e\u0431\u044a\u044f\u0432\u043b\u0435\u043d \u0432 \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0435, \u0432 GetRecent<\/code> \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442\u0441\u044f, \u0430 \u0432 Save<\/code> \u0437\u0430\u0431\u044b\u043b\u0438. \u041a\u043b\u0430\u0441\u0441\u0438\u043a\u0430 \u0436\u0430\u043d\u0440\u0430.<\/p>\n
\u041e\u0437\u0432\u0443\u0447\u0438\u0432\u0430\u044e \u0438\u043d\u0442\u0435\u0440\u0432\u044c\u044e\u0435\u0440\u0443: \u201c\u0422\u0443\u0442 data race \u2014 Save<\/code> \u043f\u0438\u0448\u0435\u0442 \u0432 slice \u0431\u0435\u0437 Lock, \u043f\u0440\u0438 \u044d\u0442\u043e\u043c GetRecent<\/code> \u0447\u0438\u0442\u0430\u0435\u0442 \u043f\u043e\u0434 RLock<\/code>. \u0415\u0441\u043b\u0438 \u043e\u0434\u043d\u0430 \u0433\u043e\u0440\u0443\u0442\u0438\u043d\u0430 \u0434\u0435\u043b\u0430\u0435\u0442 append<\/code> (\u0430 \u043e\u043d \u043c\u043e\u0436\u0435\u0442 \u043f\u0435\u0440\u0435\u0432\u044b\u0434\u0435\u043b\u0438\u0442\u044c underlying array), \u0430 \u0432\u0442\u043e\u0440\u0430\u044f \u0432 \u044d\u0442\u043e\u0442 \u043c\u043e\u043c\u0435\u043d\u0442 \u0447\u0438\u0442\u0430\u0435\u0442 \u2014 \u043f\u043e\u043b\u0443\u0447\u0430\u0435\u043c race \u043d\u0430 underlying array\u201d. \u0418\u043d\u0442\u0435\u0440\u0432\u044c\u044e\u0435\u0440 \u043a\u0438\u0432\u0430\u0435\u0442, \u0441\u0442\u0430\u0432\u0438\u0442 \u0433\u0430\u043b\u043e\u0447\u043a\u0443.<\/p>\n
\u0414\u043e\u043f\u043e\u043b\u043d\u0438\u0442\u0435\u043b\u044c\u043d\u043e: \u0434\u0430\u0436\u0435 \u0431\u0435\u0437 \u043f\u0435\u0440\u0435\u0432\u044b\u0434\u0435\u043b\u0435\u043d\u0438\u044f \u043c\u0430\u0441\u0441\u0438\u0432\u0430 \u0443 \u043d\u0430\u0441 \u043f\u0440\u043e\u0441\u0442\u0430\u044f non-atomic \u0437\u0430\u043f\u0438\u0441\u044c \u0432 slice header (3 \u043c\u0430\u0448\u0438\u043d\u043d\u044b\u0445 \u0441\u043b\u043e\u0432\u0430: pointer, len, cap) \u043e\u0434\u043d\u043e\u0432\u0440\u0435\u043c\u0435\u043d\u043d\u043e \u0441 \u0447\u0442\u0435\u043d\u0438\u0435\u043c. \u041d\u0430 amd64 \u044d\u0442\u043e \u0432\u0438\u0434\u043d\u043e go test -race<\/code> \u0441\u0440\u0430\u0437\u0443, \u0430 \u0432 production \u2014 \u0431\u0443\u0434\u0435\u0442 \u0432\u0441\u043f\u043b\u044b\u0432\u0430\u0442\u044c \u0440\u0430\u0437 \u0432 \u0441\u0443\u0442\u043a\u0438 \u0432 \u0432\u0438\u0434\u0435 \u201cinternal error\u201d \u0438\u043b\u0438 \u043d\u0435\u0432\u0438\u0434\u0438\u043c\u043e \u0440\u0443\u0448\u0438\u0442\u044c \u0438\u043d\u0432\u0430\u0440\u0438\u0430\u043d\u0442\u044b.<\/p>\n
\u041f\u0440\u0430\u0432\u0438\u043b\u044c\u043d\u043e:<\/p>\n
func (r *InMemoryClickRepository) Save(c *CampaignClick) error {    r.mu.Lock()    defer r.mu.Unlock()    r.clicks = append(r.clicks, c)    return nil}<\/code>
<\/a><\/div><\/pre>\n
\u041c\u043e\u0440\u0430\u043b\u044c:<\/strong> \u0415\u0441\u043b\u0438 \u0432\u0438\u0434\u0438\u0448\u044c sync.Mutex<\/code> \u0432 \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0435 \u2014 \u043f\u0440\u043e\u0432\u0435\u0440\u044c \u0412\u0421\u0415 \u043c\u0435\u0442\u043e\u0434\u044b, \u0433\u0434\u0435 \u043c\u0435\u043d\u044f\u0435\u0442\u0441\u044f \u0441\u043e\u0441\u0442\u043e\u044f\u043d\u0438\u0435. \u041e\u0434\u0438\u043d \u0437\u0430\u0431\u044b\u0442\u044b\u0439 Lock()<\/code> \u043e\u0431\u043d\u0443\u043b\u044f\u0435\u0442 \u0432\u0441\u044e \u0437\u0430\u0449\u0438\u0442\u0443. \u0418 \u0434\u0430, \u0432\u0441\u0435\u0433\u0434\u0430 \u0433\u043e\u043d\u044f\u0439 go test -race<\/code> \u0432 CI. \u042d\u0442\u043e \u043d\u0435 \u043e\u043f\u0446\u0438\u043e\u043d\u0430\u043b\u044c\u043d\u043e.<\/p>\n\n
2. Goroutine Leak \u2014 \u0441\u0430\u043c\u0430\u044f \u043a\u0440\u0430\u0441\u0438\u0432\u0430\u044f \u0437\u0430\u0441\u0430\u0434\u0430<\/h3>\n
\u0414\u0430\u043b\u044c\u0448\u0435 \u043d\u0430\u0442\u044b\u043a\u0430\u044e\u0441\u044c \u043d\u0430 \u044d\u0442\u043e\u0442 \u0448\u0435\u0434\u0435\u0432\u0440:<\/p>\n
type Publisher struct {    topic string    out   chan *CampaignClick}func NewPublisher(topic string, buffer int) *Publisher {    return &Publisher{        topic: topic,        out:   make(chan *CampaignClick, buffer),    }}func (p *Publisher) Publish(c *CampaignClick) {    select {    case p.out <- c:    default:    }}<\/code>
<\/a><\/div><\/pre>\n
\u0418 \u043f\u043e\u0442\u043e\u043c \u0432 handler\u2019\u0435:<\/p>\n
go c.publisher.Publish(click)<\/code>
<\/a><\/div><\/pre>\n
\u0422\u0443\u0442 \u0443 \u043c\u0435\u043d\u044f \u0441\u0440\u0430\u0437\u0443 \u0441\u0440\u0430\u0431\u043e\u0442\u0430\u043b\u0430 \u043f\u0440\u0438\u0432\u044b\u0447\u043a\u0430: \u0432\u0438\u0436\u0443 chan<\/code> \u0432 \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0435 \u2014 \u0438\u0449\u0443 <-<\/code> \u0433\u0434\u0435-\u0442\u043e \u0435\u0449\u0451 \u0432 \u043a\u043e\u0434\u0435, \u0447\u0442\u043e\u0431\u044b \u043f\u043e\u043d\u044f\u0442\u044c, \u043a\u0442\u043e consumer. \u0413\u0440\u0435\u043f\u0430\u044e publisher.out<\/code> \u043f\u043e \u0444\u0430\u0439\u043b\u0443 \u2014 \u043d\u0438 \u043e\u0434\u043d\u043e\u0433\u043e receive\u2019\u0430. \u041d\u0435\u0442 \u043d\u0438 \u0433\u043e\u0440\u0443\u0442\u0438\u043d\u044b-consumer\u2019\u0430, \u043d\u0438 \u0434\u0430\u0436\u0435 \u043c\u0435\u0442\u043e\u0434\u0430 Run()<\/code>\/Start()<\/code>.<\/p>\n
\u0413\u043e\u0432\u043e\u0440\u044e \u0438\u043d\u0442\u0435\u0440\u0432\u044c\u044e\u0435\u0440\u0443: \u201c\u041a\u0430\u043d\u0430\u043b \u0435\u0441\u0442\u044c, producer \u0435\u0441\u0442\u044c, \u0430 consumer\u2019\u0430 \u043d\u0435\u0442. \u0421\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u043d\u0430\u043a\u043e\u043f\u044f\u0442\u0441\u044f \u0434\u043e \u0431\u0443\u0444\u0435\u0440\u0430 \u043d\u0430 100 \u044d\u043b\u0435\u043c\u0435\u043d\u0442\u043e\u0432, \u0434\u0430\u043b\u044c\u0448\u0435 default<\/code> \u0441\u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442 \u2014 \u0438 \u043c\u044b \u0431\u0443\u0434\u0435\u043c \u043c\u043e\u043b\u0447\u0430 \u0442\u0435\u0440\u044f\u0442\u044c \u043a\u043b\u0438\u043a\u0438. \u041c\u0435\u0442\u0440\u0438\u043a\u0438 \u043d\u0430 \u044d\u0442\u043e \u043d\u0435\u0442, \u043e\u0448\u0438\u0431\u043a\u0438 \u043d\u0435\u0442, \u0432 \u043b\u043e\u0433\u0430\u0445 \u043f\u0443\u0441\u0442\u043e. \u0412 ad-tech \u044d\u0442\u043e \u0434\u0435\u043d\u044c\u0433\u0438, \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u0443\u043b\u0435\u0442\u0430\u044e\u0442 \u0432 \/dev\/null\u201d. \u042d\u0442\u043e \u0432\u0442\u043e\u0440\u043e\u0439 \u043f\u043e\u0439\u043c\u0430\u043d\u043d\u044b\u0439 \u0431\u0430\u0433.<\/p>\n
\u0422\u043e \u0435\u0441\u0442\u044c: \u043a\u0430\u043d\u0430\u043b \u043d\u0430 100 \u044d\u043b\u0435\u043c\u0435\u043d\u0442\u043e\u0432, \u0437\u0430\u043f\u043e\u043b\u043d\u044f\u0435\u0442\u0441\u044f \u0434\u043e \u0443\u043f\u043e\u0440\u0430, \u043f\u043e\u0442\u043e\u043c default<\/code> \u0441\u0440\u0430\u0431\u0430\u0442\u044b\u0432\u0430\u0435\u0442 \u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u043f\u0440\u043e\u0441\u0442\u043e \u043c\u043e\u043b\u0447\u0430 \u0442\u0435\u0440\u044f\u044e\u0442\u0441\u044f<\/strong>. \u0421\u0435\u0440\u0432\u0438\u0441 \u0442\u0440\u0435\u043a\u0430\u0435\u0442 \u043a\u043b\u0438\u043a\u0438 (\u044d\u0442\u043e \u0434\u0435\u043d\u044c\u0433\u0438 \u0432 ad-tech!), \u043d\u043e \u043f\u043e\u043b\u043e\u0432\u0438\u043d\u0443 \u0438\u0437 \u043d\u0438\u0445 \u0432\u044b\u0431\u0440\u0430\u0441\u044b\u0432\u0430\u0435\u0442 \u0432 \/dev\/null. \u0418 \u043d\u0438\u043a\u0442\u043e \u043d\u0435 \u0443\u0437\u043d\u0430\u0435\u0442, \u043f\u043e\u0442\u043e\u043c\u0443 \u0447\u0442\u043e \u043e\u0448\u0438\u0431\u043a\u0438 \u043d\u0435\u0442, \u043c\u0435\u0442\u0440\u0438\u043a\u0438 \u043d\u0435\u0442, \u043d\u0438\u0447\u0435\u0433\u043e \u043d\u0435\u0442.<\/p>\n
\u041f\u043b\u044e\u0441 \u043a \u044d\u0442\u043e\u043c\u0443 \u2014 go c.publisher.Publish(click)<\/code> \u0437\u0430\u043f\u0443\u0441\u043a\u0430\u0435\u0442 \u0433\u043e\u0440\u0443\u0442\u0438\u043d\u0443, \u043a\u043e\u0442\u043e\u0440\u0430\u044f \u043a\u043b\u0430\u0434\u0451\u0442 \u044d\u043b\u0435\u043c\u0435\u043d\u0442 \u0432 \u0431\u0443\u0444\u0435\u0440. \u042d\u0442\u043e \u0432 99% \u0441\u043b\u0443\u0447\u0430\u0435\u0432 \u043b\u0438\u0448\u043d\u0435\u0435: Publish<\/code> \u043d\u0435\u0431\u043b\u043e\u043a\u0438\u0440\u0443\u044e\u0449\u0438\u0439, \u0435\u0433\u043e \u043c\u043e\u0436\u043d\u043e \u0432\u044b\u0437\u0432\u0430\u0442\u044c \u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u043e. \u041b\u0438\u0448\u043d\u044f\u044f \u0433\u043e\u0440\u0443\u0442\u0438\u043d\u0430 = \u043b\u0438\u0448\u043d\u0438\u0439 overhead \u043d\u0430 scheduler. \u0410 \u0435\u0441\u043b\u0438 \u043a \u043c\u043e\u043c\u0435\u043d\u0442\u0443 \u0437\u0430\u043f\u0443\u0441\u043a\u0430 \u0433\u043e\u0440\u0443\u0442\u0438\u043d\u044b \u043f\u0440\u043e\u0446\u0435\u0441\u0441 \u043f\u043e\u043b\u0443\u0447\u0438\u0442 SIGTERM (\u0441\u043c. graceful shutdown \u0432\u043e \u0432\u0442\u043e\u0440\u043e\u0439 \u0447\u0430\u0441\u0442\u0438) \u2014 \u0433\u043e\u0440\u0443\u0442\u0438\u043d\u0430 \u043f\u0440\u043e\u0441\u0442\u043e \u0443\u043c\u0440\u0451\u0442 \u043d\u0430 \u043f\u043e\u043b\u043f\u0443\u0442\u0438.<\/p>\n
\u041f\u0440\u0430\u0432\u0438\u043b\u044c\u043d\u043e:<\/p>\n
type Publisher struct {    topic string    out   chan *CampaignClick    done  chan struct{}}func NewPublisher(topic string, buffer int) *Publisher {    p := &Publisher{        topic: topic,        out:   make(chan *CampaignClick, buffer),        done:  make(chan struct{}),    }    go p.run() \/\/ \u0437\u0430\u043f\u0443\u0441\u043a\u0430\u0435\u043c consumer!    return p}func (p *Publisher) run() {    for c := range p.out {        if err := sendToBroker(p.topic, c); err != nil {            log.Printf(\"publish failed: %v\", err)            \/\/ metric: dropped_messages++        }    }    close(p.done)}func (p *Publisher) Publish(c *CampaignClick) error {    select {    case p.out <- c:        return nil    default:        return errors.New(\"publisher buffer full\") \/\/ \u0445\u043e\u0442\u044f \u0431\u044b \u0437\u043d\u0430\u0435\u043c!    }}func (p *Publisher) Close(ctx context.Context) error {    close(p.out)    select {    case <-p.done:        return nil    case <-ctx.Done():        return ctx.Err()    }}<\/code>
<\/a><\/div><\/pre>\n
\u0412 Go 1.26 \u0437\u0430\u0432\u0435\u0437\u043b\u0438 \u044d\u043a\u0441\u043f\u0435\u0440\u0438\u043c\u0435\u043d\u0442\u0430\u043b\u044c\u043d\u044b\u0439 \u043f\u0440\u043e\u0444\u0430\u0439\u043b\u0435\u0440 GOEXPERIMENT=goroutineleakprofile<\/code> \u2014 \u043e\u043d \u043b\u043e\u0432\u0438\u0442 \u0440\u043e\u0432\u043d\u043e \u0442\u0430\u043a\u0438\u0435 \u0441\u0446\u0435\u043d\u0430\u0440\u0438\u0438. \u0417\u0430\u043f\u0443\u0441\u043a\u0430\u0439\u0442\u0435 \u043d\u0430 staging \u0438 \u0441\u043c\u043e\u0442\u0440\u0438\u0442\u0435, \u0447\u0442\u043e \u0442\u0435\u0447\u0451\u0442. \u0421\u043e\u0431\u0435\u0441 \u043f\u0440\u043e\u0445\u043e\u0434\u0438\u043b \u0435\u0449\u0435 \u043d\u0430 Go 1.24<\/p>\n
\u041c\u043e\u0440\u0430\u043b\u044c:<\/strong> \u041a\u0430\u0436\u0434\u044b\u0439 chan<\/code> \u0434\u043e\u043b\u0436\u0435\u043d \u0438\u043c\u0435\u0442\u044c \u0438 producer\u2019\u0430, \u0438 consumer\u2019\u0430. \u0415\u0441\u043b\u0438 \u043a\u0430\u043d\u0430\u043b \u0441\u043e\u0437\u0434\u0430\u043d, \u043d\u043e \u043d\u0438\u043a\u0442\u043e \u0438\u0437 \u043d\u0435\u0433\u043e \u043d\u0435 \u0447\u0438\u0442\u0430\u0435\u0442 \u2014 \u044d\u0442\u043e \u043b\u0438\u0431\u043e memory leak (\u0435\u0441\u043b\u0438 \u043a\u0430\u043d\u0430\u043b \u043d\u0435\u0431\u0443\u0444\u043a\u0440\u0438\u0437\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u044b\u0439 \u2014 \u0433\u043e\u0440\u0443\u0442\u0438\u043d\u044b \u0432\u0438\u0441\u044f\u0442 \u043d\u0430 send), \u043b\u0438\u0431\u043e \u0442\u0438\u0445\u0430\u044f \u043f\u043e\u0442\u0435\u0440\u044f \u0434\u0430\u043d\u043d\u044b\u0445 (\u0435\u0441\u043b\u0438 \u0431\u0443\u0444\u0435\u0440\u0438\u0437\u043e\u0432\u0430\u043d\u043d\u044b\u0439 + default<\/code>). \u0418 \u043d\u0438\u043a\u043e\u0433\u0434\u0430, \u041d\u0418\u041a\u041e\u0413\u0414\u0410 \u043d\u0435 \u0433\u043b\u043e\u0442\u0430\u0439 \u043e\u0448\u0438\u0431\u043a\u0443 \u043f\u0443\u0431\u043b\u0438\u043a\u0430\u0446\u0438\u0438 \u0431\u0435\u0437 \u043c\u0435\u0442\u0440\u0438\u043a\u0438.<\/p>\n\n
3. Publisher \u043f\u043e \u0437\u043d\u0430\u0447\u0435\u043d\u0438\u044e \u2014 \u043a\u043e\u043f\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u0435 \u043a\u0430\u043d\u0430\u043b\u0430<\/h3>\n
\u0421\u043c\u043e\u0442\u0440\u044e \u0432 main<\/code>:<\/p>\n
publisher := NewPublisher(\"clicks\", 100)  \/\/ \u0432\u043e\u0437\u0432\u0440\u0430\u0449\u0430\u0435\u0442 *Publisherctrl := NewController(repo, *publisher)   \/\/ \u0440\u0430\u0437\u044b\u043c\u0435\u043d\u043e\u0432\u044b\u0432\u0430\u0435\u043c!<\/code>
<\/a><\/div><\/pre>\n
\u0418 \u0441\u0438\u0433\u043d\u0430\u0442\u0443\u0440\u0430:<\/p>\n
func NewController(repo *InMemoryClickRepository, publisher Publisher) *ClickController {    return &ClickController{        repo:      repo,        publisher: publisher,  \/\/ \u043a\u043e\u043f\u0438\u044f!    }}<\/code>
<\/a><\/div><\/pre>\n
Publisher<\/code> \u043f\u0435\u0440\u0435\u0434\u0430\u0451\u0442\u0441\u044f \u043f\u043e \u0437\u043d\u0430\u0447\u0435\u043d\u0438\u044e<\/strong>, \u0431\u0435\u0437 \u0443\u043a\u0430\u0437\u0430\u0442\u0435\u043b\u044f. \u0426\u0435\u043f\u043b\u044f\u044e\u0441\u044c \u0441\u0440\u0430\u0437\u0443: \u0432\u043d\u0443\u0442\u0440\u0438 Publisher<\/code> \u2014 chan *CampaignClick<\/code>, \u043f\u0440\u0438 \u043a\u043e\u043f\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u0438 \u043c\u044b \u043a\u043e\u043f\u0438\u0440\u0443\u0435\u043c header \u043a\u0430\u043d\u0430\u043b\u0430. \u0421\u0435\u0439\u0447\u0430\u0441 \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442, \u043d\u043e \u044d\u0442\u043e \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442 \u0441\u043b\u0443\u0447\u0430\u0439\u043d\u043e<\/strong> \u2014 \u0441\u0442\u043e\u0438\u0442 \u0434\u043e\u0431\u0430\u0432\u0438\u0442\u044c \u043b\u044e\u0431\u043e\u0435 \u043c\u0443\u0442\u0430\u0431\u0435\u043b\u044c\u043d\u043e\u0435 \u043f\u043e\u043b\u0435 (\u0441\u0447\u0451\u0442\u0447\u0438\u043a, mutex), \u0438 \u043a\u043e\u043f\u0438\u044f \u043d\u0430\u0447\u043d\u0451\u0442 \u0436\u0438\u0442\u044c \u0441\u0432\u043e\u0435\u0439 \u0436\u0438\u0437\u043d\u044c\u044e.<\/p>\n
\u041a\u0430\u043d\u0430\u043b\u044b \u0432 Go \u2014 \u044d\u0442\u043e reference type, \u043f\u0440\u0438 \u043a\u043e\u043f\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u0438 \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u044b \u043c\u044b \u043a\u043e\u043f\u0438\u0440\u0443\u0435\u043c \u0441\u0430\u043c header \u043a\u0430\u043d\u0430\u043b\u0430, \u0430 \u043d\u0435 \u0441\u043e\u0434\u0435\u0440\u0436\u0438\u043c\u043e\u0435. \u0422\u043e \u0435\u0441\u0442\u044c \u0444\u043e\u0440\u043c\u0430\u043b\u044c\u043d\u043e \u043e\u0431\u0430 Publisher<\/code>\u2019\u0430 \u0443\u043a\u0430\u0437\u044b\u0432\u0430\u044e\u0442 \u043d\u0430 \u043e\u0434\u0438\u043d \u043a\u0430\u043d\u0430\u043b. \u041d\u043e \u044d\u0442\u043e \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442 \u0441\u043b\u0443\u0447\u0430\u0439\u043d\u043e.<\/strong> \u0421\u0442\u043e\u0438\u0442 \u0434\u043e\u0431\u0430\u0432\u0438\u0442\u044c \u0432 Publisher<\/code> \u043b\u044e\u0431\u043e\u0435 \u043c\u0443\u0442\u0430\u0431\u0435\u043b\u044c\u043d\u043e\u0435 \u043f\u043e\u043b\u0435 (\u0441\u0447\u0451\u0442\u0447\u0438\u043a, mutex, slice \u0441\u0442\u0430\u0442\u0438\u0441\u0442\u0438\u043a\u0438) \u2014 \u0438 \u043a\u043e\u043f\u0438\u044f \u043d\u0430\u0447\u0438\u043d\u0430\u0435\u0442 \u0436\u0438\u0442\u044c \u0441\u0432\u043e\u0435\u0439 \u0436\u0438\u0437\u043d\u044c\u044e. \u0418\u0437\u043c\u0435\u043d\u0435\u043d\u0438\u044f \u0432 \u043e\u0434\u043d\u043e\u0439 \u043a\u043e\u043f\u0438\u0438 \u043d\u0435 \u0432\u0438\u0434\u043d\u044b \u0432 \u0434\u0440\u0443\u0433\u043e\u0439. Hello debugging from hell.<\/p>\n
\u041f\u043b\u044e\u0441: \u0435\u0441\u043b\u0438 \u043a\u0442\u043e-\u0442\u043e \u0434\u043e\u0431\u0430\u0432\u0438\u0442 \u043c\u0435\u0442\u043e\u0434, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u043c\u0435\u043d\u044f\u0435\u0442 \u0441\u043e\u0441\u0442\u043e\u044f\u043d\u0438\u0435:<\/p>\n
func (p *Publisher) IncrementSent() {    p.sent++ \/\/ \u0432 \u041a\u041e\u041f\u0418\u0418 \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u044b!}<\/code>
<\/a><\/div><\/pre>\n
\u2014 \u044d\u0442\u043e \u043f\u0440\u043e\u0441\u0442\u043e \u043d\u0435 \u0431\u0443\u0434\u0435\u0442 \u0440\u0430\u0431\u043e\u0442\u0430\u0442\u044c. \u0418 \u0442\u044b \u0431\u0443\u0434\u0435\u0448\u044c \u0434\u0432\u0430 \u0434\u043d\u044f \u0433\u0430\u0434\u0430\u0442\u044c \u043f\u043e\u0447\u0435\u043c\u0443.<\/p>\n
\u041f\u0440\u0430\u0432\u0438\u043b\u044c\u043d\u043e \u2014 \u0432\u0441\u0435\u0433\u0434\u0430 \u043f\u0435\u0440\u0435\u0434\u0430\u0432\u0430\u0442\u044c \u043f\u043e \u0443\u043a\u0430\u0437\u0430\u0442\u0435\u043b\u044e<\/strong>, \u0435\u0441\u043b\u0438 \u0432 \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0435 \u0435\u0441\u0442\u044c mutex, channel, slice \u0438\u043b\u0438 map:<\/p>\n
func NewController(repo *InMemoryClickRepository, publisher *Publisher) *ClickController {    return &ClickController{        repo:      repo,        publisher: publisher,    }}\/\/ \u0432 main:ctrl := NewController(repo, publisher)  \/\/ \u0431\u0435\u0437 \u0437\u0432\u0451\u0437\u0434\u043e\u0447\u043a\u0438<\/code>
<\/a><\/div><\/pre>\n
\u0415\u0449\u0451 \u043b\u0443\u0447\u0448\u0435 \u2014 \u043f\u0440\u0438\u043d\u0438\u043c\u0430\u0442\u044c interface<\/strong>, \u0430 \u043d\u0435 \u043a\u043e\u043d\u043a\u0440\u0435\u0442\u043d\u044b\u0439 \u0442\u0438\u043f:<\/p>\n
type ClickPublisher interface {    Publish(c *CampaignClick) error}func NewController(repo *InMemoryClickRepository, publisher ClickPublisher) *ClickController {    \/\/ \u0442\u0435\u0441\u0442\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u0432 10 \u0440\u0430\u0437 \u043f\u0440\u043e\u0449\u0435, \u043c\u043e\u043a\u0438 \u0434\u0435\u043b\u0430\u044e\u0442\u0441\u044f \u0437\u0430 \u043c\u0438\u043d\u0443\u0442\u0443}<\/code>
<\/a><\/div><\/pre>\n
\u041c\u043e\u0440\u0430\u043b\u044c:<\/strong> \u0421\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u044b \u0441 \u043a\u0430\u043d\u0430\u043b\u0430\u043c\u0438\/\u043c\u044c\u044e\u0442\u0435\u043a\u0441\u0430\u043c\u0438\/\u0441\u043b\u0430\u0439\u0441\u0430\u043c\u0438 \u2014 \u0432\u0441\u0435\u0433\u0434\u0430 \u043f\u043e \u0443\u043a\u0430\u0437\u0430\u0442\u0435\u043b\u044e<\/strong>. go vet<\/code> \u043f\u043e\u0439\u043c\u0430\u0435\u0442 \u043a\u043e\u043f\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u0435 \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u044b \u0441 sync.Mutex<\/code>, \u043d\u043e \u043d\u0435 \u0441 \u043a\u0430\u043d\u0430\u043b\u043e\u043c \u2014 \u044d\u0442\u043e \u0431\u043b\u0430\u0439\u043d\u0434-\u0441\u043f\u043e\u0442 \u043b\u0438\u043d\u0442\u0435\u0440\u0430. \u0415\u0441\u043b\u0438 \u043a\u043e\u0434 \u0443\u0434\u043e\u0431\u043d\u043e \u043c\u043e\u043a\u0430\u0442\u044c \u2014 \u043e\u043d \u0443\u0434\u043e\u0431\u043d\u043e \u0442\u0435\u0441\u0442\u0438\u0440\u0443\u0435\u0442\u0441\u044f. \u041f\u0440\u044f\u0447\u044c \u043a\u043e\u043d\u043a\u0440\u0435\u0442\u043d\u044b\u0435 \u0442\u0438\u043f\u044b \u0437\u0430 \u0438\u043d\u0442\u0435\u0440\u0444\u0435\u0439\u0441\u0430\u043c\u0438.<\/p>\n\n
4. Memory Leak \u0432 \u201cin-memory storage\u201d<\/h3>\n
func (r *InMemoryClickRepository) PurgeOld() {    r.mu.Lock()    defer r.mu.Unlock()    cutoff := time.Now().Add(-5 * time.Minute)    for i := len(r.clicks) - 1; i >= 0; i-- {        if r.clicks[i].CreatedAt.Before(cutoff) {            r.clicks = append(r.clicks[:i], r.clicks[i+1:]...)        }    }}<\/code>
<\/a><\/div><\/pre>\n
\u041c\u0435\u0442\u043e\u0434 \u0435\u0441\u0442\u044c. \u041d\u043e \u0444\u0438\u0448\u043a\u0430: \u043d\u0438\u043a\u0442\u043e \u0435\u0433\u043e \u043d\u0435 \u0432\u044b\u0437\u044b\u0432\u0430\u0435\u0442.<\/strong> \u041f\u0435\u0440\u0435\u0433\u0440\u0435\u043f\u0430\u043b \u0432\u0435\u0441\u044c main.go \u2014 PurgeOld<\/code> \u0443\u043f\u043e\u043c\u044f\u043d\u0443\u0442 \u0442\u043e\u043b\u044c\u043a\u043e \u0432 \u0441\u0430\u043c\u043e\u043c \u043e\u043f\u0440\u0435\u0434\u0435\u043b\u0435\u043d\u0438\u0438.<\/p>\n
\u0427\u0442\u043e \u0432 \u0438\u0442\u043e\u0433\u0435: \u043f\u0440\u0438 1000 RPS \u0437\u0430 \u0447\u0430\u0441 \u0441\u0435\u0440\u0432\u0438\u0441 \u043d\u0430\u043a\u043e\u043f\u0438\u0442 3.6 \u043c\u043b\u043d \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440, \u0437\u0430 \u0434\u0435\u043d\u044c \u2014 86 \u043c\u043b\u043d. \u0427\u0435\u0440\u0435\u0437 \u043d\u0435\u0434\u0435\u043b\u044e pod \u043f\u0430\u0434\u0430\u0435\u0442 \u0441 OOM. \u0418 \u044d\u0442\u043e \u0432 production, \u0432 \u0441\u0443\u0431\u0431\u043e\u0442\u0443 \u043d\u043e\u0447\u044c\u044e, \u043a\u043e\u0433\u0434\u0430 \u043d\u0438\u043a\u0442\u043e \u043d\u0435 \u0432\u0438\u0434\u0438\u0442.<\/p>\n
\u041f\u0440\u0430\u0432\u0438\u043b\u044c\u043d\u043e \u2014 \u0437\u0430\u043f\u0443\u0441\u043a\u0430\u0442\u044c \u0432 \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u043e\u0439 \u0433\u043e\u0440\u0443\u0442\u0438\u043d\u0435 \u0447\u0435\u0440\u0435\u0437 ticker:<\/p>\n
func (r *InMemoryClickRepository) StartPurger(ctx context.Context, interval time.Duration) {    go func() {        ticker := time.NewTicker(interval)        defer ticker.Stop()        for {            select {            case <-ctx.Done():                return            case <-ticker.C:                r.PurgeOld()            }        }    }()}<\/code>
<\/a><\/div><\/pre>\n
\u0418 \u0432\u044b\u0437\u0432\u0430\u0442\u044c \u0438\u0437 main<\/code>:<\/p>\n
ctx, cancel := context.WithCancel(context.Background())defer cancel()repo.StartPurger(ctx, 1*time.Minute)<\/code>
<\/a><\/div><\/pre>\n
\u041c\u043e\u0440\u0430\u043b\u044c:<\/strong> \u0415\u0441\u043b\u0438 \u0442\u044b \u043d\u0430\u043f\u0438\u0441\u0430\u043b cleanup-\u043c\u0435\u0442\u043e\u0434 \u2014 \u041e\u0411\u042f\u0417\u0410\u0422\u0415\u041b\u042c\u041d\u041e \u0437\u0430\u043f\u0443\u0441\u0442\u0438 \u0435\u0433\u043e. \u0418 \u043f\u043e\u0441\u0442\u0430\u0432\u044c \u0430\u043b\u0435\u0440\u0442 \u043d\u0430 \u0440\u0430\u0437\u043c\u0435\u0440 in-memory \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440 (\u0447\u0435\u0440\u0435\u0437 expvar<\/code> \u0438\u043b\u0438 Prometheus). \u201cIn-memory\u201d \u043d\u0435 \u0437\u043d\u0430\u0447\u0438\u0442 \u201cinfinity-memory\u201d.<\/p>\n\n
5. PurgeOld: \u0434\u0435\u0440\u0436\u0438\u043c Lock \u043d\u0430 O(N\u00b2) \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u0438<\/h3>\n
\u041a \u0442\u043e\u043c\u0443 \u0436\u0435 PurgeOld<\/code> \u043d\u0430\u043f\u0438\u0441\u0430\u043d \u043d\u0435\u044d\u0444\u0444\u0435\u043a\u0442\u0438\u0432\u043d\u043e. \u0421\u043c\u043e\u0442\u0440\u0438\u0442\u0435 \u0432\u043d\u0438\u043c\u0430\u0442\u0435\u043b\u044c\u043d\u0435\u0435:<\/p>\n
for i := len(r.clicks) - 1; i >= 0; i-- {    if r.clicks[i].CreatedAt.Before(cutoff) {        r.clicks = append(r.clicks[:i], r.clicks[i+1:]...)    }}<\/code>
<\/a><\/div><\/pre>\n
\u041a\u0430\u0436\u0434\u044b\u0439 append(r.clicks[:i], r.clicks[i+1:]...)<\/code> \u0434\u043b\u044f \u0443\u0434\u0430\u043b\u0435\u043d\u0438\u044f \u043e\u0434\u043d\u043e\u0433\u043e \u044d\u043b\u0435\u043c\u0435\u043d\u0442\u0430 \u2014 \u044d\u0442\u043e O(N) \u043a\u043e\u043f\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u0435<\/strong> \u043e\u0441\u0442\u0430\u0432\u0448\u0435\u0433\u043e\u0441\u044f \u0445\u0432\u043e\u0441\u0442\u0430. \u0415\u0441\u043b\u0438 \u043f\u0440\u043e\u0442\u0443\u0445\u043b\u043e K \u044d\u043b\u0435\u043c\u0435\u043d\u0442\u043e\u0432 \u0438\u0437 N \u2014 \u043f\u043e\u043b\u0443\u0447\u0430\u0435\u043c O(K\u00b7N)<\/strong>. \u041d\u0430 1\u041c \u043a\u043b\u0438\u043a\u043e\u0432 \u0441 100K \u043f\u0440\u043e\u0442\u0443\u0445\u0448\u0438\u0445 \u2014 \u044d\u0442\u043e 100 \u043c\u0438\u043b\u043b\u0438\u0430\u0440\u0434\u043e\u0432 \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u0439<\/strong>. \u041f\u043e\u0434 Lock.<\/p>\n
\u0418 \u0432\u0441\u0451 \u044d\u0442\u043e \u0432\u0440\u0435\u043c\u044f \u043d\u0438\u043a\u0442\u043e \u043d\u0435 \u043c\u043e\u0436\u0435\u0442 \u043d\u0438 \u0447\u0438\u0442\u0430\u0442\u044c, \u043d\u0438 \u043f\u0438\u0441\u0430\u0442\u044c<\/strong>. \u0421\u0435\u0440\u0432\u0438\u0441 \u0444\u0430\u043a\u0442\u0438\u0447\u0435\u0441\u043a\u0438 \u0437\u0430\u0432\u0438\u0441\u0430\u0435\u0442 \u043d\u0430 \u0434\u043b\u0438\u0442\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u0438 cleanup. RPS \u043f\u0440\u043e\u0441\u0430\u0436\u0438\u0432\u0430\u0435\u0442\u0441\u044f, latency \u0432\u0437\u043b\u0435\u0442\u0430\u0435\u0442, k8s \u043d\u0430\u0447\u0438\u043d\u0430\u0435\u0442 \u0440\u0435\u0441\u0442\u0430\u0440\u0442\u0438\u0442\u044c \u043f\u043e\u0434 \u0438\u0437-\u0437\u0430 readiness-\u043f\u0440\u043e\u0431.<\/p>\n
\u041f\u0440\u0430\u0432\u0438\u043b\u044c\u043d\u043e \u2014 \u0434\u0432\u0435 \u0441\u0442\u0430\u0434\u0438\u0438: \u043d\u0430\u0439\u0442\u0438 \u0442\u043e\u0447\u043a\u0443 \u0441\u0440\u0435\u0437\u0430, \u0441\u0434\u0435\u043b\u0430\u0442\u044c \u043e\u0434\u0438\u043d<\/strong> \u0441\u0440\u0435\u0437:<\/p>\n
func (r *InMemoryClickRepository) PurgeOld(maxAge time.Duration) {    cutoff := time.Now().Add(-maxAge)        r.mu.Lock()    defer r.mu.Unlock()        \/\/ clicks \u043e\u0442\u0441\u043e\u0440\u0442\u0438\u0440\u043e\u0432\u0430\u043d\u044b \u043f\u043e \u0432\u0440\u0435\u043c\u0435\u043d\u0438 \u0432\u0441\u0442\u0430\u0432\u043a\u0438 (Save \u043f\u043e\u0434 Lock)    \/\/ \u0438\u0449\u0435\u043c \u043f\u0435\u0440\u0432\u044b\u0439 \"\u0441\u0432\u0435\u0436\u0438\u0439\" \u044d\u043b\u0435\u043c\u0435\u043d\u0442 \u0447\u0435\u0440\u0435\u0437 \u0431\u0438\u043d\u0430\u0440\u043d\u044b\u0439 \u043f\u043e\u0438\u0441\u043a    idx := sort.Search(len(r.clicks), func(i int) bool {        return r.clicks[i].CreatedAt.After(cutoff)    })        if idx == 0 {        return \/\/ \u043d\u0435\u0447\u0435\u0433\u043e \u0443\u0434\u0430\u043b\u044f\u0442\u044c    }        \/\/ \u043e\u0434\u0438\u043d \u0441\u0440\u0435\u0437, O(N - idx) \u043a\u043e\u043f\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u0435    r.clicks = append(r.clicks[:0], r.clicks[idx:]...)}<\/code>
<\/a><\/div><\/pre>\n
\u0411\u043e\u043d\u0443\u0441 \u2014 \u0434\u043b\u044f \u0441\u043e\u0432\u0441\u0435\u043c \u0431\u043e\u043b\u044c\u0448\u043e\u0439 \u043d\u0430\u0433\u0440\u0443\u0437\u043a\u0438 \u043c\u043e\u0436\u043d\u043e \u0434\u0435\u043b\u0430\u0442\u044c swap-and-truncate, \u0447\u0442\u043e\u0431\u044b \u043e\u0441\u0432\u043e\u0431\u043e\u0434\u0438\u0442\u044c \u0441\u0442\u0430\u0440\u044b\u0439 underlying array:<\/p>\n
newClicks := make([]*CampaignClick, len(r.clicks)-idx)copy(newClicks, r.clicks[idx:])r.clicks = newClicks  \/\/ GC \u0437\u0430\u0431\u0435\u0440\u0451\u0442 \u0441\u0442\u0430\u0440\u044b\u0439 \u043c\u0430\u0441\u0441\u0438\u0432<\/code>
<\/a><\/div><\/pre>\n
\u041c\u043e\u0440\u0430\u043b\u044c:<\/strong> Lock \u2014 \u044d\u0442\u043e \u0431\u0443\u0442\u044b\u043b\u043e\u0447\u043d\u043e\u0435 \u0433\u043e\u0440\u043b\u044b\u0448\u043a\u043e. \u0412\u043d\u0443\u0442\u0440\u0438 Lock \u0434\u0435\u0440\u0436\u0438 \u0442\u043e\u043b\u044c\u043a\u043e<\/strong> \u0440\u0430\u0431\u043e\u0442\u0443 \u0441 \u0437\u0430\u0449\u0438\u0449\u0451\u043d\u043d\u044b\u043c \u0441\u0442\u0435\u0439\u0442\u043e\u043c, \u0438 \u0434\u0435\u043b\u0430\u0439 \u0435\u0451 \u0437\u0430 O(log N) \u0438\u043b\u0438 O(N), \u043d\u0435 \u0437\u0430 O(N\u00b2). \u0415\u0441\u043b\u0438 cleanup \u0442\u044f\u0436\u0451\u043b\u044b\u0439 \u2014 \u0432\u044b\u043d\u043e\u0441\u0438 \u0440\u0430\u0431\u043e\u0442\u0443 \u0437\u0430 Lock, \u043f\u043e\u0434 Lock \u0434\u0435\u043b\u0430\u0439 \u0442\u043e\u043b\u044c\u043a\u043e \u0444\u0438\u043d\u0430\u043b\u044c\u043d\u044b\u0439 swap.<\/p>\n\n
6. TOCTOU race \u0432 \u0434\u0435\u0434\u0443\u043f\u043b\u0438\u043a\u0430\u0446\u0438\u0438 \u2014 \u0442\u043e\u0442 \u0441\u0430\u043c\u044b\u0439, \u0447\u0442\u043e \u044f \u043f\u0440\u043e\u043f\u0443\u0441\u0442\u0438\u043b \u043d\u0430 \u0438\u043d\u0442\u0435\u0440\u0432\u044c\u044e<\/h3>\n
\u0410 \u0432\u043e\u0442 \u044d\u0442\u043e\u0442 \u0431\u0430\u0433 \u044f \u043f\u0440\u043e\u0432\u043e\u0440\u043e\u043d\u0438\u043b<\/strong>. \u041f\u0440\u043e\u0447\u0438\u0442\u0430\u043b handler, \u043f\u043e\u0441\u043c\u043e\u0442\u0440\u0435\u043b: \u201c\u0430\u0433\u0430, \u043f\u0440\u043e\u0432\u0435\u0440\u043a\u0430 \u0432 \u043a\u0435\u0448\u0435, \u0435\u0441\u043b\u0438 \u043d\u0435\u0442 \u2014 \u0441\u043e\u0437\u0434\u0430\u0451\u043c\u201d, \u0432\u0441\u0451 \u043b\u043e\u0433\u0438\u0447\u043d\u043e. \u0422\u0438\u043a\u0430\u043d\u044c\u0435 \u0442\u0430\u0439\u043c\u0435\u0440\u0430 \u0432 \u0433\u043e\u043b\u043e\u0432\u0435 \u2014 \u0438\u0434\u0443 \u0434\u0430\u043b\u044c\u0448\u0435. \u0418 \u0442\u043e\u043b\u044c\u043a\u043e \u0434\u043e\u043c\u0430, \u043f\u0435\u0440\u0435\u0447\u0438\u0442\u044b\u0432\u0430\u044f, \u043f\u043e\u043d\u044f\u043b, \u0447\u0435\u0433\u043e \u043d\u0435 \u0443\u0432\u0438\u0434\u0435\u043b. \u0421\u043c\u043e\u0442\u0440\u0438\u0442\u0435 \u043d\u0430 handler:<\/p>\n
if _, cached, ok := c.repo.GetRecent(req.UserUUID, req.CampaignUUID, c.cacheTTL); ok {    ctx.JSON(http.StatusOK, ClickResponse{...cached...})    return}click := &CampaignClick{...}c.repo.Save(click)<\/code>
<\/a><\/div><\/pre>\n
\u041a\u043b\u0430\u0441\u0441\u0438\u0447\u0435\u0441\u043a\u0438\u0439 TOCTOU<\/strong> (Time Of Check vs Time Of Use). \u041c\u0435\u0436\u0434\u0443 GetRecent<\/code> \u0438 Save<\/code> \u0434\u0440\u0443\u0433\u0430\u044f \u0433\u043e\u0440\u0443\u0442\u0438\u043d\u0430 \u043c\u043e\u0436\u0435\u0442 \u0443\u0441\u043f\u0435\u0442\u044c \u0441\u043e\u0445\u0440\u0430\u043d\u0438\u0442\u044c \u0434\u0443\u0431\u043b\u0438\u043a\u0430\u0442. \u041f\u043e\u043b\u0443\u0447\u0430\u0435\u043c \u0434\u0432\u0430 \u043a\u043b\u0438\u043a\u0430 \u0434\u043b\u044f \u043e\u0434\u043d\u043e\u0433\u043e (user, campaign)<\/code> \u0437\u0430 \u043e\u043a\u043d\u043e \u0434\u0435\u0434\u0443\u043f\u043b\u0438\u043a\u0430\u0446\u0438\u0438. \u0412 ad-tech \u044d\u0442\u043e \u0437\u043d\u0430\u0447\u0438\u0442 \u2014 \u0440\u0435\u043a\u043b\u0430\u043c\u043e\u0434\u0430\u0442\u0435\u043b\u044c \u043f\u043b\u0430\u0442\u0438\u0442 \u0434\u0432\u0430\u0436\u0434\u044b \u0437\u0430 \u043e\u0434\u043d\u043e\u0433\u043e \u044e\u0437\u0435\u0440\u0430.<\/p>\n
\u041f\u043e\u0447\u0435\u043c\u0443 \u043f\u0440\u043e\u043f\u0443\u0441\u0442\u0438\u043b: \u0433\u043b\u0430\u0437 \u0437\u0430\u0446\u0435\u043f\u0438\u043b\u0441\u044f \u0437\u0430 RWMutex<\/code> \u0432\u043d\u0443\u0442\u0440\u0438 \u0440\u0435\u043f\u043e\u0437\u0438\u0442\u043e\u0440\u0438\u044f \u2014 \u043c\u043e\u0437\u0433 \u0443\u0441\u043f\u043e\u043a\u043e\u0438\u043b\u0441\u044f (\u201c\u0442\u0430\u043c \u0436\u0435 synchronization\u201d). \u0410 \u0432\u043d\u0443\u0442\u0440\u0438 handler\u2019\u0430 \u043c\u0435\u0436\u0434\u0443 \u0434\u0432\u0443\u043c\u044f \u0432\u044b\u0437\u043e\u0432\u0430\u043c\u0438 \u044d\u0442\u043e\u0433\u043e \u0440\u0435\u043f\u043e\u0437\u0438\u0442\u043e\u0440\u0438\u044f Lock\u2019\u0430 \u043d\u0435\u0442 \u2014 \u0438 \u0431\u044b\u0442\u044c \u043d\u0435 \u043c\u043e\u0436\u0435\u0442, \u043f\u043e\u0442\u043e\u043c\u0443 \u0447\u0442\u043e \u0440\u0435\u043f\u043e\u0437\u0438\u0442\u043e\u0440\u0438\u0439 \u043d\u0435 \u0437\u043d\u0430\u0435\u0442 \u043f\u0440\u043e composite-\u043e\u043f\u0435\u0440\u0430\u0446\u0438\u0438 \u201c\u0441\u043d\u0430\u0447\u0430\u043b\u0430 \u043f\u0440\u043e\u0432\u0435\u0440\u044c, \u043f\u043e\u0442\u043e\u043c \u0441\u043e\u0445\u0440\u0430\u043d\u0438\u201d.<\/p>\n
\u0421\u0446\u0435\u043d\u0430\u0440\u0438\u0439:<\/p>\n
    \n
  1. \n
    Goroutine A: GetRecent(user1, camp1)<\/code> \u2192 \u043d\u0435 \u043d\u0430\u0448\u0451\u043b<\/p>\n<\/li>\n
  2. \n
    Goroutine B: GetRecent(user1, camp1)<\/code> \u2192 \u043d\u0435 \u043d\u0430\u0448\u0451\u043b<\/p>\n<\/li>\n
  3. \n
    Goroutine A: Save(click1)<\/code><\/p>\n<\/li>\n
  4. \n
    Goroutine B: Save(click2)<\/code> \u2190 \u0434\u0443\u0431\u043b\u0438\u043a\u0430\u0442!<\/p>\n<\/li>\n<\/ol>\n
    \u041f\u0440\u0430\u0432\u0438\u043b\u044c\u043d\u043e \u2014 \u0430\u0442\u043e\u043c\u0430\u0440\u043d\u0430\u044f \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u044f GetOrCreate<\/code> \u043d\u0430 \u0441\u0442\u043e\u0440\u043e\u043d\u0435 \u0440\u0435\u043f\u043e\u0437\u0438\u0442\u043e\u0440\u0438\u044f:<\/p>\n
    func (r *InMemoryClickRepository) GetOrCreate(    userUUID, campaignUUID string,    maxAge time.Duration,    factory func() *CampaignClick,) (click *CampaignClick, created bool) {    r.mu.Lock()    defer r.mu.Unlock()        cutoff := time.Now().Add(-maxAge)    for i := len(r.clicks) - 1; i >= 0; i-- {        cc := r.clicks[i]        if cc.UserUUID == userUUID && cc.CampaignUUID == campaignUUID && cc.CreatedAt.After(cutoff) {            return cc, false        }    }        newClick := factory()    r.clicks = append(r.clicks, newClick)    return newClick, true}<\/code>
    <\/a><\/div><\/pre>\n
    \u041e\u0434\u0438\u043d Lock \u043d\u0430 check + create. \u0414\u0443\u0431\u043b\u0438\u043a\u0430\u0442\u044b \u0438\u0441\u043a\u043b\u044e\u0447\u0435\u043d\u044b by design.<\/p>\n
    \u041c\u043e\u0440\u0430\u043b\u044c:<\/strong> \u0415\u0441\u043b\u0438 \u0443 \u0442\u0435\u0431\u044f \u0435\u0441\u0442\u044c \u043f\u043e\u0441\u043b\u0435\u0434\u043e\u0432\u0430\u0442\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u044c \u201c\u043f\u0440\u043e\u0432\u0435\u0440\u044c \u2014 \u043f\u043e\u0442\u043e\u043c \u0441\u0434\u0435\u043b\u0430\u0439\u201d \u2014 \u044d\u0442\u043e \u0432\u0441\u0435\u0433\u0434\u0430 race condition \u043c\u0435\u0436\u0434\u0443 \u0434\u0432\u0443\u043c\u044f \u0433\u043e\u0440\u0443\u0442\u0438\u043d\u0430\u043c\u0438. \u041e\u0431\u044a\u0435\u0434\u0438\u043d\u044f\u0439 \u0432 \u043e\u0434\u043d\u0443 \u0430\u0442\u043e\u043c\u0430\u0440\u043d\u0443\u044e \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u044e, \u043b\u0438\u0431\u043e \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0439 distributed lock (\u0435\u0441\u043b\u0438 \u043d\u0435\u0441\u043a\u043e\u043b\u044c\u043a\u043e \u043f\u043e\u0434\u043e\u0432).<\/p>\n\n
    7. O(N) \u043f\u043e\u0438\u0441\u043a \u2014 \u043f\u043e\u043a\u0430 100 \u043a\u043b\u0438\u043a\u043e\u0432, \u043f\u043e\u0442\u043e\u043c 100 \u043c\u0438\u043b\u043b\u0438\u043e\u043d\u043e\u0432<\/h3>\n
    \u0421\u043c\u043e\u0442\u0440\u044e \u043d\u0430 GetRecent<\/code>:<\/p>\n
    for i := len(r.clicks) - 1; i >= 0; i-- {    cc := r.clicks[i]    if cc.UserUUID == userUUID && cc.CampaignUUID == campaignUUID && cc.CreatedAt.After(cutoff) {        return cc, true    }}<\/code>
    <\/a><\/div><\/pre>\n
    \u041a\u0430\u0436\u0434\u044b\u0439 \u0437\u0430\u043f\u0440\u043e\u0441 \u2014 \u043b\u0438\u043d\u0435\u0439\u043d\u044b\u0439 \u043f\u0440\u043e\u0445\u043e\u0434 \u043f\u043e \u0432\u0441\u0435\u043c\u0443 \u0441\u043b\u0430\u0439\u0441\u0443. \u041d\u0430 1000 \u043a\u043b\u0438\u043a\u043e\u0432 \u2014 \u043d\u043e\u0440\u043c. \u041d\u0430 100M (\u0441\u043c. \u043f.4 \u043f\u0440\u043e \u0443\u0442\u0435\u0447\u043a\u0443) \u2014 \u043a\u0430\u0436\u0434\u044b\u0439 \u0437\u0430\u043f\u0440\u043e\u0441 \u0441\u0442\u0430\u043d\u043e\u0432\u0438\u0442\u0441\u044f \u0441\u0435\u043a\u0443\u043d\u0434\u043e\u0439. \u0421\u0435\u0440\u0432\u0438\u0441 \u043b\u043e\u0436\u0438\u0442\u0441\u044f. \u041f\u043e\u0434 Lock \u0434\u0435\u0440\u0436\u0438\u043c \u0442\u043e\u0436\u0435 \u0434\u043e\u043b\u0433\u043e.<\/p>\n
    \u041f\u0440\u0430\u0432\u0438\u043b\u044c\u043d\u043e \u2014 map \u043f\u043e \u0441\u043e\u0441\u0442\u0430\u0432\u043d\u043e\u043c\u0443 \u043a\u043b\u044e\u0447\u0443<\/strong>:<\/p>\n
    type clickKey struct {    userUUID, campaignUUID string}type InMemoryClickRepository struct {    mu      sync.RWMutex    byKey   map[clickKey]*CampaignClick \/\/ O(1) lookup    ordered []*CampaignClick             \/\/ \u0434\u043b\u044f PurgeOld}func (r *InMemoryClickRepository) GetRecent(userUUID, campaignUUID string, maxAge time.Duration) (*CampaignClick, bool) {    r.mu.RLock()    defer r.mu.RUnlock()        cc, ok := r.byKey[clickKey{userUUID, campaignUUID}]    if !ok {        return nil, false    }    if cc.CreatedAt.After(time.Now().Add(-maxAge)) {        return cc, true    }    return nil, false}<\/code>
    <\/a><\/div><\/pre>\n
    PurgeOld<\/code> \u0442\u0435\u043f\u0435\u0440\u044c \u0434\u043e\u043b\u0436\u0435\u043d \u043f\u043e\u0434\u0447\u0438\u0449\u0430\u0442\u044c \u043e\u0431\u0435 \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u044b \u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u043e. \u0427\u0443\u0442\u044c \u0441\u043b\u043e\u0436\u043d\u0435\u0435, \u043d\u043e lookup O(1).<\/p>\n
    \u041c\u043e\u0440\u0430\u043b\u044c:<\/strong> \u201cIn-memory\u201d \u2014 \u043d\u0435 \u0437\u043d\u0430\u0447\u0438\u0442 \u201c\u0431\u0435\u0441\u043a\u043e\u043d\u0435\u0447\u043d\u043e \u0431\u044b\u0441\u0442\u0440\u043e\u201d. \u0421\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0430 \u0434\u0430\u043d\u043d\u044b\u0445 \u0440\u0435\u0448\u0430\u0435\u0442. \u041b\u0438\u043d\u0435\u0439\u043d\u044b\u0439 \u043f\u043e\u0438\u0441\u043a \u043f\u043e 100M \u044d\u043b\u0435\u043c\u0435\u043d\u0442\u043e\u0432 \u0431\u0443\u0434\u0435\u0442 \u043c\u0435\u0434\u043b\u0435\u043d\u043d\u0435\u0435, \u0447\u0435\u043c \u0437\u0430\u043f\u0440\u043e\u0441 \u0432 \u0438\u043d\u0434\u0435\u043a\u0441\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u044b\u0439 PostgreSQL.<\/p>\n\n
    8. go publisher.Publish(click) \u2014 fire-and-forget \u0431\u0435\u0437 \u043e\u0442\u043c\u0435\u043d\u044b<\/h3>\n
    \u0412\u043e\u0437\u0432\u0440\u0430\u0449\u0430\u0435\u043c\u0441\u044f \u043a handler:<\/p>\n
    c.repo.Save(click)go c.publisher.Publish(click)  \/\/ fire and forget<\/code>
    <\/a><\/div><\/pre>\n
    \u041f\u043e\u043c\u0438\u043c\u043e \u0431\u0430\u0433\u043e\u0432 \u0438\u0437 \u043f\u0443\u043d\u043a\u0442\u0430 #2, \u0442\u0443\u0442 \u0435\u0441\u0442\u044c \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u0430\u044f \u043f\u0440\u043e\u0431\u043b\u0435\u043c\u0430: \u0433\u043e\u0440\u0443\u0442\u0438\u043d\u0430 \u0437\u0430\u043f\u0443\u0441\u043a\u0430\u0435\u0442\u0441\u044f \u0431\u0435\u0437 context\u2019\u0430<\/strong> \u0438 \u0431\u0435\u0437 \u043a\u0430\u043a\u043e\u0439-\u043b\u0438\u0431\u043e \u0441\u0432\u044f\u0437\u0438 \u0441 lifecycle \u0441\u0435\u0440\u0432\u0438\u0441\u0430. \u041a\u043e\u0433\u0434\u0430 \u043f\u0440\u0438\u0434\u0451\u0442 SIGTERM:<\/p>\n
      \n
    1. \n
      http.Server.Shutdown(ctx)<\/code> \u0434\u043e\u0436\u0438\u0434\u0430\u0435\u0442\u0441\u044f in-flight \u0437\u0430\u043f\u0440\u043e\u0441\u043e\u0432<\/p>\n<\/li>\n
    2. \n
      \u041d\u043e \u044d\u0442\u0438 \u0437\u0430\u043f\u0443\u0449\u0435\u043d\u043d\u044b\u0435 go publisher.Publish()<\/code> \u0433\u043e\u0440\u0443\u0442\u0438\u043d\u044b \u2014 \u043d\u0438\u043a\u0435\u043c \u043d\u0435 \u0443\u0447\u0438\u0442\u044b\u0432\u0430\u044e\u0442\u0441\u044f<\/strong><\/p>\n<\/li>\n
    3. \n
      \u041f\u0440\u043e\u0446\u0435\u0441\u0441 \u0437\u0430\u0432\u0435\u0440\u0448\u0430\u0435\u0442\u0441\u044f, \u0433\u043e\u0440\u0443\u0442\u0438\u043d\u044b \u0443\u043c\u0438\u0440\u0430\u044e\u0442 \u043d\u0430 \u043f\u043e\u043b\u043f\u0443\u0442\u0438<\/p>\n<\/li>\n<\/ol>\n
      \u0412 \u043d\u0430\u0448\u0435\u043c \u0441\u043b\u0443\u0447\u0430\u0435 Publish<\/code> \u0441\u0435\u0439\u0447\u0430\u0441 \u043f\u0440\u043e\u0441\u0442\u043e \u043f\u0438\u0448\u0435\u0442 \u0432 \u043a\u0430\u043d\u0430\u043b \u2014 \u044d\u0442\u043e \u0431\u044b\u0441\u0442\u0440\u043e. \u041d\u043e \u0437\u0430\u0432\u0442\u0440\u0430 \u043a\u0442\u043e-\u0442\u043e \u0437\u0430\u043c\u0435\u043d\u0438\u0442 \u0440\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u044e \u043d\u0430 \u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u044b\u0439 \u0432\u044b\u0437\u043e\u0432 \u0432 Kafka \u2014 \u0438 \u0442\u043e\u0433\u0434\u0430 in-flight publish\u2019\u0438 \u043f\u0440\u0438 shutdown \u0431\u0443\u0434\u0443\u0442 \u0442\u0435\u0440\u044f\u0442\u044c\u0441\u044f.<\/p>\n
      \u041f\u0440\u0430\u0432\u0438\u043b\u044c\u043d\u043e: \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c errgroup<\/code> \u0441 \u043a\u043e\u043d\u0442\u0435\u043a\u0441\u0442\u043e\u043c \u0441\u0435\u0440\u0432\u0438\u0441\u0430 \u043b\u0438\u0431\u043e \u043f\u0440\u0438\u043d\u0438\u043c\u0430\u0442\u044c context.Context<\/code> \u0432 Publish<\/code>:<\/p>\n
      func (p *Publisher) Publish(ctx context.Context, c *CampaignClick) error {    select {    case p.out <- c:        return nil    case <-ctx.Done():        return ctx.Err()    default:        return ErrBufferFull    }}<\/code>
      <\/a><\/div><\/pre>\n
      \u0418 \u0432 handler \u2014 \u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u043e:<\/p>\n
      if err := c.publisher.Publish(ctx.Request.Context(), click); err != nil {    log.Printf(\"publish failed: %v\", err)    \/\/ \u043d\u0435 \u043f\u0430\u0434\u0430\u0435\u043c \u2014 \u043a\u043b\u0438\u043a \u0443\u0436\u0435 \u0441\u043e\u0445\u0440\u0430\u043d\u0451\u043d, publish \u043c\u043e\u0436\u043d\u043e \u043e\u0442\u0440\u0435\u0442\u0440\u0430\u0438\u0442\u044c \u0438\u0437 \u0440\u0435\u043f\u043e\u0437\u0438\u0442\u043e\u0440\u0438\u044f}<\/code>
      <\/a><\/div><\/pre>\n
      \u041c\u043e\u0440\u0430\u043b\u044c:<\/strong> Fire-and-forget \u0433\u043e\u0440\u0443\u0442\u0438\u043d\u044b (go someFunc()<\/code>) \u2014 \u044d\u0442\u043e \u0434\u043e\u043b\u0433\u043e\u0432\u0430\u044f \u0440\u0430\u0441\u043f\u0438\u0441\u043a\u0430<\/strong>, \u043a\u043e\u0442\u043e\u0440\u0443\u044e \u043a\u0442\u043e-\u0442\u043e \u0440\u0430\u043d\u043e \u0438\u043b\u0438 \u043f\u043e\u0437\u0434\u043d\u043e \u043f\u0440\u0435\u0434\u044a\u044f\u0432\u0438\u0442. \u041a\u0430\u0436\u0434\u0430\u044f \u0442\u0430\u043a\u0430\u044f \u0433\u043e\u0440\u0443\u0442\u0438\u043d\u0430 \u0434\u043e\u043b\u0436\u043d\u0430 \u043b\u0438\u0431\u043e \u0438\u043c\u0435\u0442\u044c \u043f\u0440\u0438\u0432\u044f\u0437\u043a\u0443 \u043a lifecycle (\u0447\u0435\u0440\u0435\u0437 context\/wg\/errgroup), \u043b\u0438\u0431\u043e \u0431\u044b\u0442\u044c \u044f\u0432\u043d\u043e \u0437\u0430\u0434\u043e\u043a\u0443\u043c\u0435\u043d\u0442\u0438\u0440\u043e\u0432\u0430\u043d\u0430 \u043a\u0430\u043a \u201cbest-effort, may be lost\u201d.<\/p>\n\n
      \u0418\u0442\u043e\u0433\u043e \u0427\u0430\u0441\u0442\u044c 1: 8 \u043f\u0440\u043e\u0431\u043b\u0435\u043c concurrency & memory<\/h3>\n
      \n
      \n\n\n\n\n\n\n\n\n\n\n\n
      \n
      #<\/p>\n<\/th>\n
      		\n
      \u041f\u0440\u043e\u0431\u043b\u0435\u043c\u0430<\/p>\n<\/th>\n
      		\n
      \u0422\u0438\u043f<\/p>\n<\/th>\n<\/tr>\n
      \n
      1<\/p>\n<\/td>\n
      		\n
      \u0417\u0430\u0431\u044b\u0442\u044b\u0439 Lock<\/code> \u0432 Save<\/p>\n<\/td>\n
      		\n
      Data race<\/p>\n<\/td>\n<\/tr>\n
      \n
      2<\/p>\n<\/td>\n
      		\n
      \u041a\u0430\u043d\u0430\u043b \u0431\u0435\u0437 consumer\u2019\u0430<\/p>\n<\/td>\n
      		\n
      Goroutine leak \/ data loss<\/p>\n<\/td>\n<\/tr>\n
      \n
      3<\/p>\n<\/td>\n
      		\n
      Publisher \u043f\u043e \u0437\u043d\u0430\u0447\u0435\u043d\u0438\u044e<\/p>\n<\/td>\n
      		\n
      Channel duplication<\/p>\n<\/td>\n<\/tr>\n
      \n
      4<\/p>\n<\/td>\n
      		\n
      PurgeOld \u043d\u0435 \u0432\u044b\u0437\u044b\u0432\u0430\u0435\u0442\u0441\u044f<\/p>\n<\/td>\n
      		\n
      Memory leak<\/p>\n<\/td>\n<\/tr>\n
      \n
      5<\/p>\n<\/td>\n
      		\n
      PurgeOld O(N\u00b2) \u043f\u043e\u0434 Lock<\/p>\n<\/td>\n
      		\n
      Latency spike<\/p>\n<\/td>\n<\/tr>\n
      \n
      6<\/p>\n<\/td>\n
      		\n
      TOCTOU race \u0432 \u0434\u0435\u0434\u0443\u043f\u043b\u0438\u043a\u0430\u0446\u0438\u0438<\/p>\n<\/td>\n
      		\n
      Race condition<\/p>\n<\/td>\n<\/tr>\n
      \n
      7<\/p>\n<\/td>\n
      		\n
      O(N) \u043f\u043e\u0438\u0441\u043a \u0432 \u0433\u043e\u0440\u044f\u0447\u0435\u043c \u043f\u0443\u0442\u0438<\/p>\n<\/td>\n
      		\n
      Performance<\/p>\n<\/td>\n<\/tr>\n
      \n
      8<\/p>\n<\/td>\n
      		\n
      go publisher.Publish()<\/code> \u0431\u0435\u0437 context<\/p>\n<\/td>\n
      		\n
      Fire-and-forget leak<\/p>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/div>\n<\/div>\n
      \u0418\u0437 \u044d\u0442\u0438\u0445 \u0432\u043e\u0441\u044c\u043c\u0438 \u0431\u0430\u0433\u043e\u0432 \u043d\u0430 \u0438\u043d\u0442\u0435\u0440\u0432\u044c\u044e \u044f \u043d\u0430\u0448\u0451\u043b \u0441\u0435\u043c\u044c<\/strong>. \u041f\u0440\u043e\u043f\u0443\u0441\u0442\u0438\u043b \u0442\u043e\u043b\u044c\u043a\u043e #6 \u2014 TOCTOU race \u0432 \u0434\u0435\u0434\u0443\u043f\u043b\u0438\u043a\u0430\u0446\u0438\u0438<\/strong>. \u041e\u0441\u0442\u0430\u043b\u044c\u043d\u044b\u0435 \u0441\u0435\u043c\u044c \u043f\u043e\u0439\u043c\u0430\u043b, \u043f\u043e\u0442\u043e\u043c\u0443 \u0447\u0442\u043e \u043f\u0440\u043e\u0448\u0451\u043b\u0441\u044f \u043f\u043e \u0447\u0435\u043a\u043b\u0438\u0441\u0442\u0443: \u0433\u0434\u0435 Lock \u043d\u0430 write-\u043c\u0435\u0442\u043e\u0434\u0430\u0445? \u0433\u0434\u0435 consumer \u0434\u043b\u044f \u043a\u0430\u0436\u0434\u043e\u0433\u043e \u043a\u0430\u043d\u0430\u043b\u0430? \u0433\u0434\u0435 cleanup \u0434\u043b\u044f in-memory storage? \u0433\u0434\u0435 O(N) \u043f\u043e\u0434 Lock? \u042d\u0442\u043e \u0440\u0443\u0442\u0438\u043d\u0430 \u2014 \u043d\u0435 \u201c\u0443\u0432\u0438\u0434\u0435\u043b \u0438 \u0443\u0434\u0438\u0432\u0438\u043b\u0441\u044f\u201d, \u0430 \u201c\u043f\u0440\u043e\u0432\u0435\u0440\u0438\u043b \u0438 \u0441\u0432\u0435\u0440\u0438\u043b\u201d.<\/p>\n
      TOCTOU \u0436\u0435 \u0432\u044b\u043f\u0430\u043b, \u043f\u043e\u0442\u043e\u043c\u0443 \u0447\u0442\u043e \u044f \u043c\u044b\u0441\u043b\u0435\u043d\u043d\u043e \u201c\u0434\u043e\u0432\u0435\u0440\u0438\u043b\u0441\u044f\u201d RWMutex<\/code> \u0432\u043d\u0443\u0442\u0440\u0438 \u0440\u0435\u043f\u043e\u0437\u0438\u0442\u043e\u0440\u0438\u044f \u2014 \u0430 \u043a\u043e\u043c\u043f\u043e\u0437\u0438\u0442\u043d\u0430\u044f \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u044f \u201ccheck then save\u201d \u0436\u0438\u0432\u0451\u0442 \u0443\u0440\u043e\u0432\u043d\u0435\u043c \u0432\u044b\u0448\u0435, \u0432 handler\u2019\u0435.<\/p>\n
      \u0412\u043e \u0432\u0442\u043e\u0440\u043e\u0439 \u0447\u0430\u0441\u0442\u0438 \u2014 \u0435\u0449\u0451 13 \u0431\u0430\u0433\u043e\u0432. \u0418\u0437 \u043d\u0438\u0445 \u043d\u0430 \u0438\u043d\u0442\u0435\u0440\u0432\u044c\u044e \u043f\u0440\u043e\u043f\u0443\u0441\u0442\u0438\u043b \u0434\u0432\u0430 (package main<\/code>\/compile error \u0438 \u043e\u0442\u0441\u0443\u0442\u0441\u0442\u0432\u0438\u0435 slog<\/code>). \u0420\u0430\u0441\u0441\u043a\u0430\u0436\u0443, \u043a\u0430\u043a\u0438\u0435 \u0437\u0430\u0446\u0435\u043f\u043a\u0438 \u043f\u043e\u043c\u043e\u0433\u043b\u0438 \u043f\u043e\u0439\u043c\u0430\u0442\u044c \u043e\u0441\u0442\u0430\u043b\u044c\u043d\u044b\u0435 11.<\/p>\n
      \ud83c\udd95 \u0427\u0442\u043e \u043d\u043e\u0432\u043e\u0433\u043e \u0432 Go 1.26 \u0434\u043b\u044f \u0431\u043e\u0440\u044c\u0431\u044b \u0441 \u0442\u0430\u043a\u0438\u043c\u0438 \u0431\u0430\u0433\u0430\u043c\u0438<\/h4>\n