Mercurial Hosting > luan

comparison src/org/eclipse/jetty/server/nio/SelectChannelConnector.java @ 865:6b210bb66c63

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
remove ThreadPool
author Franklin Schmidt <fschmidt@gmail.com>
date Sun, 02 Oct 2016 20:38:06 -0600
parents e21ca9878a10
children df84a1741687
comparison
equal deleted inserted replaced
864:e21ca9878a10 865:6b210bb66c63
34 import org.eclipse.jetty.io.nio.SelectChannelEndPoint; 34 import org.eclipse.jetty.io.nio.SelectChannelEndPoint;
35 import org.eclipse.jetty.io.nio.SelectorManager; 35 import org.eclipse.jetty.io.nio.SelectorManager;
36 import org.eclipse.jetty.io.nio.SelectorManager.SelectSet; 36 import org.eclipse.jetty.io.nio.SelectorManager.SelectSet;
37 import org.eclipse.jetty.server.AsyncHttpConnection; 37 import org.eclipse.jetty.server.AsyncHttpConnection;
38 import org.eclipse.jetty.server.Request; 38 import org.eclipse.jetty.server.Request;
39 import org.eclipse.jetty.util.thread.ThreadPool;
40 39
41 /* ------------------------------------------------------------------------------- */ 40 /* ------------------------------------------------------------------------------- */
42 /** 41 /**
43 * Selecting NIO connector. 42 * Selecting NIO connector.
44 * <p> 43 * <p>
281 /* ------------------------------------------------------------ */ 280 /* ------------------------------------------------------------ */
282 /* ------------------------------------------------------------ */ 281 /* ------------------------------------------------------------ */
283 private final class ConnectorSelectorManager extends SelectorManager 282 private final class ConnectorSelectorManager extends SelectorManager
284 { 283 {
285 @Override 284 @Override
286 public boolean dispatch(Runnable task) 285 public void execute(Runnable task)
287 { 286 {
288 ThreadPool pool=getThreadPool(); 287 getThreadPool().execute(task);
289 if (pool==null)
290 pool=getServer().getThreadPool();
291 return pool.dispatch(task);
292 } 288 }
293 289
294 @Override 290 @Override
295 protected void endPointClosed(final SelectChannelEndPoint endpoint) 291 protected void endPointClosed(final SelectChannelEndPoint endpoint)
296 { 292 {