honeymoose/OpenSearch
1
0
Fork 0
mirror of https://github.com/honeymoose/OpenSearch.git synced 2025-04-08 00:09:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

[TEST] Add CountDownLatches to ensure order of operation.

Browse Source 
This change adds countdownlatches to the `FairKeyedLock` tests on `WatchLockService`.

Original commit: elastic/x-pack-elasticsearch@2bf36e10d2
This commit is contained in:
Brian Murphy 2015-04-21 14:54:11 -04:00
parent 6c54251e61
commit ca38fd6a89
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/test/java/org/elasticsearch/watcher/watch/WatchLockServiceTests.java
View File

@ -11,6 +11,7 @@ import org.junit.Test;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicInteger;
import static org.hamcrest.Matchers.*; import static org.hamcrest.Matchers.*;
@ -66,6 +67,7 @@ public class WatchLockServiceTests extends ElasticsearchTestCase {
class FairRunner implements Runnable { class FairRunner implements Runnable {
final int expectedValue; final int expectedValue;
final CountDownLatch startLatch = new CountDownLatch(1);
FairRunner(int expectedValue) { FairRunner(int expectedValue) {
this.expectedValue = expectedValue; this.expectedValue = expectedValue;
@ -73,6 +75,7 @@ public class WatchLockServiceTests extends ElasticsearchTestCase {
@Override @Override
public void run() { public void run() {
startLatch.countDown();
WatchLockService.Lock lock = lockService.acquire("_name"); WatchLockService.Lock lock = lockService.acquire("_name");
try { try {
int actualValue = value.getAndIncrement(); int actualValue = value.getAndIncrement();
@ -85,13 +88,17 @@ public class WatchLockServiceTests extends ElasticsearchTestCase {
} }
} }
List<FairRunner> runners = new ArrayList<>();
for(int i = 0; i < 100; ++i) { for(int i = 0; i < 100; ++i) {
FairRunner f = new FairRunner(i); FairRunner f = new FairRunner(i);
runners.add(f);
threads.add(new Thread(f)); threads.add(new Thread(f));
} }
for(Thread t : threads) { for(int i = 0; i < threads.size(); ++i) {
t.start(); threads.get(i).start();
runners.get(i).startLatch.await();
Thread.sleep(10); Thread.sleep(10);
} }