Comunicación entre hilos mediante Pipes en Kotlin | Operating systems, scripting, PowerShell and security

Hilos, Kotlin

import java.io.BufferedReader
import java.io.InputStreamReader
import java.io.PrintWriter
import java.io.PipedInputStream
import java.io.PipedOutputStream

fun main() {

    for (i in 1..5) {

        // Pipe: padre → hijo
        val padreEscribe = PipedOutputStream()
        val hijoLee = PipedInputStream(padreEscribe)

        // Pipe: hijo → padre
        val hijoEscribe = PipedOutputStream()
        val padreLee = PipedInputStream(hijoEscribe)

        val hilo = Thread {

            // El hijo recibe el mensaje
            val entrada = BufferedReader(
                InputStreamReader(hijoLee)
            )

            val mensaje = entrada.readLine()

            // Lo convierte a mayúsculas
            val respuesta = mensaje.uppercase()

            // El hijo responde al padre
            val salida = PrintWriter(
                hijoEscribe,
                true
            )

            salida.println(respuesta)

            println("Hijo $i recibe: $mensaje")
            println("Hijo $i responde: $respuesta")
        }

        hilo.start()

        // El padre envía el mensaje
        val salida = PrintWriter(
            padreEscribe,
            true
        )

        salida.println("hola hijos")

        // El padre recibe la respuesta
        val entrada = BufferedReader(
            InputStreamReader(padreLee)
        )

        val respuesta = entrada.readLine()

        println("Padre recibe del hijo $i: $respuesta")

        hilo.join()
    }
}

import java.io.BufferedReader

import java.io.InputStreamReader

import java.io.PrintWriter

import java.io.PipedInputStream

import java.io.PipedOutputStream

fun main() {

for (i in 1..5) {

// Pipe: padre → hijo

val padreEscribe = PipedOutputStream()

val hijoLee = PipedInputStream(padreEscribe)

// Pipe: hijo → padre

val hijoEscribe = PipedOutputStream()

val padreLee = PipedInputStream(hijoEscribe)

val hilo = Thread {

// El hijo recibe el mensaje

val entrada = BufferedReader(

InputStreamReader(hijoLee)

)

val mensaje = entrada.readLine()

// Lo convierte a mayúsculas

val respuesta = mensaje.uppercase()

// El hijo responde al padre

val salida = PrintWriter(

hijoEscribe,

true

)

salida.println(respuesta)

println("Hijo $i recibe: $mensaje")

println("Hijo $i responde: $respuesta")

}

hilo.start()

// El padre envía el mensaje

val salida = PrintWriter(

padreEscribe,

true

)

salida.println("hola hijos")

// El padre recibe la respuesta

val entrada = BufferedReader(

InputStreamReader(padreLee)

)

val respuesta = entrada.readLine()

println("Padre recibe del hijo $i: $respuesta")

hilo.join()

}

Comunicación entre hilos mediante Pipes en Kotlin (Kotlin, Hilos)

LIBRO DE POWERSHELL

LO ÚLTIMO

RECOMENDADO