public interface IReadWriteLock{
    public void lockWrite();
    public void unlockWrite();
    
    public void lockRead();
    public void unlockRead();
}

public class RWPriorityMonitorLock implements IReadWriteLock{
	
	private boolean dbWritting, writterWantsIn;
	private int numReaders;
	
	public RWPriorityMonitorLock() {
		dbWritting = false;
		numReaders = 0;
		writterWantsIn = false;
	}
	
	@Override
	public void lockRead() {
		while(dbWritting || writterWantsIn)
			try{
				wait();
			}catch(InterruptedException e){ e.printStackTrace(); }
			
		numReaders++;
	}

	@Override
	public void unlockRead() {
		numReaders--;
		
		if(numReaders == 0)
			notify();
	}

	@Override
	public void lockWrite() {
		writterWantsIn = true;
		while(numReaders > 0 || dbWritting)
			try{
				wait();
			}catch(InterruptedException e){ e.printStackTrace(); }
		
		dbWritting = true;
		writterWantsIn = false;
	}

	@Override
	public void unlockWrite() {
		dbWritting = false;
		notifyAll();
	}
}

public aspect IReadWriteLockAspect {

	private static Map<IReadWriteLock, Lock> allLocks = new HashMap<>();

	pointcut lockReflectInit(): call(public Object 
			java.lang.reflect.Constructor.newInstance(..));  

	pointcut hardWaitMutex():
		call(public void IReadWriteLock+.*());

	void around(): hardWaitMutex(){
		IReadWriteLock currentLock = (IReadWriteLock) thisJoinPoint.getTarget();
		Lock mutex = allLocks.get(currentLock);
		mutex.lock();
		try{
			proceed();
		}finally{
			mutex.unlock();
		}
	}

	Object around(): lockReflectInit() {
		IReadWriteLock lockType = (IReadWriteLock)proceed();
		allLocks.put(lockType, new ReentrantLock(true));
		return lockType;
	}
}