dedicatedThread = Thread.currentThread();
DedicatedThreadExecutorTest.assertNotSame(testingThread,
dedicatedThread);
- return 123L;
+ return Long.valueOf(123);
}
});
assertEquals(123, result.longValue());
dedicatedThread = Thread.currentThread();
DedicatedThreadExecutorTest.assertNotSame(testingThread,
dedicatedThread);
- return 456L;
+ return Long.valueOf(456);
}
});
assertEquals(456, result.longValue());
private volatile CounterLatch latch = null;
- public void setUp() {
-
- }
-
+ @Override
public void tearDown() {
CounterLatch temp = latch;
if (temp!=null) temp.releaseAll();
latch = new CounterLatch(0,1);
assertEquals("No threads should be waiting", false, latch.hasQueuedThreads());
Thread testThread = new Thread() {
+ @Override
public void run() {
try {
latch.await();
latch = new CounterLatch(0,1);
assertEquals("No threads should be waiting", false, latch.hasQueuedThreads());
Thread testThread = new Thread() {
+ @Override
public void run() {
try {
latch.await();
latch = new CounterLatch(1,0);
assertEquals("No threads should be waiting", false, latch.hasQueuedThreads());
Thread testThread = new Thread() {
+ @Override
public void run() {
try {
//System.out.println("Entering ["+Thread.currentThread().getName()+"]");
latch = new CounterLatch(1,0);
assertEquals("No threads should be waiting", false, latch.hasQueuedThreads());
Thread testThread = new Thread() {
+ @Override
public void run() {
try {
latch.await();