honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

tone down test

This commit is contained in:
Robert Muir 2015-05-27 19:53:49 -04:00
parent a86d9e7908
commit 23726ece00
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/test/java/org/elasticsearch/script/python/PythonScriptMultiThreadedTest.java
View File

@ -52,7 +52,7 @@ public class PythonScriptMultiThreadedTest extends ElasticsearchTestCase {
final Object compiled = se.compile("x + y"); final Object compiled = se.compile("x + y");
final AtomicBoolean failed = new AtomicBoolean(); final AtomicBoolean failed = new AtomicBoolean();
Thread[] threads = new Thread[50]; Thread[] threads = new Thread[4];
final CountDownLatch latch = new CountDownLatch(threads.length); final CountDownLatch latch = new CountDownLatch(threads.length);
final CyclicBarrier barrier = new CyclicBarrier(threads.length + 1); final CyclicBarrier barrier = new CyclicBarrier(threads.length + 1);
for (int i = 0; i < threads.length; i++) { for (int i = 0; i < threads.length; i++) {
@ -68,7 +68,7 @@ public class PythonScriptMultiThreadedTest extends ElasticsearchTestCase {
vars.put("x", x); vars.put("x", x);
vars.put("y", y); vars.put("y", y);
ExecutableScript script = se.executable(compiled, vars); ExecutableScript script = se.executable(compiled, vars);
for (int i = 0; i < 100000; i++) { for (int i = 0; i < 10000; i++) {
long result = ((Number) script.run()).longValue(); long result = ((Number) script.run()).longValue();
assertThat(result, equalTo(addition)); assertThat(result, equalTo(addition));
} }
@ -138,7 +138,7 @@ public class PythonScriptMultiThreadedTest extends ElasticsearchTestCase {
final Object compiled = se.compile("x + y"); final Object compiled = se.compile("x + y");
final AtomicBoolean failed = new AtomicBoolean(); final AtomicBoolean failed = new AtomicBoolean();
Thread[] threads = new Thread[50]; Thread[] threads = new Thread[4];
final CountDownLatch latch = new CountDownLatch(threads.length); final CountDownLatch latch = new CountDownLatch(threads.length);
final CyclicBarrier barrier = new CyclicBarrier(threads.length + 1); final CyclicBarrier barrier = new CyclicBarrier(threads.length + 1);
for (int i = 0; i < threads.length; i++) { for (int i = 0; i < threads.length; i++) {
@ -148,7 +148,7 @@ public class PythonScriptMultiThreadedTest extends ElasticsearchTestCase {
try { try {
barrier.await(); barrier.await();
Map<String, Object> runtimeVars = new HashMap<String, Object>(); Map<String, Object> runtimeVars = new HashMap<String, Object>();
for (int i = 0; i < 100000; i++) { for (int i = 0; i < 10000; i++) {
long x = ThreadLocalRandom.current().nextInt(); long x = ThreadLocalRandom.current().nextInt();
long y = ThreadLocalRandom.current().nextInt(); long y = ThreadLocalRandom.current().nextInt();
long addition = x + y; long addition = x + y;