Golang
¿Qué consecuencias ocurrirán si los datos transmitidos a través del canal permanecen sin leer?
¿Cuál es la ventaja de las goroutines en comparación con los hilos en términos de eficiencia y facilidad de uso?
¿Qué determina el ámbito de acceso de una variable declarada con el modificador privado?
Газпром
Газпромбанк¿Qué parámetros se pueden configurar para el funcionamiento del planificador de tareas?
¿Qué métodos se pueden utilizar para garantizar el procesamiento de Kafka hasta 100 mil mensajes por segundo?
¿Cómo percibe la situación cuando en el código no se indica explícitamente el uso de una interfaz?
Cuéntame sobre el proyecto actual en el que estás trabajando o en el que trabajaste recientemente
¿Qué operaciones existen sobre las slices en Go?
VK Cloud¿Cómo se llama el proceso de mover elementos de un Map a otro?
/* Necesitamos transferir datos desde una fuente a un consumidor. La fuente entrega los datos en pequeños lotes (~diez registros), mientras que el consumidor funciona mejor con lotes grandes (~mil registros). Un ejemplo real es la transferencia de datos desde colas tipo Kafka a una base de datos Clickhouse. Fuente: - Prácticamente infinita. - La fuente nunca devuelve más de MaxItems registros en una llamada a Next. - Dentro de una "sesión" (una llamada a la función Pipe), la fuente devuelve datos nuevos en cada llamada a Next. - Sin embargo, tras reiniciar, la fuente comienza desde la posición "confirmada" anterior, indicada por cookie. Por lo tanto, *cada* valor de cookie devuelto por Next, después de guardar los datos en el receptor, debe ser confirmado con la llamada a Commit, en el mismo orden en que fueron devueltos por Next. Receptor: - No puede procesar más de MaxItems a la vez. Nivel básico: Se requiere implementar la función func Pipe(p Producer, c Consumer) error que lee datos de la fuente, los agrupa en un buffer de tamaño no mayor que MaxItems y los guarda en el receptor, después de lo cual confirma el progreso en la fuente. Dificultad adicional: Los métodos Next, Process y Commit están relacionados con llamadas de red y pueden tardar bastante. Para acelerar el proceso, es necesario paralelizar los procesos de lectura, escritura y confirmación del progreso. De modo que, durante Process o Commit, la lectura de la fuente y la formación del nuevo buffer continúen. */ const MaxItems = 9999 type Producer interface { // Next devuelve: // - un lote de items para procesar // - una cookie para confirmar cuando se complete el procesamiento // - un error Next() (items []any, cookie int, err error) // Commit se usa para marcar un lote de datos como procesado Commit(cookie int) error } type Consumer interface { Process(items []any) error } func Pipe(p Producer, c Consumer) error { // TODO }
¿Cómo se implementa la operación select en el lenguaje Go y cómo funciona con los canales?
Wildberries
Касперский¿Se puede pausar la ejecución de una gorutina de modo que se bloquee en un hilo del sistema específico?
¿El lenguaje Go tiene soporte incorporado para arreglos?
¿Qué mecanismo de abstracción en el lenguaje Go está diseñado para representar caracteres o tokens?
¿Qué significa un valor nulo para un segmento en un lenguaje de programación?
¿Cómo se implementa el procesamiento paralelo y secuencial de tareas en el lenguaje Go?
¿Qué mecanismos y métodos se utilizan para proteger los datos al establecer conexiones HTTPS?
¿Qué tipos de datos son adecuados para su uso como clave en una estructura de datos Map?
¿Puede explicar el mecanismo de funcionamiento del planificador de tareas en el sistema operativo?
Касперский¿Puede explicar la estructura interna y el funcionamiento de una tabla hash?