Golang
Welke gevolgen zullen er zijn als de via het kanaal verzonden gegevens ongelezen blijven?
Wat is het voordeel van goroutines ten opzichte van threads in termen van efficiëntie en gebruiksgemak?
Wat bepaalt het toegangsgebied van een variabele die is gedeclareerd met de private-modificator?
Газпром
ГазпромбанкWelke parameters kunnen worden ingesteld voor de werking van de taakplanner?
Welke methoden kunnen worden gebruikt om de verwerking van Kafka tot 100 duizend berichten per seconde te garanderen?
Hoe ervaar je de situatie wanneer het gebruik van een interface niet expliciet in de code is aangegeven?
Vertel me over het huidige project waar je aan werkt of recent hebt gewerkt
Welke bewerkingen bestaan er op slices in Go?
VK CloudHoe heet het proces van het verplaatsen van elementen van de ene Map naar de andere?
/* We moeten gegevens van een bron naar een consument overbrengen. De bron geeft gegevens in kleine batches (~tien records), terwijl de consument efficiënter werkt met grote batches (~duizend records). Een echt voorbeeld is het overzetten van gegevens van Kafka-achtige wachtrijen naar een Clickhouse-database. Bron: - Bijna oneindig. - De bron geeft nooit meer dan MaxItems records terug in één Next-aanroep. - Tijdens één "sessie" (één aanroep van de Pipe-functie) geeft de bron bij elke Next-aanroep nieuwe gegevens. - Na een herstart begint de bron echter vanaf de vorige "bevestigde" positie, aangegeven door cookie. Daarom moet elke cookie-waarde die door Next wordt geretourneerd, na het opslaan van de gegevens in de ontvanger, worden bevestigd met een Commit-aanroep, in dezelfde volgorde als ze door Next werden geretourneerd. Ontvanger: - Kan niet meer dan MaxItems tegelijk verwerken. Basissysteem: Het is nodig om de functie func Pipe(p Producer, c Consumer) error te implementeren die gegevens uit de bron leest, deze groepeert in een buffer van niet groter dan MaxItems en opslaat in de ontvanger, waarna de voortgang in de bron wordt bevestigd. Uitdaging: De methoden Next, Process en Commit zijn verbonden met netwerkoproepen en kunnen vrij lang duren. Om het proces te versnellen, moeten de lees-, schrijf- en bevestigingsprocessen parallel worden uitgevoerd. Zodat tijdens Process of Commit, het lezen uit de bron en het vormen van de nieuwe buffer doorgaan. */ const MaxItems = 9999 type Producer interface { // Next geeft terug: // - een batch van items om te verwerken // - een cookie om te bevestigen wanneer de verwerking is voltooid // - een fout Next() (items []any, cookie int, err error) // Commit wordt gebruikt om een gegevensbatch als verwerkt te markeren Commit(cookie int) error } type Consumer interface { Process(items []any) error } func Pipe(p Producer, c Consumer) error { // TODO }
Hoe wordt de select-operatie geïmplementeerd in de Go-taal en hoe werkt deze met kanalen?
Wildberries
КасперскийKun je de uitvoering van een goroutine onderbreken zodat deze blokkeert op een specifiek systeemthread?
Heeft de programmeertaal Go ingebouwde ondersteuning voor arrays?
Welk abstractiemechanisme in de Go-taal is bedoeld om tekens of tokens weer te geven?
Wat betekent een nulwaarde voor een segment in een programmeertaal?
Hoe wordt parallel en sequentieel verwerken van taken geïmplementeerd in de programmeertaal Go?
Welke mechanismen en methoden worden gebruikt om gegevens te beschermen bij het tot stand brengen van HTTPS-verbindingen?
Welke gegevens types zijn geschikt voor gebruik als sleutel in een Map-gegevensstructuur?
Kunt u het mechanisme van de taakplanner in het besturingssysteem uitleggen?
КасперскийKunt u de interne structuur en werking van een hash-tabel uitleggen?