Golang

/* Musíme přenést data z nějakého zdroje k nějakému příjemci. Zdroj vrací data v malých dávkách (~deset záznamů), zatímco příjemce pracuje efektivněji s většími dávkami (~tisíc záznamů). Reálný příklad je přenos dat z front typu Kafka do databáze Clickhouse. Zdroj: - Téměř nekonečný. - Zdroj nikdy nevrátí více než MaxItems záznamů v jednom volání Next. - V rámci jedné "seance" (jedno volání funkce Pipe) zdroj při každém volání Next vrací nová data. - Nicméně, po restartu začne zdroj od předchozí "potvrzené" pozice, určené cookie. Proto *každá* hodnota cookie, kterou Next vrátí, po uložení dat do příjemce, musí být potvrzena voláním Commit, ve stejném pořadí, v jakém byla vrácena Next. Příjemce: - Nemůže zpracovat více než MaxItems najednou. Je třeba implementovat funkci func Pipe(p Producer, c Consumer) error, která čte data ze zdroje, seskupuje je do bufferu o velikosti nejvýše MaxItems a ukládá je do příjemce, po čemž potvrzuje pokrok ve zdroji. */ const MaxItems = 9999 type Producer interface { // Next vrací: // - dávku položek k zpracování // - cookie k potvrzení po dokončení zpracování // - chybu Next() (items []any, cookie int, err error) // Commit slouží k označení dávky dat jako zpracované Commit(cookie int) error } type Consumer interface { Process(items []any) error } func Pipe(p Producer, c Consumer) error { // TODO }

Middle+

Яндекс

137

4 - rychle přijímat příchozí úkoly, 5 - vrátit výsledek úkolu na požádání 6 - pokud není výsledek, vrátit odpovídající stav /* Procesor - služba, která provádí dlouhou, náročnou operaci. Je již implementována Chyby, které vrací, jsou výhradně spojeny s nesprávnými vstupními údaji, jsou stabilní a opětovné požádání je zbytečné */ type Processor interface { Process([]byte) ([]byte, error) } /* Předpokládáme, že máme generátor unikátních identifikátorů (například UUID). Generátor zaručuje, že nedojde ke kolizím */ type ID string // func NewID() ID /* Plánovač přijímá úkoly od klientů, zařadí je do fronty a spustí je ke zpracování. Zajišťuje, že současně běží nejvýše 'threads' metod zpracování Umožňuje zkontrolovat stav úkolu a získat výsledek neblokuje své veřejné metody pro zpracování */ type Scheduler struct { processor Processor } func NewScheduler( prc Processor, threads int, ) *Scheduler { // inicializační logika return &Scheduler{ processor: prc, } } func (s *Scheduler) Queue(request []byte) ID { // implementace return "" }

Middle+

Яндекс

132

Popište algoritmus řešení úlohy maxSegment

Senior

Яндекс

131

Řekni mi, co se na konci děje — jak shromažďujeme vyrovnávací paměť?

Middle+

Яндекс

131

Jaké jsou vaše očekávání ohledně platu?