Ejemplo 5: Uso de Hilos con Thread y Runnable

.
└── concurrencia/
    └── src/
        └── app/
            └── concurrencia/
                ├── entities/
                │   ├── DownloadTask.java
                │   └── ThreadManager.java
                └── launch/
                    └── Main.java

package app.concurrencia.entities;

/**
 * Clase que representa una tarea de descarga de un archivo.
 */
public class DownloadTask implements Runnable {
    /**
     * Nombre del archivo a descargar.
     */
    private String fileName;

    /**
     * Constructor de la clase DownloadTask.
     * 
     * @param fileName Nombre del archivo a descargar.
     */
    public DownloadTask(String fileName) {
        this.fileName = fileName;
    }

    /**
     * Función que simula la descarga del archivo. Imprime el nombre del archivo que se está descargando, luego espera un tiempo aleatorio para simular el proceso de descarga y finalmente imprime un mensaje indicando que la descarga ha sido completada. Si el hilo es interrumpido durante la descarga, se captura la excepción y se imprime un mensaje indicando que la descarga ha sido interrumpida.
     */
    @Override
    public void run() {
        try {
            IO.println("Descargando: " + fileName);
            // Simular el tiempo de descarga
            Thread.sleep((long) (Math.random() * 5000));
            IO.println("Descarga completada: " + fileName);
        } catch (InterruptedException e) {
            IO.println("Descarga interrumpida: " + fileName);
        }
    }
}

package app.concurrencia.entities;

import java.util.ArrayList;
import java.util.List;

/**
 * Clase que maneja la creación y ejecución de hilos para tareas de descarga.
 */
public class ThreadManager {
    /**
     * Lista de hilos que representan las tareas de descarga.
     */
    private List<Thread> threads;

    /**
     * Constructor de la clase ThreadManager. Inicializa la lista de hilos.
     */
    public ThreadManager() {
        threads = new ArrayList<>();
    }

    /**
     * Función para iniciar las descargas. Crea un hilo para cada tarea de descarga y lo inicia.
     * 
     * @param fileNames Lista de nombres de archivos a descargar.
     */
    public void startDownloads(List<String> fileNames) {
        for (String fileName : fileNames) {
            Thread thread = new Thread(new DownloadTask(fileName));
            threads.add(thread);
            thread.start();
        }
    }

    /**
     * Función para esperar a que todas las descargas se completen. Utiliza la función join para esperar a que cada hilo termine su ejecución.
     */
    public void waitForDownloads() {
        for (Thread thread : threads) {
            try {
                thread.join();
            } catch (InterruptedException e) {
                IO.println("Esperando a que las descargas se completen ha sido interrumpido.");
            }
        }
    }
}

package app.concurrencia.launch;

import app.concurrencia.entities.ThreadManager;
import java.util.Arrays;
import java.util.List;

/**
 * Clase principal del programa que simula la descarga de archivos utilizando hilos.
 */
public class Main {
    void main() {
        // Lista de archivos a descargar
        List<String> fileNames = Arrays.asList("archivo1.txt", "archivo2.txt", "archivo3.txt");

        // Crear una instancia de ThreadManager
        ThreadManager threadManager = new ThreadManager();

        // Iniciar las descargas
        threadManager.startDownloads(fileNames);

        // Esperar a que todas las descargas se completen
        threadManager.waitForDownloads();

        IO.println("Todas las descargas han sido completadas.");
    }
}

Descargando: archivo1.txt
Descargando: archivo2.txt
Descargando: archivo3.txt
Descarga completada: archivo2.txt
Descarga completada: archivo1.txt
Descarga completada: archivo3.txt
Todas las descargas han sido completadas.