Golang
Welche Folgen hat es, wenn die über den Kanal übertragenen Daten ungelesen bleiben?
Was ist der Vorteil von Goroutinen im Vergleich zu Threads in Bezug auf Effizienz und Benutzerfreundlichkeit?
Was bestimmt den Zugriffbereich einer Variable, die mit dem Modifikator privat deklariert wurde?
Газпром
ГазпромбанкWelche Parameter können für die Arbeit des Aufgabenplaners eingestellt werden?
Welche Methoden können verwendet werden, um die Verarbeitung von Kafka bis zu 100.000 Nachrichten pro Sekunde sicherzustellen?
Wie nehmen Sie die Situation wahr, wenn im Code die Verwendung einer Schnittstelle nicht explizit angegeben ist?
Erzähl mir vom aktuellen Projekt, an dem du arbeitest oder kürzlich gearbeitet hast
Welche Operationen gibt es an Slices in Go?
VK CloudWie nennt man den Prozess, bei dem Elemente von einer Map in eine andere verschoben werden?
/* Wir müssen Daten von einer Quelle zu einem Verbraucher übertragen. Die Quelle liefert die Daten in kleinen Chargen (~zehn Einträge), während der Verbraucher besser mit größeren Chargen (~tausend Einträge) arbeitet. Ein echtes Beispiel ist die Übertragung von Daten aus Kafka-Queues in eine Clickhouse-Datenbank. Quelle: - Praktisch unendlich. - Die Quelle gibt nie mehr als MaxItems Datensätze bei einem Aufruf von Next zurück. - Innerhalb einer "Sitzung" (einem Aufruf der Funktion Pipe) liefert die Quelle bei jedem Aufruf von Next neue Daten. - Nach einem Neustart beginnt die Quelle jedoch an der vorherigen "bestätigten" Position, die durch cookie bestimmt wird. Daher muss jeder Wert von cookie, der von Next zurückgegeben wird, nach dem Speichern der Daten im Empfänger mit Commit bestätigt werden, und zwar in genau der Reihenfolge, in der sie von Next zurückgegeben wurden. Empfänger: - Kann nicht mehr als MaxItems auf einmal verarbeiten. Basisebene: Es ist erforderlich, die Funktion func Pipe(p Producer, c Consumer) error zu implementieren, die Daten aus der Quelle liest, sie in einen Puffer gruppiert, der nicht größer als MaxItems ist, und sie im Empfänger speichert, und anschließend den Fortschritt in der Quelle bestätigt. Schwierigkeit: Die Methoden Next, Process und Commit sind mit Netzwerkaufrufen verbunden und können ziemlich lange dauern. Um den Prozess zu beschleunigen, müssen die Prozesse Lesen, Schreiben und Fortschrittsbestätigung parallelisiert werden. Damit während Process oder Commit das Lesen aus der Quelle und die Bildung des neuen Puffers fortgesetzt werden. */ const MaxItems = 9999 type Producer interface { // Next gibt zurück: // - einen Batch von Items zur Verarbeitung // - eine cookie, die bestätigt werden muss, wenn die Verarbeitung abgeschlossen ist // - einen Fehler Next() (items []any, cookie int, err error) // Commit wird verwendet, um einen Datenbatch als verarbeitet zu markieren Commit(cookie int) error } type Consumer interface { Process(items []any) error } func Pipe(p Producer, c Consumer) error { // TODO }
Wie wird die Select-Operation in der Programmiersprache Go implementiert und wie funktioniert sie mit Kanälen?
Wildberries
КасперскийKann man die Ausführung einer Goroutine so pausieren, dass sie auf einem bestimmten System-Thread blockiert?
Verfügt die Programmiersprache Go über eine eingebaute Unterstützung für Arrays?
Welcher Abstraktionsmechanismus in der Programmiersprache Go ist für die Darstellung von Zeichen oder Tokens vorgesehen?
Was bedeutet ein Nullwert für einen Abschnitt in einer Programmiersprache?
Wie wird die parallele und sequenzielle Verarbeitung von Aufgaben in der Programmiersprache Go implementiert?
Welche Mechanismen und Methoden werden zum Schutz der Daten bei der Herstellung von HTTPS-Verbindungen verwendet?
Welche Datentypen eignen sich als Schlüssel in einer Map-Datenstruktur?
Können Sie den Funktionsmechanismus des Task-Schedulers im Betriebssystem erklären?
КасперскийKönnen Sie die interne Struktur und Funktionsweise einer Hashtabelle erklären?