|
| |
|
| org.jgroups.tests.QueueTest
| QueueTest | | public class QueueTest extends TestCase (Code) | | |
| Inner Class :class AddOneItem extends Thread | |
| Inner Class :class RemoveOneItem extends Thread | |
| Inner Class :class RemoveOneItemWithTimeout extends Thread | |
| Inner Class :class Writer extends Thread | |
| Inner Class :class Reader extends Thread | |
| testBarrier | | public void testBarrier()(Code) | | Multiple threads call remove(), one threads then adds an element. Only 1 thread should actually terminate
(the one that has the element)
|
| testBarrierWithTimeOut | | public void testBarrierWithTimeOut()(Code) | | Multiple threads call remove(), one threads then adds an element. Only 1 thread should actually terminate
(the one that has the element)
|
| testCloseWithFlush | | public void testCloseWithFlush()(Code) | | |
| testCloseWithoutFlush | | public void testCloseWithoutFlush()(Code) | | |
| testConcurrentAccess | | public void testConcurrentAccess()(Code) | | Has multiple threads add(), remove() and peek() elements to/from the queue
|
| testConcurrentAddRemove | | public void testConcurrentAddRemove()(Code) | | Times how long it takes to add and remove 1000000 elements concurrently (1 reader, 1 writer)
|
| testEmptyQueue | | public void testEmptyQueue()(Code) | | |
| testInsertionAndRemoval | | public void testInsertionAndRemoval() throws Exception(Code) | | |
| testLargeInsertion | | public void testLargeInsertion()(Code) | | |
| testMultipleWriterOneReader | | public void testMultipleWriterOneReader()(Code) | | Multiple threads add one element, one thread read them all.
(the one that has the element)
|
| testQueue | | public void testQueue()(Code) | | |
| testRemoveAndClose | | public void testRemoveAndClose()(Code) | | |
| testRemoveAndInterrupt | | public void testRemoveAndInterrupt()(Code) | | |
| testRemoveElementNoElement | | public void testRemoveElementNoElement()(Code) | | |
| testRemoveElementOneElement | | public void testRemoveElementOneElement()(Code) | | |
| testRemoveElementThreeElementsFirstFound | | public void testRemoveElementThreeElementsFirstFound()(Code) | | |
| testRemoveElementThreeElementsSecondFound | | public void testRemoveElementThreeElementsSecondFound()(Code) | | |
| testRemoveElementThreeElementsThirdFound | | public void testRemoveElementThreeElementsThirdFound()(Code) | | |
| testRemoveElementTwoElementsFirstFound | | public void testRemoveElementTwoElementsFirstFound()(Code) | | |
| testRemoveElementTwoElementsSecondFound | | public void testRemoveElementTwoElementsSecondFound()(Code) | | |
| testWaitUntilClosed | | public void testWaitUntilClosed()(Code) | | |
| testWaitUntilClosed2 | | public void testWaitUntilClosed2()(Code) | | |
|
|
|