Многопоточность. Читетель и много писателей

import java.util.Random;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReadWriteLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;
 
public class ReaderWriter<T> {
    Random rand = new Random();
    private BlockingQueue<Thread> queue = new ArrayBlockingQueue<Thread>(7);
    private ReadWriteLock rwLock = new ReentrantReadWriteLock();
    private Lock readLock = rwLock.readLock();
    private Lock writeLock = rwLock.writeLock();
 
    public void read() {
        readLock.lock();
        try {
            queue.add(Thread.currentThread());
           for(Thread t : queue) {
                System.out.print(t.getName()+" ");
            }
            System.out.println(" is reading;");
            try {
                Thread.currentThread().sleep(rand.nextInt(3000));
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        } finally {
            queue.remove(Thread.currentThread());
            readLock.unlock();
        }
    }
 
    public void write() {
        writeLock.lock();
        try {
            System.out.println(Thread.currentThread().getName() + " is writing!");
            try {
                Thread.currentThread().sleep(rand.nextInt(3000));
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        } finally {
            writeLock.unlock();
        }
    }
    public boolean isLockedRead(){
        return readLock.tryLock();
    }
    public boolean isLockedWrite(){
        return writeLock.tryLock();
    }
}
class Reader implements Runnable {
    Random rand = new Random();
    private ReaderWriter readerWriter;
    public Reader(ReaderWriter rw){
        readerWriter=rw;
    }
    @Override
    public void run() {
        while(true){
            if(readerWriter.isLockedRead()){
                readerWriter.read();
           }else{
                System.out.println(Thread.currentThread().getName()+" is waiting to read!");
                try {
                    Thread.currentThread().sleep(rand.nextInt(3000));
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}
class Writer implements Runnable {
    Random rand = new Random();
    private ReaderWriter readerWriter;
    public Writer(ReaderWriter rw){
        readerWriter=rw;
    }
    @Override
    public void run() {
        while(true){
            if(readerWriter.isLockedWrite()){
 
                readerWriter.write();
            }else{
                System.out.println(Thread.currentThread().getName()+" is waiting to write!");
                try {
                    Thread.currentThread().sleep(rand.nextInt(3000));
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}
class Main{
    public static void main(String[] args) {
        ReaderWriter rw = new ReaderWriter();
        for (int i = 0; i <2 ; i++) {
            new Thread(new Writer(rw)).start();
        }
        for (int i = 0; i <10 ; i++) {
           new Thread(new Reader(rw)).start();
        }
 
    }
}