Skip to main content
se añadió 1 carácter en el cuerpo
Origen Enlace
Roberto E Moran
  • 3.5k
  • 1
  • 9
  • 19

Por ejemplo si se ejecutase un proceso de escritura y hubiesen 8 permit libres, reservaría los 8 y esperaría a que los 2 procesos de lectura finalicen para obtener los 2 permit faltantes, al tener todos los permite reservados si otro proceso de lectura o escritura quiere ejecutarse tendrá que esperar a que se liberen y obtener la cantidad necesaria para la ejecución (1 lectura y 10 para escritura).

Por ejemplo si se ejecutase un proceso de escritura y hubiesen 8 permit libres reservaría los 8 y esperaría a que los 2 procesos de lectura finalicen para obtener los 2 permit faltantes, al tener todos los permite reservados si otro proceso de lectura o escritura quiere ejecutarse tendrá que esperar a que se liberen y obtener la cantidad necesaria para la ejecución (1 lectura y 10 para escritura).

Por ejemplo si se ejecutase un proceso de escritura y hubiesen 8 permit libres, reservaría los 8 y esperaría a que los 2 procesos de lectura finalicen para obtener los 2 permit faltantes, al tener todos los permite reservados si otro proceso de lectura o escritura quiere ejecutarse tendrá que esperar a que se liberen y obtener la cantidad necesaria para la ejecución (1 lectura y 10 para escritura).

se añadieron 10 caracteres en el cuerpo
Origen Enlace
Roberto E Moran
  • 3.5k
  • 1
  • 9
  • 19

Los permit sirven como una unidad para definir si un proceso puede ejecutarse, en caso que sea una lectura obtendremos 1 permit quedando con 9 permit libres, de esta forma se podrían ejecutar 9 más de lectura simultánea, en el caso que sea una escritura solicitamos todos los permit.

Por ejemplo si se ejecutase un proceso de escritura y hubiesen 8 permit libres reservaría los 8 y esperaría a que los 2 procesos de lectura finalicen para obtener los 2 permit faltantes, al tener todos los permite reservados si otro proceso de lectura o escritura quiere ejecutarse tendrá que esperar a que se liberen y obtener la cantidad necesaria para la ejecución (1 lectura y 10 para escritura).

Los permit sirven como una unidad para definir si un proceso puede ejecutarse, en caso que sea una lectura obtendremos 1 permit quedando con 9 permit libres, de esta forma se podrían ejecutar 9 más de lectura simultánea, en el caso que sea una escritura solicitamos todos los permit.

Por ejemplo si se ejecutase un proceso de escritura y hubiesen 8 permit libres reservaría los 8 y esperaría a que los 2 procesos de lectura finalicen para obtener los 2 permit faltantes, al tener todos los permite reservados si otro proceso de lectura o escritura quiere ejecutarse tendrá que esperar a que se liberen y obtener la cantidad necesaria para la ejecución (1 lectura y 10 para escritura).

se añadieron 10 caracteres en el cuerpo
Origen Enlace
Roberto E Moran
  • 3.5k
  • 1
  • 9
  • 19
import java.util.Random;
import java.util.concurrent.Semaphore;
import java.util.concurrent.TimeUnit;

public class Escritor extends Thread {

    private Semaphore semaforo;
    private Random random = new Random();

    public Escritor(String nombre, Semaphore semaforo) {
        super(nombre);
        this.semaforo = semaforo;
    }

    @Override
    public void run() {
        System.out.println(getName() + "\t intentando escribir");
        try {
            bloquearTodo();
            // Utilizamos String.format() como una buena práctica para mostrar mensajes,
            // además usamos ++BaseDatos.count para que primero incremente el valor y después lo imprima,
            // si fuera BaseDatos.count++ primero imprime el valor y después lo incrementa.

            System.out.println(String.format("%s escribiendo, valor anterior: %o - nuevo valor: %o ", getName(), BaseDatos.count, ++BaseDatos.count));

            // Definimos que el tiempo de escritura será entre 0 y 4
            int i = random.nextInt(4);

            // En mi opinión esta es una forma de dormir un hilo que favorece un código más legible.
            // Puedes utilizar otras unidades de medida como MILLISECONDS, MICROSECONDS, etc. Solo recuerda aumentar el valor máximo del random
            TimeUnit.SECONDS.sleep(i);

            System.out.println(String.format("%s ya ha escrito - tiempo escritura: %o ", getName(), i));
        } catch (InterruptedException e) {
            // Si lo que quieres es imprimir la excepción debes utilizar printStackTrace() para ver la traza completa.
            e.printStackTrace();
        } finally {
            // En caso que la ejecución del programa falle se deben liberar los recursos en finally para
            // para garantizar que los recursos siempre son liberados después de ser adquiridos.
            liberarTodo();
        }
    }

