本文整理了Java中org.eclipse.jetty.server.Server.getThreadPool()方法的一些代码示例，展示了Server.getThreadPool()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Server.getThreadPool()方法的具体详情如下：
包路径：org.eclipse.jetty.server.Server
类名称：Server
方法名：getThreadPool

Server.getThreadPool介绍

暂无

代码示例

代码示例来源：origin: jooby-project/jooby

@Override
public Optional<Executor> executor() {
 return Optional.ofNullable(server.getThreadPool());
}

代码示例来源：origin: perwendel/spark

@Override
public int activeThreadCount() {
  if (server == null) {
    return 0;
  }
  return server.getThreadPool().getThreads() - server.getThreadPool().getIdleThreads();
}

代码示例来源：origin: 4thline/cling

@Override
synchronized public void setExecutorService(ExecutorService executorService) {
  if (INSTANCE.server.getThreadPool() == null) {
    INSTANCE.server.setThreadPool(new ExecutorThreadPool(executorService) {
      @Override
      protected void doStop() throws Exception {
        // Do nothing, don't shut down the Cling ExecutorService when Jetty stops!
      }
    });
  }
}

代码示例来源：origin: loklak/loklak_server

public static int getServerThreads() {
  return server.getThreadPool().getThreads() - server.getThreadPool().getIdleThreads();
}

代码示例来源：origin: apache/hbase

/**
 * Set the min, max number of worker threads (simultaneous connections).
 */
public void setThreads(int min, int max) {
 QueuedThreadPool pool = (QueuedThreadPool) webServer.getThreadPool();
 pool.setMinThreads(min);
 pool.setMaxThreads(max);
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

/**
 * Set the min, max number of worker threads (simultaneous connections).
 */
public void setThreads(int min, int max) {
 QueuedThreadPool pool = (QueuedThreadPool) webServer.getThreadPool();
 pool.setMinThreads(min);
 pool.setMaxThreads(max);
}

代码示例来源：origin: alibaba/jvm-sandbox

private void initHttpServer(final CoreConfigure cfg) {
  // 如果IP:PORT已经被占用，则无法继续被绑定
  // 这里说明下为什么要这么无聊加个这个判断，让Jetty的Server.bind()抛出异常不是更好么？
  // 比较郁闷的是，如果这个端口的绑定是"SO_REUSEADDR"端口可重用的模式，那么这个server是能正常启动，但无法正常工作的
  // 所以这里必须先主动检查一次端口占用情况，当然了，这里也会存在一定的并发问题，BUT，我认为这种概率事件我可以选择暂时忽略
  if (isPortInUsing(cfg.getServerIp(), cfg.getServerPort())) {
    throw new IllegalStateException(format("address[%s:%s] already in using, server bind failed.",
        cfg.getServerIp(),
        cfg.getServerPort())
    );
  }
  httpServer = new Server(new InetSocketAddress(cfg.getServerIp(), cfg.getServerPort()));
  if (httpServer.getThreadPool() instanceof QueuedThreadPool) {
    final QueuedThreadPool qtp = (QueuedThreadPool) httpServer.getThreadPool();
    qtp.setName("sandbox-jetty-qtp-" + qtp.hashCode());
  }
}

代码示例来源：origin: apache/incubator-druid

@Test
public void testNumThreads()
{
 // Just make sure the injector stuff for this test is actually working.
 Assert.assertEquals(
   10,
   ((QueuedThreadPool) server.getThreadPool()).getMaxThreads()
 );
}

代码示例来源：origin: apache/hbase

@Override
 public void run() {
  ready.countDown();
  try {
   start.await();
   assertEquals("a:b\nc:d\n",
          readOutput(new URL(baseUrl, "/echo?a=b&c=d")));
   int serverThreads = server.webServer.getThreadPool().getThreads();
   assertTrue("More threads are started than expected, Server Threads count: "
       + serverThreads, serverThreads <= MAX_THREADS);
   System.out.println("Number of threads = " + serverThreads +
     " which is less or equal than the max = " + MAX_THREADS);
  } catch (Exception e) {
   // do nothing
  }
 }
});

代码示例来源：origin: gocd/gocd

