VoltronReadWriteLockActiveEntityTest.java 文件源码

@Test
public void testWriteUnlockNotifiesListeners() throws MessageCodecException {
  ClientCommunicator communicator = mock(ClientCommunicator.class);
  VoltronReadWriteLockActiveEntity entity = new VoltronReadWriteLockActiveEntity(communicator);

  ClientDescriptor locker = mock(ClientDescriptor.class);
  ClientDescriptor waiter = mock(ClientDescriptor.class);

  entity.invoke(locker, LockMessaging.lock(WRITE));
  entity.invoke(waiter, LockMessaging.lock(WRITE));
  entity.invoke(locker, LockMessaging.unlock(WRITE));

  verify(communicator).sendNoResponse(eq(waiter), argThat(
          HasPropertyWithValue.<EntityResponse>hasProperty("released", is(true))));
}