org.apache.mina.filter.executor

Class PriorityThreadPoolExecutorTest

java.lang.Object

org.apache.mina.filter.executor.PriorityThreadPoolExecutorTest

public class PriorityThreadPoolExecutorTest
extends Object

Tests that verify the functionality provided by the implementation of PriorityThreadPoolExecutor.

Author:

Guus der Kinderen, guus.der.kinderen@gmail.com

Constructor Summary

Constructors

Constructor and Description
PriorityThreadPoolExecutorTest()

Method Summary

Modifier and Type	Method and Description
void	fifoEntryTestComparatorDifferentSession() Tests that verify the functionality provided by the implementation of PriorityThreadPoolExecutor.SessionEntry .
void	fifoEntryTestNoComparatorDifferentSession() Tests that verify the functionality provided by the implementation of PriorityThreadPoolExecutor.SessionEntry .
void	fifoEntryTestNoComparatorSameSession() Tests that verify the functionality provided by the implementation of PriorityThreadPoolExecutor.SessionEntry .
void	fifoEntryTestWithComparatorSameSession() Tests that verify the functionality provided by the implementation of PriorityThreadPoolExecutor.SessionEntry .
void	testErrorInWorkerRun() Tests the state of PriorityThreadPoolExecutor workers after an Error is thrown when the PriorityThreadPoolExecutor worker is running.
void	testPrioritisation() Asserts that, when enough work is being submitted to the executor for it to start queuing work, prioritisation of work starts to occur.
void	testRuntimeExceptionInWorkerRun() Tests the state of PriorityThreadPoolExecutor workers after a RuntimeException is thrown when the PriorityThreadPoolExecutor Worker is running.

Methods inherited from class java.lang.Object

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

Constructor Detail

PriorityThreadPoolExecutorTest

public PriorityThreadPoolExecutorTest()

Method Detail

fifoEntryTestNoComparatorSameSession

public void fifoEntryTestNoComparatorSameSession()
                                          throws Exception

Tests that verify the functionality provided by the implementation of PriorityThreadPoolExecutor.SessionEntry . This test asserts that, without a provided comparator, entries are considered equal, when they reference the same session.

Throws:

Exception - an exception

fifoEntryTestNoComparatorDifferentSession

public void fifoEntryTestNoComparatorDifferentSession()
                                               throws Exception

Tests that verify the functionality provided by the implementation of PriorityThreadPoolExecutor.SessionEntry . This test asserts that, without a provided comparator, the first entry created is 'less than' an entry that is created later.

Throws:

Exception - an exception

fifoEntryTestWithComparatorSameSession

public void fifoEntryTestWithComparatorSameSession()
                                            throws Exception

Tests that verify the functionality provided by the implementation of PriorityThreadPoolExecutor.SessionEntry . This test asserts that, with a provided comparator, entries are considered equal, when they reference the same session (the provided comparator is ignored).

Throws:

Exception - an exception

fifoEntryTestComparatorDifferentSession

public void fifoEntryTestComparatorDifferentSession()
                                             throws Exception

Tests that verify the functionality provided by the implementation of PriorityThreadPoolExecutor.SessionEntry . This test asserts that a provided comparator is used instead of the (fallback) default behavior (when entries are referring different sessions).

Throws:

Exception - an exception

testPrioritisation

public void testPrioritisation()
                        throws Throwable

Asserts that, when enough work is being submitted to the executor for it to start queuing work, prioritisation of work starts to occur. This implementation starts a number of sessions, and evenly distributes a number of messages to them. Processing each message is artificially made 'expensive', while the executor pool is kept small. This causes work to be queued in the executor. The executor that is used is configured to prefer one specific session. Each session records the timestamp of its last activity. After all work has been processed, the test asserts that the last activity of all sessions was later than the last activity of the preferred session.

Throws:

Exception - an exception

Throwable

testRuntimeExceptionInWorkerRun

public void testRuntimeExceptionInWorkerRun()
                                     throws Throwable

Tests the state of PriorityThreadPoolExecutor workers after a RuntimeException is thrown when the PriorityThreadPoolExecutor Worker is running. Note that the implementation of this test is not representative of how tasks are normally executed, as tasks would ordinarily be 'wrapped' in a FilterChain. Most FilterChain implementations would catch the RuntimeException that is being used in the implementation of this test. The purpose of this test is to verify Worker's behavior when a RuntimeException is thrown during execution occurs (even if that RuntimeException cannot occur in the way that this test simulates it). A test that implements the execution in a more realistic manner is provided in DIRMINA1156Test.

Throws:

Exception - an exception

Throwable

See Also:

DIRMINA1156Test, Issue DIRMINA-1156: Inconsistent worker / idleWorker in ThreadPoolExecutors

testErrorInWorkerRun

public void testErrorInWorkerRun()
                          throws Throwable

Tests the state of PriorityThreadPoolExecutor workers after an Error is thrown when the PriorityThreadPoolExecutor worker is running. Note that the implementation of this test is not representative of how tasks are normally executed, as tasks would ordinarily be 'wrapped' in a FilterChain. Most FilterChain implementations would catch the Error that is being used in the implementation of this test. The purpose of this test is to verify Worker's behavior when an Error is thrown during execution occurs (even if that Error cannot occur in the way that this test simulates it). A test that implements the execution in a more realistic manner is provided in DIRMINA1156Test.

Throws:

Exception - an exception

Throwable

See Also:

DIRMINA1156Test, Issue DIRMINA-1156: Inconsistent worker / idleWorker in ThreadPoolExecutors