Adding tests.

@@ -186,12 +186,15 @@ public final class RingBufferWheel {
     }
     }
 
 
     private void size2Notify() {
     private void size2Notify() {
-        lock.lock();
-        int size = taskSize.decrementAndGet();
-        if (size == 0) {
-            condition.signal();
+        try {
+            lock.lock();
+            int size = taskSize.decrementAndGet();
+            if (size == 0) {
+                condition.signal();
+            }
+        }finally {
+            lock.unlock();
         }
         }
-        lock.unlock();
     }
     }
 
 
     private boolean powerOf2(int target) {
     private boolean powerOf2(int target) {

 package com.crossoverjie.cim.common.data.construct;
 package com.crossoverjie.cim.common.data.construct;
 
 
-import org.junit.Test;
 import org.slf4j.Logger;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.slf4j.LoggerFactory;
 
 
@@ -21,7 +20,7 @@ public class RingBufferWheelTest {
     private static void test1() throws InterruptedException {
     private static void test1() throws InterruptedException {
         ExecutorService executorService = Executors.newFixedThreadPool(2) ;
         ExecutorService executorService = Executors.newFixedThreadPool(2) ;
 
 
-        Task task = new Task() ;
+        RingBufferWheel.Task task = new Task() ;
         task.setKey(10);
         task.setKey(10);
         RingBufferWheel wheel = new RingBufferWheel(executorService) ;
         RingBufferWheel wheel = new RingBufferWheel(executorService) ;
         wheel.addTask(task) ;
         wheel.addTask(task) ;
@@ -40,7 +39,7 @@ public class RingBufferWheelTest {
     private static void test2() throws InterruptedException {
     private static void test2() throws InterruptedException {
         ExecutorService executorService = Executors.newFixedThreadPool(2) ;
         ExecutorService executorService = Executors.newFixedThreadPool(2) ;
 
 
-        Task task = new Task() ;
+        RingBufferWheel.Task task = new Task() ;
         task.setKey(10);
         task.setKey(10);
         RingBufferWheel wheel = new RingBufferWheel(executorService) ;
         RingBufferWheel wheel = new RingBufferWheel(executorService) ;
         wheel.addTask(task) ;
         wheel.addTask(task) ;
@@ -70,7 +69,7 @@ public class RingBufferWheelTest {
     private static void test3() throws InterruptedException {
     private static void test3() throws InterruptedException {
         ExecutorService executorService = Executors.newFixedThreadPool(2) ;
         ExecutorService executorService = Executors.newFixedThreadPool(2) ;
 
 
-        Task task = new Task() ;
+        RingBufferWheel.Task task = new Task() ;
         task.setKey(10);
         task.setKey(10);
         RingBufferWheel wheel = new RingBufferWheel(executorService) ;
         RingBufferWheel wheel = new RingBufferWheel(executorService) ;
         wheel.addTask(task) ;
         wheel.addTask(task) ;
@@ -93,7 +92,7 @@ public class RingBufferWheelTest {
         RingBufferWheel wheel = new RingBufferWheel(executorService) ;
         RingBufferWheel wheel = new RingBufferWheel(executorService) ;
 
 
         for (int i = 0; i < 65; i++) {
         for (int i = 0; i < 65; i++) {
-            Job task = new Job(i) ;
+            RingBufferWheel.Task task = new Job(i) ;
             task.setKey(i);
             task.setKey(i);
             wheel.addTask(task);
             wheel.addTask(task);
         }
         }
@@ -112,7 +111,7 @@ public class RingBufferWheelTest {
         RingBufferWheel wheel = new RingBufferWheel(executorService,512) ;
         RingBufferWheel wheel = new RingBufferWheel(executorService,512) ;
 
 
         for (int i = 0; i < 65; i++) {
         for (int i = 0; i < 65; i++) {
-            Job task = new Job(i) ;
+            RingBufferWheel.Task task = new Job(i) ;
             task.setKey(i);
             task.setKey(i);
             wheel.addTask(task);
             wheel.addTask(task);
         }
         }