org.apache.hadoop.hbase.util

Class TestStealJobQueue

java.lang.Object

org.apache.hadoop.hbase.util.TestStealJobQueue

public class TestStealJobQueue
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	TestStealJobQueue.TestTask

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
(package private) BlockingQueue<Integer>	stealFromQueue
(package private) org.apache.hadoop.hbase.util.StealJobQueue<Integer>	stealJobQueue

Constructor Summary

Constructors

Constructor and Description
TestStealJobQueue()

Method Summary

Modifier and Type	Method and Description
void	setup()
void	testAddInStealJobQueueShouldUnblockPoll()
void	testInteractWithThreadPool()
void	testOfferInStealJobQueueShouldUnblock()
void	testOfferInStealQueueFromShouldUnblock()
void	testPoll()
void	testPutInStealQueueFromShouldUnblockPoll()
void	testTake()

Methods inherited from class java.lang.Object

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

Field Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

stealJobQueue

org.apache.hadoop.hbase.util.StealJobQueue<Integer> stealJobQueue

stealFromQueue

BlockingQueue<Integer> stealFromQueue

Constructor Detail

TestStealJobQueue

public TestStealJobQueue()

Method Detail

setup

public void setup()

testTake

public void testTake()
              throws InterruptedException

Throws:

InterruptedException

testOfferInStealQueueFromShouldUnblock

public void testOfferInStealQueueFromShouldUnblock()
                                            throws InterruptedException

Throws:

InterruptedException

testOfferInStealJobQueueShouldUnblock

public void testOfferInStealJobQueueShouldUnblock()
                                           throws InterruptedException

Throws:

InterruptedException

testPoll

public void testPoll()
              throws InterruptedException

Throws:

InterruptedException

testPutInStealQueueFromShouldUnblockPoll

public void testPutInStealQueueFromShouldUnblockPoll()
                                              throws InterruptedException

Throws:

InterruptedException

testAddInStealJobQueueShouldUnblockPoll

public void testAddInStealJobQueueShouldUnblockPoll()
                                             throws InterruptedException

Throws:

InterruptedException

testInteractWithThreadPool

public void testInteractWithThreadPool()
                                throws InterruptedException

Throws:

InterruptedException