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

reworked futures test classes

This commit is contained in:
Adrian Cole 2011-04-04 21:34:11 -07:00
parent e79e651d78
commit f322931755
2 changed files with 20 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
core/src/test/java/com/google/common/util/concurrent/FuturesComposePerformanceTest.java
View File

@ -68,7 +68,7 @@ import com.google.common.collect.Sets;
* *
* @author Adrian Cole * @author Adrian Cole
*/ */
@Test(groups = "performance", sequential = true, testName = "FuturesComposePerformanceTest") @Test(groups = "performance", enabled = false, sequential = true, testName = "FuturesComposePerformanceTest")
public class FuturesComposePerformanceTest { public class FuturesComposePerformanceTest {
private static final int FUDGE = 5; private static final int FUDGE = 5;
private static final int COUNT = 100; private static final int COUNT = 100;
@ -81,6 +81,7 @@ public class FuturesComposePerformanceTest {
* When we use threadpools for both the chain and invoking listener, user experience is * When we use threadpools for both the chain and invoking listener, user experience is
* consistent. * consistent.
*/ */
@Test(enabled = false)
public void whenCachedThreadPoolIsUsedForChainAndListenerMaxDurationIsSumOfCallableAndListener() public void whenCachedThreadPoolIsUsedForChainAndListenerMaxDurationIsSumOfCallableAndListener()
throws InterruptedException, ExecutionException { throws InterruptedException, ExecutionException {
long expectedMax = IO_DURATION + LISTENER_DURATION; long expectedMax = IO_DURATION + LISTENER_DURATION;
@ -102,6 +103,7 @@ public class FuturesComposePerformanceTest {
* When we use threadpools for the chain, but same thread for invoking listener, user experience * When we use threadpools for the chain, but same thread for invoking listener, user experience
* is still consistent. * is still consistent.
*/ */
@Test(enabled = false)
public void whenCachedThreadPoolIsUsedForChainButSameThreadForListenerMaxDurationIsSumOfCallableAndListener() public void whenCachedThreadPoolIsUsedForChainButSameThreadForListenerMaxDurationIsSumOfCallableAndListener()
throws InterruptedException, ExecutionException { throws InterruptedException, ExecutionException {
long expectedMax = IO_DURATION + LISTENER_DURATION; long expectedMax = IO_DURATION + LISTENER_DURATION;
@ -125,6 +127,7 @@ public class FuturesComposePerformanceTest {
* case, listeners are executed in a different thread pool. * case, listeners are executed in a different thread pool.
* *
*/ */
@Test(enabled = false)
public void whenSameThreadIsUsedForChainButCachedThreadPoolForListenerMaxDurationIsSumOfAllIOAndOneListener() public void whenSameThreadIsUsedForChainButCachedThreadPoolForListenerMaxDurationIsSumOfAllIOAndOneListener()
throws InterruptedException, ExecutionException { throws InterruptedException, ExecutionException {
long expectedMax = (IO_DURATION * COUNT) + LISTENER_DURATION; long expectedMax = (IO_DURATION * COUNT) + LISTENER_DURATION;
@ -149,6 +152,7 @@ public class FuturesComposePerformanceTest {
* listener duration. An efficient implementation would call get() on the i/o future lazily. Such * listener duration. An efficient implementation would call get() on the i/o future lazily. Such
* an impl would have a max duration of I/O + Listener * count. * an impl would have a max duration of I/O + Listener * count.
*/ */
@Test(enabled = false)
public void whenSameThreadIsUsedForChainAndListenerMaxDurationIsSumOfAllIOAndAllListeners() public void whenSameThreadIsUsedForChainAndListenerMaxDurationIsSumOfAllIOAndAllListeners()
throws InterruptedException, ExecutionException { throws InterruptedException, ExecutionException {

20
core/src/test/java/org/jclouds/concurrent/FutureIterablesTest.java
View File

@ -44,10 +44,11 @@ import com.google.common.collect.Sets;
* *
* @author Adrian Cole * @author Adrian Cole
*/ */
@Test(groups = "performance", sequential = true, testName = "FutureIterablesTest") @Test(groups = "performance", enabled = false, sequential = true, testName = "FutureIterablesTest")
public class FutureIterablesTest { public class FutureIterablesTest {
ExecutorService ioFunctionExecutor = newCachedThreadPool(); ExecutorService ioFunctionExecutor = newCachedThreadPool();
@Test(enabled = false)
public void testMakeListenableDoesntSerializeFutures() throws InterruptedException, ExecutionException { public void testMakeListenableDoesntSerializeFutures() throws InterruptedException, ExecutionException {
long expectedMax = IO_DURATION; long expectedMax = IO_DURATION;
long expectedMin = IO_DURATION; long expectedMin = IO_DURATION;
@ -60,6 +61,7 @@ public class FutureIterablesTest {
checkTimeThresholds(expectedMin, expectedMax, expectedOverhead, start, responses); checkTimeThresholds(expectedMin, expectedMax, expectedOverhead, start, responses);
} }
@Test(enabled = false)
public void testAwaitCompletionUsingSameThreadExecutorDoesntSerializeFutures() throws InterruptedException, public void testAwaitCompletionUsingSameThreadExecutorDoesntSerializeFutures() throws InterruptedException,
ExecutionException { ExecutionException {
long expectedMax = IO_DURATION; long expectedMax = IO_DURATION;
@ -76,7 +78,9 @@ public class FutureIterablesTest {
checkTimeThresholds(expectedMin, expectedMax, expectedOverhead, start, responses); checkTimeThresholds(expectedMin, expectedMax, expectedOverhead, start, responses);
} }
public void whenCachedThreadPoolIsUsedForChainAndListenerMaxDurationIsSumOfCallableAndListener() throws InterruptedException, ExecutionException { @Test(enabled = false)
public void whenCachedThreadPoolIsUsedForChainAndListenerMaxDurationIsSumOfCallableAndListener()
throws InterruptedException, ExecutionException {
long expectedMax = IO_DURATION + LISTENER_DURATION; long expectedMax = IO_DURATION + LISTENER_DURATION;
long expectedMin = IO_DURATION + LISTENER_DURATION; long expectedMin = IO_DURATION + LISTENER_DURATION;
long expectedOverhead = COUNT * 4 + FUDGE; long expectedOverhead = COUNT * 4 + FUDGE;
@ -92,7 +96,9 @@ public class FutureIterablesTest {
} }
} }
public void whenCachedThreadPoolIsUsedForChainButSameThreadForListenerMaxDurationIsSumOfCallableAndListener() throws InterruptedException, ExecutionException { @Test(enabled = false)
public void whenCachedThreadPoolIsUsedForChainButSameThreadForListenerMaxDurationIsSumOfCallableAndListener()
throws InterruptedException, ExecutionException {
long expectedMax = IO_DURATION + LISTENER_DURATION; long expectedMax = IO_DURATION + LISTENER_DURATION;
long expectedMin = IO_DURATION + LISTENER_DURATION; long expectedMin = IO_DURATION + LISTENER_DURATION;
long expectedOverhead = COUNT + FUDGE; long expectedOverhead = COUNT + FUDGE;
@ -108,7 +114,9 @@ public class FutureIterablesTest {
} }
} }
public void whenSameThreadIsUsedForChainButCachedThreadPoolForListenerMaxDurationIsIOAndSumOfAllListeners() throws InterruptedException, ExecutionException { @Test(enabled = false)
public void whenSameThreadIsUsedForChainButCachedThreadPoolForListenerMaxDurationIsIOAndSumOfAllListeners()
throws InterruptedException, ExecutionException {
long expectedMax = IO_DURATION + (LISTENER_DURATION * COUNT); long expectedMax = IO_DURATION + (LISTENER_DURATION * COUNT);
long expectedMin = IO_DURATION + LISTENER_DURATION; long expectedMin = IO_DURATION + LISTENER_DURATION;
long expectedOverhead = COUNT + FUDGE; long expectedOverhead = COUNT + FUDGE;
@ -124,7 +132,9 @@ public class FutureIterablesTest {
} }
} }
public void whenSameThreadIsUsedForChainAndListenerMaxDurationIsIOAndSumOfAllListeners() throws InterruptedException, ExecutionException { @Test(enabled = false)
public void whenSameThreadIsUsedForChainAndListenerMaxDurationIsIOAndSumOfAllListeners()
throws InterruptedException, ExecutionException {
long expectedMax = IO_DURATION + (LISTENER_DURATION * COUNT); long expectedMax = IO_DURATION + (LISTENER_DURATION * COUNT);
long expectedMin = IO_DURATION + LISTENER_DURATION; long expectedMin = IO_DURATION + LISTENER_DURATION;