org.spf4j.concurrent

Class LifoThreadPoolExecutor2Test

java.lang.Object

org.spf4j.concurrent.LifoThreadPoolExecutor2Test

public class LifoThreadPoolExecutor2Test
extends Object

Author:

zoly

Constructor Summary

Constructors

Constructor and Description
LifoThreadPoolExecutor2Test()

Method Summary

Modifier and Type	Method and Description
static void	assertPoolThreadDynamics(ExecutorService executor)
static int	consume(Collection<Future<?>> futures)
void	testJdkExec() this is to confirm JDK behavior.
void	testLifoExecSQ()
static void	testMaxParallel(ExecutorService executor, int maxParallel, long time, TimeUnit unit)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LifoThreadPoolExecutor2Test

public LifoThreadPoolExecutor2Test()

Method Detail

testLifoExecSQ

public void testLifoExecSQ()
                    throws InterruptedException,
                           IOException,
                           ExecutionException

Throws:

InterruptedException

IOException

ExecutionException

testJdkExec

public void testJdkExec()
                 throws InterruptedException,
                        IOException,
                        ExecutionException

this is to confirm JDK behavior.

Throws:

InterruptedException

IOException

ExecutionException

assertPoolThreadDynamics

public static void assertPoolThreadDynamics(ExecutorService executor)
                                     throws InterruptedException,
                                            IOException,
                                            ExecutionException

Throws:

InterruptedException

IOException

ExecutionException

testMaxParallel

public static void testMaxParallel(ExecutorService executor,
                                   int maxParallel,
                                   long time,
                                   TimeUnit unit)
                            throws InterruptedException

Throws:

InterruptedException

consume

public static int consume(Collection<Future<?>> futures)
                   throws InterruptedException

Throws:

InterruptedException