Zaimplementuj metodę Queue
Golang
Dlaczego chcesz się zmienić i rozważasz inne firmy?
// kod dla funkcji best() // z obsługą błędów, gdy brak backendu
Dlaczego zdecydowałeś się skontaktować z 2GIS? Co przyciągnęło cię do firmy lub konkretnego stanowiska?
Czy kiedykolwiek pracowałeś z równoczesnym dostępem do danych w bazie danych? Jakie mechanizmy, takie jak transakcje i blokady, używałeś? Czy istnieją sposoby rozwiązania tego problemu bez angażowania bazy danych?
// kod dla funkcji best() // z obsługą błędów, gdy brak backendu
Jak to jest obsługiwane w kodzie?
type Response interface{} type Backend interface { Invoke(ctx context.Context, req Request) (Response, error) } var _ Backend = &BackendImpl{} // addr содержит ip:port конкретного экземпляра func NewBackend(addr string) *BackendImpl type backentry struct { backend Backend inflight int64 } type Balancer struct { backends []*backentry mu *sync.Mutex } var _ Backend = &Balancer{} // addrs содержат адреса всех балансируемых экземпляров func NewBalancer(addrs []string) *Balancer { data := make([]*backentry,len(addrs)) for i,addr := range addrs{ data[i] = &backentry{ backend: NewBackend(addr), inflight: 0, } } return &Balancer{backends:data} } func(b *Balancer)Invoke(ctx context.Context, req Request) (Response, error){ b.mu.Lock() entry := b.best() atomic.AddInt64(&entry.inflight,1) b.mu.Unlock() defer atomic.AddInt64(&entry.inflight,-1) return entry.backend.Invoke(ctx,req) } func(b *Balancer) best() *backentry{ var best *backentry for _,entry := b.backends{ if best == nil || atomic.LoadInt64(&entry.inflight) < atomic.LoadInt64(&best.inflight){ best = entry } } return best }
// kod dla funkcji best() // z obsługą błędów, gdy brak backendu
Czy w Go jest programowanie obiektowe? Jeśli tak, jak jest zaimplementowane; jeśli nie, dlaczego?
Co jest dla ciebie najważniejsze w pracy?
Co zwraca odczyt z zamkniętego kanału?
Jak zorganizowałeś skalowanie i z jakimi architekturami mikroserwisów pracowałeś?
Kiedy dochodzi do wycieku goroutine?
Jak zaimplementować metodę Status, aby uzyskać stan zadania po ID?
Co się dzieje z programem, jeśli w osobnej goroutine wystąpi panic?
Czym różni się sync.Mutex od sync.RWMutex?
Opisz swój proces tworzenia i wdrażania nowej usługi: od zbierania wymagań do wdrożenia na środowiskach deweloperskich i testowych.
Jak przebiegał deployment usług?
Zaimplementuj metodę Queue