org.eclipse.jetty.util.thread.ThreadPool.getThreads()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(2.8k)|赞(0)|评价(0)|浏览(140)

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

ThreadPool.getThreads介绍

暂无

代码示例

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

  1. @Override
  2. public int activeThreadCount() {
  3. if (server == null) {
  4. return 0;
  5. }
  6. return server.getThreadPool().getThreads() - server.getThreadPool().getIdleThreads();
  7. }

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

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

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

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

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

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

代码示例来源:origin: Comcast/cmb

  1. @Override
  2. public int getJettyCNSRequestHandlerPoolSize() {
  3. return CMB.cnsServer.getThreadPool().getThreads();
  4. }

代码示例来源:origin: Comcast/cmb

  1. @Override
  2. public int getJettyCQSRequestHandlerPoolSize() {
  3. return CMB.cqsServer.getThreadPool().getThreads();
  4. }

代码示例来源:origin: org.nanoframework/nano-jetty-server

  1. protected void startServer() {
  2. try {
  3. writePid2File();
  4. super.start();
  5. LOGGER.info("Current thread: {} | Idle thread: {}", super.getThreadPool().getThreads(), super.getThreadPool().getIdleThreads());
  6. super.join();
  7. } catch (final Throwable e) {
  8. // NANO-386: fixed Address already in use bug
  9. LOGGER.error("Bootstrap server error: {}", e.getMessage());
  10. System.exit(1);
  11. }
  12. }

代码示例来源:origin: com.sparkjava/spark-core

  1. @Override
  2. public int activeThreadCount() {
  3. if (server == null) {
  4. return 0;
  5. }
  6. return server.getThreadPool().getThreads() - server.getThreadPool().getIdleThreads();
  7. }

代码示例来源:origin: jenkinsci/winstone

  1. @Override
  2. public boolean isLowOnResources()
  3. {
  4. ThreadPool serverThreads = _server.getThreadPool();
  5. if(serverThreads.isLowOnThreads())
  6. {
  7. reason ="Server low on threads: "+serverThreads.getThreads()+", idleThreads:"+serverThreads.getIdleThreads();
  8. return true;
  9. }
  10. for(Connector connector : getMonitoredConnectors())
  11. {
  12. Executor executor = connector.getExecutor();
  13. if (executor instanceof ThreadPool && executor!=serverThreads)
  14. {
  15. ThreadPool connectorThreads=(ThreadPool)executor;
  16. if (connectorThreads.isLowOnThreads())
  17. {
  18. reason ="Connector low on threads: "+connectorThreads;
  19. return true;
  20. }
  21. }
  22. }
  23. return false;
  24. }

相关文章