Skip to content

Commit 71ed77d

Browse files
committed
Moved the testcase to core-java-jvm module
1 parent 536e9b6 commit 71ed77d

1 file changed

Lines changed: 22 additions & 6 deletions

File tree

core-java-modules/core-java-lang-2/src/test/java/com/baeldung/error/oom/TestExecutorService.java renamed to core-java-modules/core-java-jvm/src/test/java/com/baeldung/error/oom/ExecutorServiceUnitTest.java

Lines changed: 22 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -12,12 +12,12 @@
1212

1313
import org.junit.jupiter.api.Test;
1414

15-
public class TestExecutorService {
15+
public class ExecutorServiceUnitTest {
1616

1717
@Test
1818
public void givenAnExecutorService_WhenMoreTasksSubmitted_ThenAdditionalTasksWait() {
1919

20-
//Given
20+
// Given
2121
int noOfThreads = 5;
2222
ExecutorService executorService = Executors.newFixedThreadPool(noOfThreads);
2323

@@ -29,11 +29,27 @@ public void givenAnExecutorService_WhenMoreTasksSubmitted_ThenAdditionalTasksWai
2929
}
3030
};
3131

32-
//When
32+
// When
3333
IntStream.rangeClosed(1, 10)
3434
.forEach(i -> executorService.submit(runnableTask));
35-
36-
//Then
37-
assertThat(((ThreadPoolExecutor )executorService).getQueue().size(), is(equalTo(5)));
35+
36+
// Then
37+
assertThat(((ThreadPoolExecutor) executorService).getQueue()
38+
.size(), is(equalTo(5)));
39+
}
40+
41+
@Test
42+
public void givenAnExecutorService() throws Exception {
43+
44+
while (true) {
45+
TimeUnit.SECONDS.sleep(5);
46+
new Thread(() -> {
47+
try {
48+
TimeUnit.HOURS.sleep(1);
49+
} catch (InterruptedException e) {
50+
e.printStackTrace();
51+
}
52+
}).start();
53+
}
3854
}
3955
}

0 commit comments

Comments
 (0)