Package org.apache.hadoop.hbase.util

Class TestStealJobQueue

java.lang.Object

org.apache.hadoop.hbase.util.TestStealJobQueue

@Tag("org.apache.hadoop.hbase.testclassification.MiscTests") @Tag("org.apache.hadoop.hbase.testclassification.SmallTests")
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
(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

stealJobQueue

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

stealFromQueue

BlockingQueue<Integer> stealFromQueue

Constructor Details

TestStealJobQueue

public TestStealJobQueue()

Method Details

setup

@BeforeEach
public void setup()

testTake

@Test
public void testTake()
              throws InterruptedException

Throws:

InterruptedException

testOfferInStealQueueFromShouldUnblock

@Test
public void testOfferInStealQueueFromShouldUnblock()
                                            throws InterruptedException

Throws:

InterruptedException

testOfferInStealJobQueueShouldUnblock

@Test
public void testOfferInStealJobQueueShouldUnblock()
                                           throws InterruptedException

Throws:

InterruptedException

testPoll

@Test
public void testPoll()
              throws InterruptedException

Throws:

InterruptedException

testPutInStealQueueFromShouldUnblockPoll

@Test
public void testPutInStealQueueFromShouldUnblockPoll()
                                              throws InterruptedException

Throws:

InterruptedException

testAddInStealJobQueueShouldUnblockPoll

@Test
public void testAddInStealJobQueueShouldUnblockPoll()
                                             throws InterruptedException

Throws:

InterruptedException

testInteractWithThreadPool

@Test
public void testInteractWithThreadPool()
                                throws InterruptedException

Throws:

InterruptedException