2

Estou tentando implementar o problema dos leitores e escritores no Java, e para isso estou me baseando no método utilizado por Tanenbaum no livro de Sistemas Operacionais. Com apenas uma thread escritor e uma thread leitor o programa funciona bem, o problema é que quando eu crio mais de um thread leitor o programa entra em um tipo de loop infinito e para de imprimir na tela. Poderiam me dizer onde está o problema?

public class Principal {

  public static void main(String[] args) {
    Semaphore mutex = new Semaphore(1);
    Semaphore db = new Semaphore(1);
    int rc = 0;

    Escritores e1 = new Escritores(db, mutex);
    Leitores l1 = new Leitores(db, mutex, rc);
    Leitores l2 = new Leitores(db, mutex, rc);

    e1.start();
    l1.start();
    l2.start();
  }

}

public class Escritores extends Thread {
  Semaphore db;
  Semaphore mutex;
  int rc;

  public Escritores(Semaphore db, Semaphore mutex){
    this.db = db;
    this.mutex = mutex;
  }

  public void run(){
    while(true){
        try {
            Thread.sleep(this.aleatoriar(0, 100));
            this.db.acquire();
            System.out.println("Escreveu!");
            this.db.release();
        } catch (InterruptedException ex) {
            Logger.getLogger(Escritores.class.getName()).log(Level.SEVERE, null, ex);
        }

    }
  }

  public int aleatoriar(int minimo, int maximo) {
    Calendar lCDateTime = Calendar.getInstance();
    return (int)(lCDateTime.getTimeInMillis() % (maximo - minimo + 1) + minimo);
    }
}

public class Leitores extends Thread {
  Semaphore db;
  Semaphore mutex;
  int rc;


  public Leitores(Semaphore db, Semaphore mutex, int rc){
    this.db = db;
    this.mutex = mutex;
    this.rc = rc;
  }

  public void run(){
    while(true){
        try {
            Thread.sleep(this.aleatoriar(0, 100));
            this.mutex.acquire();
            this.rc = this.rc + 1;
            if(this.rc == 1){
                this.db.acquire();
            }
            this.mutex.release();
            System.out.println("Leu");
            this.mutex.acquire();
            this.rc = this.rc - 1;
            if(this.rc == 0){
                this.db.release();
            }
            this.mutex.release();
        } catch (InterruptedException ex) {
            Logger.getLogger(Leitores.class.getName()).log(Level.SEVERE, null, ex);
        }
    }
  }

  public int aleatoriar(int minimo, int maximo) {
    Calendar lCDateTime = Calendar.getInstance();
    return (int)(lCDateTime.getTimeInMillis() % (maximo - minimo + 1) + minimo);
  }
}
2
  • 1
    A leitura pode ser paralela? Pode ser suja? Escrita precisa ser consistente? Existem escritas em lugares distintos? Escritor pode morrer de stratvation? Requisições são enfileiradas? Ou quem sabe empilhadas? Ou leitura tem sempre prioridade? Ou escrita tem sempre prioridade? Todas as respostas para essas minhas perguntas implicam em soluções distintas para o problema de leitores e escritores 2/11/2017 às 5:31
  • Você não adicionou @Override antes do método run. Para o algoritmo ser implementado de modo concorrente é importante ter essa anotação. 15/09/2020 às 15:39

0

Você deve fazer log-in para responder a esta pergunta.

Pesquise outras perguntas com a tag .