add 'executorService.shutdown()' call to 'Server.stop()' (#73)

* add 'executorService.shutdown()' call to 'Server.stop()' and assertTrue in ServerShutdownTest

* add assertFalse(server.executorService.isShutdown()) before shutdown to make sure it stops on server.stop() and not before.

* move executorService.shutdown() to after socketPoll while loop. remove from SocketPoll.java.

* move executorService.shutdown() to finally block

src/main/java/com/teragrep/rlp_03/Server.java

@@ -115,10 +115,15 @@ public void run() {
             while (!stop.get()) {
                 socketPoll.poll();
             }
+
         }
         catch (IOException ioException) {
             throw new UncheckedIOException(ioException);
         }
+        finally {
+            // shutdown executorService when outside of poll() loop
+            executorService.shutdown();
+        }
         LOGGER.debug("Stopped");
     }
 }

src/main/java/com/teragrep/rlp_03/SocketPoll.java

@@ -140,7 +140,6 @@ public void poll() throws IOException {
     public void close() throws IOException {
         serverSocketChannel.close();
         selector.close();
-        executorService.shutdown();
     }
 
     private void processAccept(ServerSocketChannel serverSocketChannel, SelectionKey selectionKey) throws IOException {

src/test/java/com/teragrep/rlp_03/ServerShutdownTest.java

@@ -49,6 +49,13 @@
 import com.teragrep.rlp_03.config.Config;
 import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.condition.DisabledOnJre;
+import org.junit.jupiter.api.condition.JRE;
+
+import java.io.IOException;
+
+import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertTrue;
 
 public class ServerShutdownTest {
     @Test
@@ -63,10 +70,12 @@ public void testServerShutdownSingleThread() {
 
             server.startup.waitForCompletion();
 
+            Assertions.assertFalse(server.executorService.isShutdown());
             server.stop();
-
             serverThread.join();
+            Assertions.assertTrue(server.executorService.isShutdown());
         });
+
     }
 
     @Test
@@ -81,9 +90,10 @@ public void testServerShutdownMultiThread() {
 
             server.startup.waitForCompletion();
 
+            Assertions.assertFalse(server.executorService.isShutdown());
             server.stop();
-
             serverThread.join();
+            Assertions.assertTrue(server.executorService.isShutdown());
         });
     }
 }