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();
}
}
}