Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ARTEMIS-3604 Test Improvement

This commit is contained in:
Clebert Suconic 2021-12-13 12:04:25 -05:00
parent 03b61c5da0
commit b5eb7d2342
1 changed files with 19 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
artemis-commons/src/test/java/org/apache/activemq/artemis/utils/actors/ThresholdActorTest.java
View File

@ -121,7 +121,7 @@ public class ThresholdActorTest {
public void block() {
try {
if (!semaphore.tryAcquire(10, TimeUnit.SECONDS)) {
if (!semaphore.tryAcquire()) {
errors.incrementAndGet();
System.err.println("acquire failed");
}
@ -136,6 +136,20 @@ public class ThresholdActorTest {
@Test
public void testFlow() throws Exception {
testFlow(true);
}
/**
* This test will actually not respect the semaphore and keep going.
* The blockers and unblocks should still perform ok.
* @throws Exception
*/
@Test
public void testFlow2() throws Exception {
testFlow(false);
}
public void testFlow(boolean respectSemaphore) throws Exception {
final ExecutorService executorService = Executors.newFixedThreadPool(2);
try {
@ -148,8 +162,10 @@ public class ThresholdActorTest {
executorService.execute(() -> {
for (int i = 0; i <= LAST_ELEMENT; i++) {
try {
semaphore.acquire();
semaphore.release();
if (respectSemaphore) {
semaphore.acquire();
semaphore.release();
}
actor.act(new Element(i, i % 2 == 0 ? 20 : 1));
} catch (Exception e) {
e.printStackTrace();