    /**
     * Debido a que el enunciado dice que solo un hilo puede escribir solicitamos el total de los permit para que no
     * se ejecuten más procesos de lectura y de escritura.
     */
    private void bloquearTodo() throws InterruptedException {
        this.semaforo.acquire(Ejecucion.NUM_HILOS_MAX);
    }

    /**
     * Liberamos el total de los permit adquiridos al inicio con el método release(Ejecucion.NUM_HILOS_MAX), si solo utilizamos release() liberaríamos 1 permit
     * lo cual bloquearia todas las ejecuciones siguientes de escritura que necesitan 10 permit.
     */
    private void liberarTodo() {
        this.semaforo.release(Ejecucion.NUM_HILOS_MAX);
    }

}

import java.util.Random;
import java.util.concurrent.Semaphore;

public class Lector extends Thread {


    private Semaphore semaforo;
    private Random random = new Random();

    public Lector(String nombre, Semaphore semaforo) {
        super(nombre);
        this.semaforo = semaforo;
    }

    @Override
    public void run() {
        System.out.println(getName() + "\t\t intentando leer");
        try {
            // Adquirimos 1 permit para lectura.
            semaforo.acquire();

            System.out.println(String.format("%s Valor de lectura: %o", getName(), BaseDatos.count));

            // Quitamos el sleep para que las lecturas sean más rápidas puedas ver el funcionamiento correcto.
//            int i = random.nextInt(2);
//            TimeUnit.SECONDS.sleep(i);

            System.out.println(String.format("%s ya he leído", getName()));
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            semaforo.release();
        }
    }

}
import java.util.Random;
import java.util.concurrent.Semaphore;
import java.util.concurrent.TimeUnit;

public class Escritor extends Thread {

    private Semaphore semaforo;
    private Random random = new Random();

    public Escritor(String nombre, Semaphore semaforo) {
        super(nombre);
        this.semaforo = semaforo;
    }

    @Override
    public void run() {
        System.out.println(getName() + "\t intentando escribir");
        try {
            bloquearTodo();
            // Utilizamos String.format() como una buena práctica para mostrar mensajes,
            // además usamos ++BaseDatos.count para que primero incremente el valor y después lo imprima,
            // si fuera BaseDatos.count++ primero imprime el valor y después lo incrementa.

            System.out.println(String.format("%s escribiendo, valor anterior: %o - nuevo valor: %o ", getName(), BaseDatos.count, ++BaseDatos.count));

            // Definimos que el tiempo de escritura será entre 0 y 4
            int i = random.nextInt(4);

            // En mi opinión esta es una forma de dormir un hilo que favorece un código más legible.
            // Puedes utilizar otras unidades de medida como MILLISECONDS, MICROSECONDS, etc. Solo recuerda aumentar el valor máximo del random
            TimeUnit.SECONDS.sleep(i);

            System.out.println(String.format("%s ya ha escrito - tiempo escritura: %o ", getName(), i));
        } catch (InterruptedException e) {
            // Si lo que quieres es imprimir la excepción debes utilizar printStackTrace() para ver la traza completa.
            e.printStackTrace();
        } finally {
            // En caso que la ejecución programa se deben liberar los recursos en finally para
            // garantizar que los recursos siempre son liberados después de ser adquiridos.
            liberarTodo();
        }
    }

    /**
     * Debido a que el enunciado dice que solo un hilo puede escribir solicitamos el total de los permit para que no
     * se ejecuten más procesos de lectura y de escritura.
     */
    private void bloquearTodo() throws InterruptedException {
        this.semaforo.acquire(Ejecucion.NUM_HILOS_MAX);
    }

    /**
     * Liberamos el total de los permit adquiridos al inicio con el método release(Ejecucion.NUM_HILOS_MAX), si solo utilizamos release() liberaríamos 1 permit
     * lo cual bloquearia todas las ejecuciones siguientes de escritura que necesitan 10 permit.
     */
    private void liberarTodo() {
        this.semaforo.release(Ejecucion.NUM_HILOS_MAX);
    }

}

