tests optimization

src/test/java/org/redisson/BaseConcurrentTest.java

@@ -2,13 +2,11 @@ package org.redisson;
 
 import java.util.HashMap;
 import java.util.Map;
-import java.util.Queue;
-import java.util.concurrent.ConcurrentLinkedQueue;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.TimeUnit;
 
-public abstract class BaseConcurrentTest {
+public abstract class BaseConcurrentTest extends BaseTest {
 
     protected void testMultiInstanceConcurrency(int iterations, final RedissonRunnable runnable) throws InterruptedException {
         ExecutorService executor = Executors.newCachedThreadPool();

src/test/java/org/redisson/BaseTest.java

@@ -1,15 +1,21 @@
 package org.redisson;
 
 import org.junit.After;
-import org.junit.Before;
+import org.junit.AfterClass;
+import org.junit.BeforeClass;
 
 public abstract class BaseTest {
 
-    protected Redisson redisson;
+    protected static Redisson redisson;
 
-    @Before
+    @BeforeClass
-    public void before() {
+    public static void beforeClass() {
-        this.redisson = createInstance();
+        redisson = createInstance();
+    }
+
+    @AfterClass
+    public static void afterClass() {
+        redisson.shutdown();
     }
 
     public static Redisson createInstance() {
@@ -19,17 +25,12 @@ public abstract class BaseTest {
         }
         Config config = new Config();
         config.useSingleServer().setAddress(redisAddress);
-//        config.setCodec(new SerializationCodec());
         return Redisson.create(config);
     }
 
     @After
     public void after() {
-        try {
+        redisson.flushdb();
-            redisson.flushdb();
-        } finally {
-            redisson.shutdown();
-        }
     }
 
 }