JAVA-5505 minor refactoring (#1488)

JAVA-5505

Author: katcharov

driver-core/src/main/com/mongodb/internal/connection/tlschannel/async/AsynchronousTlsChannel.java

@@ -98,8 +98,8 @@ public <A> void read(ByteBuffer dst, A attach, CompletionHandler<Integer, ? supe
         new ByteBufferSet(dst),
         0,
         TimeUnit.MILLISECONDS,
-        c -> group.executor.submit(() -> handler.completed((int) c, attach)),
-        e -> group.executor.submit(() -> handler.failed(e, attach)));
+        c -> group.submit(() -> handler.completed((int) c, attach)),
+        e -> group.submit(() -> handler.failed(e, attach)));
   }
 
   @Override
@@ -119,8 +119,8 @@ public <A> void read(
         new ByteBufferSet(dst),
         timeout,
         unit,
-        c -> group.executor.submit(() -> handler.completed((int) c, attach)),
-        e -> group.executor.submit(() -> handler.failed(e, attach)));
+        c -> group.submit(() -> handler.completed((int) c, attach)),
+        e -> group.submit(() -> handler.failed(e, attach)));
   }
 
   @Override
@@ -145,8 +145,8 @@ public <A> void read(
         bufferSet,
         timeout,
         unit,
-        c -> group.executor.submit(() -> handler.completed(c, attach)),
-        e -> group.executor.submit(() -> handler.failed(e, attach)));
+        c -> group.submit(() -> handler.completed(c, attach)),
+        e -> group.submit(() -> handler.failed(e, attach)));
   }
 
   @Override
@@ -185,8 +185,8 @@ public <A> void write(ByteBuffer src, A attach, CompletionHandler<Integer, ? sup
         new ByteBufferSet(src),
         0,
         TimeUnit.MILLISECONDS,
-        c -> group.executor.submit(() -> handler.completed((int) c, attach)),
-        e -> group.executor.submit(() -> handler.failed(e, attach)));
+        c -> group.submit(() -> handler.completed((int) c, attach)),
+        e -> group.submit(() -> handler.failed(e, attach)));
   }
 
   @Override
@@ -205,8 +205,8 @@ public <A> void write(
         new ByteBufferSet(src),
         timeout,
         unit,
-        c -> group.executor.submit(() -> handler.completed((int) c, attach)),
-        e -> group.executor.submit(() -> handler.failed(e, attach)));
+        c -> group.submit(() -> handler.completed((int) c, attach)),
+        e -> group.submit(() -> handler.failed(e, attach)));
   }
 
   @Override
@@ -228,8 +228,8 @@ public <A> void write(
         bufferSet,
         timeout,
         unit,
-        c -> group.executor.submit(() -> handler.completed(c, attach)),
-        e -> group.executor.submit(() -> handler.failed(e, attach)));
+        c -> group.submit(() -> handler.completed(c, attach)),
+        e -> group.submit(() -> handler.failed(e, attach)));
   }
 
   @Override
@@ -251,11 +251,11 @@ public Future<Integer> write(ByteBuffer src) {
   }
 
   private <A> void completeWithZeroInt(A attach, CompletionHandler<Integer, ? super A> handler) {
-    group.executor.submit(() -> handler.completed(0, attach));
+    group.submit(() -> handler.completed(0, attach));
   }
 
   private <A> void completeWithZeroLong(A attach, CompletionHandler<Long, ? super A> handler) {
-    group.executor.submit(() -> handler.completed(0L, attach));
+    group.submit(() -> handler.completed(0L, attach));
   }
 
   /**

driver-core/src/main/com/mongodb/internal/connection/tlschannel/async/AsynchronousTlsChannelGroup.java

@@ -159,7 +159,7 @@ static final class WriteOperation extends Operation {
 
     private final Selector selector;
 
-    final ExecutorService executor;
+    private final ExecutorService executor;
 
     private final ScheduledThreadPoolExecutor timeoutExecutor =
             new ScheduledThreadPoolExecutor(
@@ -228,6 +228,10 @@ public AsynchronousTlsChannelGroup() {
         this(Runtime.getRuntime().availableProcessors());
     }
 
+    void submit(final Runnable r) {
+        executor.submit(r);
+    }
+
     RegisteredSocket registerSocket(TlsChannel reader, SocketChannel socketChannel) {
         if (shutdown != Shutdown.No) {
             throw new ShutdownChannelGroupException();