From f184d91eff01f44bb0cd19967628a8f745f7b3e0 Mon Sep 17 00:00:00 2001
From: Nikita <abracham.mitchell@gmail.com>
Date: Tue, 9 Aug 2016 15:28:57 +0300
Subject: [PATCH] refactoring

---
 src/main/java/org/redisson/RedissonNode.java | 20 +++++++++-----------
 1 file changed, 9 insertions(+), 11 deletions(-)

diff --git a/src/main/java/org/redisson/RedissonNode.java b/src/main/java/org/redisson/RedissonNode.java
index 0d22e3ea3..957d81d36 100644
--- a/src/main/java/org/redisson/RedissonNode.java
+++ b/src/main/java/org/redisson/RedissonNode.java
@@ -54,26 +54,24 @@ public class RedissonNode {
             }
         }
         
-        if (config.getExecutorServiceWorkers().isEmpty()) {
-            throw new IllegalArgumentException("Executor service workers are empty");
-        }
-        
         start(config);
     }
 
     public static void start(RedissonNodeConfig config) {
-        final RedissonClient redisson = Redisson.create(config);
+        if (config.getExecutorServiceWorkers().isEmpty()) {
+            throw new IllegalArgumentException("Executor service workers are empty");
+        }
+        
         final ExecutorService executor;
-        if (config.getExecutorServiceThreads() != -1) {
-            if (config.getExecutorServiceThreads() == 0) {
-                executor = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors() * 2);
-            } else {
-                executor = Executors.newFixedThreadPool(config.getExecutorServiceThreads());
-            }
+        if (config.getExecutorServiceThreads() == 0) {
+            executor = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors() * 2);
+        } else if (config.getExecutorServiceThreads() > 0) {
+            executor = Executors.newFixedThreadPool(config.getExecutorServiceThreads());
         } else {
             executor = null;
         }
         
+        final RedissonClient redisson = Redisson.create(config);
         for (Entry<String, Integer> entry : config.getExecutorServiceWorkers().entrySet()) {
             String name = entry.getKey();
             int workers = entry.getValue();