Add unit tests for server worker executor.

Author: krisztiankocsis

jooby-jetty/src/test/java/org/jooby/internal/jetty/JettyServerTest.java

@@ -1,7 +1,10 @@
 package org.jooby.internal.jetty;
 
+import static org.easymock.EasyMock.expect;
 import static org.easymock.EasyMock.expectLastCall;
 import static org.easymock.EasyMock.isA;
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertTrue;
 
 import java.util.Map;
 
@@ -109,6 +112,8 @@ public class JettyServerTest {
     server.stop();
 
     unit.registerMock(Server.class, server);
+
+    expect(server.getThreadPool()).andReturn(unit.get(QueuedThreadPool.class)).anyTimes();
   };
 
   private MockUnit.Block httpConf = unit -> {
@@ -194,7 +199,9 @@ public void startStopServer() throws Exception {
           JettyServer server = new JettyServer(unit.get(HttpHandler.class), config,
               unit.get(Provider.class));
 
+          assertNotNull(server.executor());
           server.start();
+          assertTrue(server.executor().isPresent());
           server.join();
           server.stop();
         });

jooby-netty/src/test/java/org/jooby/internal/netty/NettyServerTest.java

@@ -1,5 +1,8 @@
 package org.jooby.internal.netty;
 
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertTrue;
+
 import static org.easymock.EasyMock.expect;
 import static org.easymock.EasyMock.isA;
 
@@ -117,7 +120,9 @@ public void defaultServer() throws Exception {
         .run(unit -> {
           NettyServer server = new NettyServer(unit.get(HttpHandler.class), config);
           try {
+            assertNotNull(server.executor());
             server.start();
+            assertTrue(server.executor().isPresent());
             server.join();
           } finally {
             server.stop();

jooby-undertow/src/test/java/org/jooby/internal/undertow/UndertowServerTest.java

@@ -1,5 +1,8 @@
 package org.jooby.internal.undertow;
 
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertTrue;
+
 import javax.inject.Provider;
 
 import org.jooby.spi.HttpHandler;
@@ -37,7 +40,9 @@ public void server() throws Exception {
           UndertowServer server = new UndertowServer(unit.get(HttpHandler.class), config,
               unit.get(Provider.class));
           try {
+            assertNotNull(server.executor());
             server.start();
+            assertTrue(server.executor().isPresent());
             server.join();// NOOP
           } finally {
             server.stop();

jooby/src/main/java/org/jooby/Jooby.java

@@ -2359,24 +2359,6 @@ public Jooby executor(final Executor executor) {
     return this;
   }
 
-  /**
-   * Set a named executor to use from {@link Deferred Deferred API}. Useful for override the
-   * default/global executor.
-   *
-   * Default executor runs each task in the thread that invokes {@link Executor#execute execute},
-   * that's a Jooby worker thread. A worker thread in Jooby can block.
-   *
-   * @param name Name of the executor.
-   * @param provider Provider for the executor.
-   * @return This jooby instance.
-   */
-  public Jooby executor(final String name, final Class<? extends javax.inject.Provider<Executor>> provider) {
-    this.executors.add(binder -> {
-      binder.bind(Key.get(Executor.class, Names.named(name))).toProvider(provider).in(Singleton.class);
-    });
-    return this;
-  }
-
   /**
    * Set a named executor to use from {@link Deferred Deferred API}. Useful for override the
    * default/global executor.
@@ -2434,6 +2416,24 @@ public Jooby executor(final String name) {
     return this;
   }
 
+  /**
+   * Set a named executor to use from {@link Deferred Deferred API}. Useful for override the
+   * default/global executor.
+   *
+   * Default executor runs each task in the thread that invokes {@link Executor#execute execute},
+   * that's a Jooby worker thread. A worker thread in Jooby can block.
+   *
+   * @param name Name of the executor.
+   * @param provider Provider for the executor.
+   * @return This jooby instance.
+   */
+  private Jooby executor(final String name, final Class<? extends Provider<Executor>> provider) {
+    this.executors.add(binder -> {
+      binder.bind(Key.get(Executor.class, Names.named(name))).toProvider(provider).in(Singleton.class);
+    });
+    return this;
+  }
+
   /**
    * If the application fails to start all the services are shutdown. Also, the exception is logged
    * and usually the application is going to exit.

jooby/src/main/java/org/jooby/internal/ServerExecutorProvider.java

@@ -20,14 +20,15 @@
 
 import com.google.common.util.concurrent.MoreExecutors;
 import com.google.inject.Inject;
+import com.google.inject.Provider;
 import org.jooby.spi.Server;
 
-import javax.inject.Provider;
 import java.util.concurrent.Executor;
 
 import static java.util.Objects.requireNonNull;
 
-public class ServerExecutorProvider implements Provider<Executor> {
+public class ServerExecutorProvider implements Provider<Executor>
+{
 
   private Executor executor;