Java 读写器

Question

我对我在编程语言概念课中学习的一个新概念感到有些困惑。任何信息都会很棒。读写器问题如下：

这个经典问题需要进程同步进行读写。因此，在定义和创建读写线程之前需要一个同步控制器。下面是一个控制器类（有两个方法留给你实现）。为了保持编程的简单性，当你编写读写线程类时（比如三个读者和一个写者），你只需要在开始读或写时象征性地打印一条消息，在读或写结束时再打印一条消息（因此无需创建每个线程读取或写入的实际共享内容）。

这就是我所拥有的。我认为我缺少线程的基本内容。请注意，控制器类和方法是给定的并且是必需的，除了 startWriting() 和 stopWriting() 必须由我实现。谢谢。

class Controller {
private int activeReaders = 0;  
private boolean writerPresent = false;  

protected boolean writeCondition() {
    return activeReaders == 0 && !writerPresent;
}

protected boolean readCondition() {
    return !writerPresent;
}

protected synchronized void startRead() {
    while (!readCondition())
        try { wait(); } catch (InterruptedException ex) {}
    ++activeReaders;
}

protected synchronized void stopRead()  { 
    --activeReaders;
    notifyAll();
}

protected synchronized void startWriting(){
    writerPresent = true;
    System.out.println("Writing has begun");
}

protected synchronized void stopWriting(){
    System.out.println("Reading is now available");
    writerPresent = false;      
}

public static void main(String [] args){
    Controller c = new Controller();

    Thread tRead1   = new Thread(new Runnable() {
        @Override
        public void run(){
            c.startRead();
            System.out.println("Reader 1 has started reading");
            c.stopRead();
            System.out.println("Reader 1 has stopped reading");
        }
    });
    Thread tRead2   = new Thread(new Runnable() {
        @Override
        public void run(){
            c.startRead();
            System.out.println("Reader 2 has started reading");
            c.stopRead();
            System.out.println("Reader 2 has stopped reading");
        }
    });
    Thread tRead3   = new Thread(new Runnable() {
        @Override
        public void run(){
            c.startRead();
            System.out.println("Reader 3 has started reading");
            c.stopRead();
            System.out.println("Reader 3 has stopped reading");
        }
    });
    Thread tWrite1  = new Thread(new Runnable() {
        @Override
        public void run(){
            c.startWriting();
            c.stopWriting();

        }
    });

    tRead1.start();
    tRead2.start();
    tWrite1.start();
    try {
        tWrite1.join();
    } catch (InterruptedException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
    tRead3.start();

}

}

Answer 1

首先，我建议您访问 javadocs 并阅读 wait、notify 和 notifyall 的方法定义。这是Java中基本的等待/锁定/通知系统。

在读者和作者方面，读者应该都在阅读作者，如果没有可用内容，则在作者上使用wait暂停。如果你有多个作者，你可以对等待消息队列的读者做同样的事情。当写入器写入并有更多数据可供读取器使用时，它应该在自己（写入器）上调用notify 以唤醒一个使用者以获取新数据。

让您了解何时可以/应该使用 notifyAll：

Thread.join 通过在正在加入的线程上调用 wait 来工作。线程死亡后，Thread 调用notifyAll 唤醒所有等待它完成的线程。