@Before
public void setUp() throws Exception {
  initMocks(this);
  when(server.getThreadPool()).thenReturn(new QueuedThreadPool(1));
  Answer<Void> setHandlerMock = invocation -> {
    serverLevelHandler = (Handler) invocation.getArguments()[0];

代码示例来源：origin: line/armeria

ArmeriaConnector(Server server) {
  this.server = server;
  executor = server.getThreadPool();
  final HttpConfiguration httpConfig = server.getBean(HttpConfiguration.class);
  this.httpConfig = httpConfig != null ? httpConfig : new HttpConfiguration();
  final Scheduler scheduler = server.getBean(Scheduler.class);
  this.scheduler = scheduler != null ? scheduler : new ScheduledExecutorScheduler();
  final ByteBufferPool byteBufferPool = server.getBean(ByteBufferPool.class);
  this.byteBufferPool = byteBufferPool != null ? byteBufferPool : new ArrayByteBufferPool();
  addBean(server, false);
  addBean(executor);
  unmanage(executor);
  addBean(this.httpConfig);
  addBean(this.scheduler);
  addBean(this.byteBufferPool);
  connectionFactory = new ArmeriaConnectionFactory();
  connectionFactories = Collections.singleton(connectionFactory);
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

QueuedThreadPool threadPool = (QueuedThreadPool) webServer.getThreadPool();
threadPool.setDaemon(true);
if (maxThreads != -1) {

代码示例来源：origin: neo4j/neo4j

@Test
public void shouldHaveConfigurableJettyThreadPoolSize() throws Exception
{
  Jetty9WebServer server = new Jetty9WebServer( NullLogProvider.getInstance(), Config.defaults(), NetworkConnectionTracker.NO_OP );
  int numCores = 1;
  int configuredMaxThreads = 12; // 12 is the new min max Threads value, for one core
  int acceptorThreads = 1; // In this configuration, 1 thread will become an acceptor...
  int selectorThreads = 1; // ... and 1 thread will become a selector...
  int jobThreads = configuredMaxThreads - acceptorThreads - selectorThreads; // ... and the rest are job threads
  server.setMaxThreads( numCores );
  server.setHttpAddress( new ListenSocketAddress( "localhost", 0 ) );
  try
  {
    server.start();
    QueuedThreadPool threadPool = (QueuedThreadPool) server.getJetty().getThreadPool();
    threadPool.start();
    CountDownLatch startLatch = new CountDownLatch( jobThreads );
    CountDownLatch endLatch = loadThreadPool( threadPool, configuredMaxThreads + 1, startLatch );
    startLatch.await(); // Wait for threadPool to create threads
    int threads = threadPool.getThreads();
    assertEquals( "Wrong number of threads in pool", configuredMaxThreads, threads );
    endLatch.countDown();
  }
  finally
  {
    server.stop();
  }
}

代码示例来源：origin: yacy/yacy_grid_mcp

public static void join() {
  try {
    server.getThreadPool().join();
  } catch (Exception e) {
    Data.logger.warn("", e);
  }
}

代码示例来源：origin: kingthy/TVRemoteIME

@Override
synchronized public void setExecutorService(ExecutorService executorService) {
  if (INSTANCE.server.getThreadPool() == null) {
    INSTANCE.server.setThreadPool(new ExecutorThreadPool(executorService) {
      @Override
      protected void doStop() throws Exception {
        // Do nothing, don't shut down the Cling ExecutorService when Jetty stops!
      }
    });
  }
}

代码示例来源：origin: yacy/yacy_grid_mcp

public static int getServerThreads() {
  return server.getThreadPool().getThreads() - server.getThreadPool().getIdleThreads();
}

代码示例来源：origin: org.springframework.boot/spring-boot-actuator

private ThreadPool findThreadPool(ApplicationContext applicationContext) {
  if (applicationContext instanceof WebServerApplicationContext) {
    WebServer webServer = ((WebServerApplicationContext) applicationContext)
        .getWebServer();
    if (webServer instanceof JettyWebServer) {
      return ((JettyWebServer) webServer).getServer().getThreadPool();
    }
  }
  return null;
}

代码示例来源：origin: sixt/ja-micro

public void startJettyContainer() throws Exception {
  jettyServer = new Server(serviceProperties.getServicePort());
  org.eclipse.jetty.util.thread.ThreadPool threadPool = jettyServer.getThreadPool();
  if (threadPool instanceof QueuedThreadPool) {
    ((QueuedThreadPool) threadPool).setMaxThreads(FeatureFlags.getMaxJettyThreads(serviceProperties));
    ((QueuedThreadPool) threadPool).setMinThreads(FeatureFlags.getMinJettyThreads(serviceProperties));
  } else {
    logger.warn("Expected ThreadPool to be instance of QueuedThreadPool, but was {}",
        jettyServer.getThreadPool().getClass().getName());
  }
  JettyComposer.compose(jettyServer);
  jettyServer.start();
  int port = ((ServerConnector) jettyServer.getConnectors()[0]).getLocalPort();
  logger.info("Jetty has started on port {}", port);
  serviceProperties.setServicePort(port);
}

代码示例来源：origin: org.eclipse.jetty.aggregate/jetty-all-server

@Override
public boolean dispatch(Runnable task)
{
  ThreadPool pool=getThreadPool();
  if (pool==null)
    pool=getServer().getThreadPool();
  return pool.dispatch(task);
}

代码示例来源：origin: org.eclipse.jetty.aggregate/jetty-server

@Override
public void setServer(Server server)
{
  super.setServer(server);
  server.getContainer().update(this, null, _selectorManager, "selectManager");
  if (_privateThreadPool)
    server.getContainer().update(this, null, _privateThreadPool, "threadpool", true);
  else
    _threadPool = server.getThreadPool();
}