Package 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	Description
(package private) class	TestStealJobQueue.TestTask

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
TestStealJobQueue()

Method Summary

Modifier and Type	Method	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 Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

stealJobQueue

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

stealFromQueue

BlockingQueue<Integer> stealFromQueue

Constructor Details

TestStealJobQueue

public TestStealJobQueue()

Method Details

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