import java.util.Random;
import java.util.concurrent.Semaphore;

public class Lector extends Thread {


    private Semaphore semaforo;
    private Random random = new Random();

    public Lector(String nombre, Semaphore semaforo) {
        super(nombre);
        this.semaforo = semaforo;
    }

    @Override
    public void run() {
        System.out.println(getName() + "\t\t intentando leer");
        try {
            // Adquirimos 1 permit para lectura.
            semaforo.acquire();

            System.out.println(String.format("%s Valor de lectura: %o", getName(), BaseDatos.count));

            // Quitamos el sleep para que las lecturas sean más rápidas puedas ver el funcionamiento correcto.
//            int i = random.nextInt(2);
//            TimeUnit.SECONDS.sleep(i);

            System.out.println(String.format("%s ya he leído", getName()));
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            semaforo.release();
        }
    }

}
import java.util.Random;
import java.util.concurrent.Semaphore;
import java.util.concurrent.TimeUnit;

public class Escritor extends Thread {

    private Semaphore semaforo;
    private Random random = new Random();

    public Escritor(String nombre, Semaphore semaforo) {
        super(nombre);
        this.semaforo = semaforo;
    }

    @Override
    public void run() {
        System.out.println(getName() + "\t intentando escribir");
        try {
            bloquearTodo();
            // Utilizamos String.format() como una buena práctica para mostrar mensajes,
            // además usamos ++BaseDatos.count para que primero incremente el valor y después lo imprima,
            // si fuera BaseDatos.count++ primero imprime el valor y después lo incrementa.

            System.out.println(String.format("%s escribiendo, valor anterior: %o - nuevo valor: %o ", getName(), BaseDatos.count, ++BaseDatos.count));

            // Definimos que el tiempo de escritura será entre 0 y 4
            int i = random.nextInt(4);

            // En mi opinión esta es una forma de dormir un hilo que favorece un código más legible.
            // Puedes utilizar otras unidades de medida como MILLISECONDS, MICROSECONDS, etc. Solo recuerda aumentar el valor máximo del random
            TimeUnit.SECONDS.sleep(i);

            System.out.println(String.format("%s ya ha escrito - tiempo escritura: %o ", getName(), i));
        } catch (InterruptedException e) {
            // Si lo que quieres es imprimir la excepción debes utilizar printStackTrace() para ver la traza completa.
            e.printStackTrace();
        } finally {
            // En caso que la ejecución del programa falle se deben liberar los recursos en finally
            // para garantizar que los recursos siempre son liberados después de ser adquiridos.
            liberarTodo();
        }
    }

    /**
     * Debido a que el enunciado dice que solo un hilo puede escribir solicitamos el total de los permit para que no
     * se ejecuten más procesos de lectura y de escritura.
     */
    private void bloquearTodo() throws InterruptedException {
        this.semaforo.acquire(Ejecucion.NUM_HILOS_MAX);
    }

    /**
     * Liberamos el total de los permit adquiridos al inicio con el método release(Ejecucion.NUM_HILOS_MAX), si solo utilizamos release() liberaríamos 1 permit
     * lo cual bloquearia todas las ejecuciones siguientes de escritura que necesitan 10 permit.
     */
    private void liberarTodo() {
        this.semaforo.release(Ejecucion.NUM_HILOS_MAX);
    }

}

import java.util.Random;
import java.util.concurrent.Semaphore;

public class Lector extends Thread {


    private Semaphore semaforo;
    private Random random = new Random();

    public Lector(String nombre, Semaphore semaforo) {
        super(nombre);
        this.semaforo = semaforo;
    }

    @Override
    public void run() {
        System.out.println(getName() + "\t\t intentando leer");
        try {
            // Adquirimos 1 permit para lectura.
            semaforo.acquire();

            System.out.println(String.format("%s Valor de lectura: %o", getName(), BaseDatos.count));

            // Quitamos el sleep para que las lecturas sean más rápidas puedas ver el funcionamiento correcto.
//            int i = random.nextInt(2);
//            TimeUnit.SECONDS.sleep(i);

            System.out.println(String.format("%s ya he leído", getName()));
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            semaforo.release();
        }
    }

}
Origen Enlace
Roberto E Moran
  • 3.5k
  • 1
  • 9
  • 19
Loading