private CeServer underTest = null;
private Thread waitingThread = null;
- private MinimumViableSystem minimumViableSystem = mock(MinimumViableSystem.class, Mockito.RETURNS_MOCKS);
- private CeSecurityManager ceSecurityManager = mock(CeSecurityManager.class);
+ private final MinimumViableSystem minimumViableSystem = mock(MinimumViableSystem.class, Mockito.RETURNS_MOCKS);
+ private final CeSecurityManager ceSecurityManager = mock(CeSecurityManager.class);
@After
public void tearDown() throws Exception {
@Test
public void constructor_does_not_start_a_new_Thread() {
- int activeCount = Thread.activeCount();
+ assertThat(ceThreadExists()).isFalse();
newCeServer();
- assertThat(Thread.activeCount()).isSameAs(activeCount);
+ assertThat(ceThreadExists()).isFalse();
}
@Test
@Test
public void start_starts_a_new_Thread() {
- int activeCount = Thread.activeCount();
-
+ assertThat(ceThreadExists()).isFalse();
newCeServer().start();
-
- assertThat(Thread.activeCount()).isSameAs(activeCount + 1);
+ assertThat(ceThreadExists()).isTrue();
}
@Test
}
private static boolean ceThreadExists() {
- return Thread.getAllStackTraces().keySet().stream().anyMatch(t -> t.getName().equals("ce-main"));
+ return Thread.getAllStackTraces().keySet()
+ .stream()
+ .map(Thread::getName)
+ .anyMatch("ce-main"::equals);
}
@Test