Golang

8226

გააზიარე შენი გამოცდილება Tinkoff-ში — როგორ მიიღე სამუშაო და რა საქმიანობა გქონდა?

func collectRTT(ctx context.Context, urls []string) (map[string]time.Duration, error) { pingMap := make(map[string]time.Duration, len(urls)) var mu sync.Mutex var wg sync.WaitGroup errCh := make(chan error, 1) for _, url := range urls { wg.Add(1) go func(u string) { defer wg.Done() dur, err := rtt(ctx, u) if err != nil { select { case errCh <- fmt.Errorf("RTT შეცდომა %s, %w", u, err): default: } return } mu.Lock() pingMap[u] = dur mu.Unlock() }(url) } wg.Wait() close(errCh) if err := <-errCh; err != nil { return nil, err } return pingMap, nil }

Senior

СБК ПАРУС

რა არის ძირითადი პროგრამირების ენა და რა სხვა ენებს იცით, მათ შორის არასამეწარმეო გამოცდილება?

Middle+

Озон банк

func (p *Pool) Stop() { p.mu.Unlock() // ახლა უსაფრთხოდ შეიძლება ჩაკეტოთ არხი close(p.tasks) // სიგნალი მუშაკებს: ახალი დავალებები აღარ იქნება, წაიკითხეთ დარჩენილი p.wg.Wait() // ველით ყველა გორუტინის დასრულებას p.cancel() // საჭიროების შემთხვევაში გაუქმეთ კონტექსტი fmt.Println("Pool შეჩერებულია.") } // ForceStop ძალით აჩერებს ყველა მუშაკს დავალებების დასრულების მოლოდინის გარეშე. // მუშაკები დაუყოვნებლივ გაწყდება კონტექსტის მეშვეობით. func (p *Pool) ForceStop(timeout time.Duration) { fmt.Printf("ძალადობრივი გაჩერება პულის (timeout: %v)...\n", timeout) // ბლოკავს ახალი დავალებების დამატებას p.mu.Lock() p.isOpen = false p.mu.Unlock() // არხის დახურვა, რათა მუშაკებმა ახალი დავალებები არ მიიღონ close(p.tasks) // კონტექსტის გაუქმება – ეს ყველა მიმდინარე დავალებას გაწყდება p.cancel() // შეზღუდული დრო მიცემულია დასრულებისთვის done := make(chan struct{}) go func() { p.wg.Wait() close(done) }() select { case <-done: fmt.Println("პული ძალით გაჩერებულია (ყველა მუშაკი დასრულდა)") case <-time.After(timeout): fmt.Println("პული ძალით გაჩერებულია (тайმ-აუტ, შეიძლება დარჩეს გაჩერებული goroutine-ები)") } }

Senior

Pasul LTD

რატომ არის HAVING საჭირო და რატომ არა WHERE?

Senior