private synchronized void addToQueue(MonoSink<Lock> callback, LockType lockType) {
lockRequestQueue.add(new LockRequest(callback, lockType, this));
private synchronized void addToQueue(MonoSink<Lock> callback, LockType lockType) {
lockRequestQueue.add(new LockRequest(callback, lockType, this));