Paaiškinkite rankinio įsipareigojimo sąvoką Kafka
Golang
Kodėl mums reikia nutraukti kontekstą struktūroje? Kodėl užbaigti darbuotojus? Mes norime nutraukti Stop metodą.
Kaip duomenys saugomi duomenų bazėje?
Ar turi klausimų man?
Kuo skiriasi HAVING nuo WHERE?
Ar rašote daug asinchroninio kodo savo dabartiniame darbe?
Kas nutiktų, jei paslauga kristų ir neskaitė žinučių iš Kafka?
Kas nutinka su buferiu, kai rašymo gorutinos yra užblokuotos?
Pridedi WaitGroup, kam?
Kaip vartotojo committed offset veikia skirtingais režimais?
Kaip padaryti duomenų struktūrą generišką (veikiančią su bet kokio tipo reikšmėmis) Go kalboje?
Sudėtiniai indeksai – ką pirmiausia dėti: lygybę ar diapazoną?
Skirtumas tarp virtualios mašinos ir konteinerio
Kuo skiriasi RIGHT JOIN nuo kitų JOIN? Kas yra CROSS JOIN?
Papaskink man apie CQRS
Kodėl pasirinkote Kafka, o ne kitus žinučių siuntimo būdus (RabbitMQ, NATS)?
Kokius kitus percentilius naudojote?
// Parašykite asinchroninį užduočių tvarkyklę kaip biblioteką // Klientas perduoda objektą (Task) su duomenimis užduočiai atlikti, // mūsų pavyzdyje naudosime tuščią struktūrą. // Tvarkyklė gali vienu metu apdoroti ne daugiau kaip N užduočių, // ir ne daugiau kaip X užduočių gali būti įtrauktos į eilę apdorojimui. // Jei nėra vietos eilėje, iš karto grąžiname klaidą klientui. // Užduotis imama į apdorojimą, jei yra laisvų apdorotojų. // Simuliuojame apdorojimo trukmę naudodami time.Sleep(5*time.Second). // Kai viena užduotis baigiasi, paimame kitą iš eilės. // Jei eilė tuščia, laukiame naujų užduočių iš klientų. // Su žvaigždute: papildykite Task struktūrą ir gaukite užduočių būsenas per atskirą užklausą.
Kaip pridėti kontekstą prie Stop metodo, kad būtų galima nutraukti laukimą užduočių vykdymo su laiko limitu?
Kodėl mums reikalingas WaitGroup šiame užduotyje?