java.util.concurrent.ThreadPoolExecutor.getMaximumPoolSize()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(7.8k)|赞(0)|评价(0)|浏览(133)

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

ThreadPoolExecutor.getMaximumPoolSize介绍

[英]Returns the maximum allowed number of threads.
[中]返回允许的最大线程数。

代码示例

代码示例来源：origin: PipelineAI/pipeline

/**
 * Value from {@link ThreadPoolExecutor#getMaximumPoolSize()}
 * 
 * @return Number
 */
public Number getCurrentMaximumPoolSize() {
  return threadPool.getMaximumPoolSize();
}

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

@Override
public int getMaxPoolSize() {
 return pool.getMaximumPoolSize();
}

代码示例来源：origin: igniterealtime/Openfire

/**
 * Returns the max number of threads the channel will use for processing messages. The
 * channel will automatically allocate new worker threads as the queue load grows, up to the
 * defined maximum. This lets the channel meet higher concurrency needs, but prevents too
 * many threads from being allocated, which decreases overall system performance.
 *
 * @return the max number of threads that can be used by the channel.
 */
public int getMaxThreadCount() {
  return executor.getMaximumPoolSize();
}

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

/** {@inheritDoc} */
@Override public int getMaximumPoolSize() {
  return exec instanceof ThreadPoolExecutor ? ((ThreadPoolExecutor)exec).getMaximumPoolSize() : -1;
}

代码示例来源：origin: ltsopensource/light-task-scheduler

/**
 * 得到当前可用的线程数
 */
public int getAvailablePoolSize() {
  return threadPoolExecutor.getMaximumPoolSize() - threadPoolExecutor.getActiveCount();
}

代码示例来源：origin: ltsopensource/light-task-scheduler

/**
 * 得到当前可用的线程数
 */
public int getAvailablePoolSize() {
  return threadPoolExecutor.getMaximumPoolSize() - threadPoolExecutor.getActiveCount();
}

代码示例来源：origin: mpusher/mpush

public static Map<String, Object> getPoolInfo(ThreadPoolExecutor executor) {
  Map<String, Object> info = new HashMap<>(5);
  info.put("corePoolSize", executor.getCorePoolSize());
  info.put("maxPoolSize", executor.getMaximumPoolSize());
  info.put("activeCount(workingThread)", executor.getActiveCount());
  info.put("poolSize(workThread)", executor.getPoolSize());
  info.put("queueSize(blockedTask)", executor.getQueue().size());
  return info;
}

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

boolean ok = tp.getActiveCount() < tp.getMaximumPoolSize() - 1;
Status.Level lvl = Status.Level.OK;
if (!ok) {
    + ", max:" + tp.getMaximumPoolSize()
    + ", core:" + tp.getCorePoolSize()
    + ", largest:" + tp.getLargestPoolSize()

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

boolean ok = tp.getActiveCount() < tp.getMaximumPoolSize() - 1;
Status.Level lvl = Status.Level.OK;
if (!ok) {
    + ", max:" + tp.getMaximumPoolSize()
    + ", core:" + tp.getCorePoolSize()
    + ", largest:" + tp.getLargestPoolSize()

代码示例来源：origin: alipay/sofa-rpc

@Override
  public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
    if (LOGGER.isWarnEnabled()) {
      LOGGER.warn(LogCodes.getLog(LogCodes.ERROR_PROVIDER_TR_POOL_REJECTION, executor.getActiveCount(),
        executor.getPoolSize(), executor.getLargestPoolSize(), executor
          .getCorePoolSize(), executor.getMaximumPoolSize(), executor.getQueue()
          .size(), executor.getQueue().remainingCapacity()));
    }
    throw new RejectedExecutionException();
  }
}

代码示例来源：origin: alipay/sofa-rpc

@Override
  public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
    if (LOGGER.isWarnEnabled()) {
      LOGGER.warn(LogCodes.getLog(LogCodes.ERROR_PROVIDER_TR_POOL_REJECTION, executor.getActiveCount(),
        executor.getPoolSize(), executor.getLargestPoolSize(), executor
          .getCorePoolSize(), executor.getMaximumPoolSize(), executor.getQueue()
          .size(), executor.getQueue().remainingCapacity()));
    }
    throw new RejectedExecutionException();
  }
}

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

@Override
public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
  String msg = String.format("Thread pool is EXHAUSTED!" +
          " Thread Name: %s, Pool Size: %d (active: %d, core: %d, max: %d, largest: %d), Task: %d (completed: %d)," +
          " Executor status:(isShutdown:%s, isTerminated:%s, isTerminating:%s), in %s://%s:%d!",
      threadName, e.getPoolSize(), e.getActiveCount(), e.getCorePoolSize(), e.getMaximumPoolSize(), e.getLargestPoolSize(),
      e.getTaskCount(), e.getCompletedTaskCount(), e.isShutdown(), e.isTerminated(), e.isTerminating(),
      url.getProtocol(), url.getIp(), url.getPort());
  logger.warn(msg);
  dumpJStack();
  throw new RejectedExecutionException(msg);
}

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

@Override
public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
  String msg = String.format("Thread pool is EXHAUSTED!" +
          " Thread Name: %s, Pool Size: %d (active: %d, core: %d, max: %d, largest: %d), Task: %d (completed: %d)," +
          " Executor status:(isShutdown:%s, isTerminated:%s, isTerminating:%s), in %s://%s:%d!",
      threadName, e.getPoolSize(), e.getActiveCount(), e.getCorePoolSize(), e.getMaximumPoolSize(), e.getLargestPoolSize(),
      e.getTaskCount(), e.getCompletedTaskCount(), e.isShutdown(), e.isTerminated(), e.isTerminating(),
      url.getProtocol(), url.getIp(), url.getPort());
  logger.warn(msg);
  dumpJStack();
  throw new RejectedExecutionException(msg);
}

代码示例来源：origin: vipshop/vjtools

@Override
public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
  String msg = String.format(
      "Thread pool is EXHAUSTED!"
          + " Thread Name: %s, Pool Size: %d (active: %d, core: %d, max: %d, largest: %d), Task: %d (completed: %d),"
          + " Executor status:(isShutdown:%s, isTerminated:%s, isTerminating:%s)!",
      threadName, e.getPoolSize(), e.getActiveCount(), e.getCorePoolSize(), e.getMaximumPoolSize(),
      e.getLargestPoolSize(), e.getTaskCount(), e.getCompletedTaskCount(), e.isShutdown(), e.isTerminated(),
      e.isTerminating());
  logger.warn(msg);
  dummper.tryThreadDump(null);
  throw new RejectedExecutionException(msg);
}

代码示例来源：origin: jankotek/mapdb

/**
 * Returns maximum number of tasks that can be submitted to given
 * pool (with bounded queue) before saturation (when submission
 * throws RejectedExecutionException).
 */
static final int saturatedSize(ThreadPoolExecutor pool) {
  BlockingQueue<Runnable> q = pool.getQueue();
  return pool.getMaximumPoolSize() + q.size() + q.remainingCapacity();
}

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

@Override
 protected Ratio getRatio() {
  ThreadPoolExecutor metaPool = (ThreadPoolExecutor) conn.getCurrentMetaLookupPool();
  if (metaPool == null) {
   return Ratio.of(0, 0);
  }
  return Ratio.of(metaPool.getActiveCount(), metaPool.getMaximumPoolSize());
 }
});

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

@Override
 protected Ratio getRatio() {
  ThreadPoolExecutor batchPool = (ThreadPoolExecutor) conn.getCurrentBatchPool();
  if (batchPool == null) {
   return Ratio.of(0, 0);
  }
  return Ratio.of(batchPool.getActiveCount(), batchPool.getMaximumPoolSize());
 }
});

代码示例来源：origin: weibocom/motan

private void rejectMessage(ChannelHandlerContext ctx, NettyMessage msg) {
  if (msg.isRequest()) {
    DefaultResponse response = new DefaultResponse();
    response.setRequestId(msg.getRequestId());
    response.setException(new MotanServiceException("process thread pool is full, reject by server: " + ctx.channel().localAddress(), MotanErrorMsgConstant.SERVICE_REJECT));
    sendResponse(ctx, response);
    LoggerUtil.error("process thread pool is full, reject, active={} poolSize={} corePoolSize={} maxPoolSize={} taskCount={} requestId={}",
        threadPoolExecutor.getActiveCount(), threadPoolExecutor.getPoolSize(), threadPoolExecutor.getCorePoolSize(),
        threadPoolExecutor.getMaximumPoolSize(), threadPoolExecutor.getTaskCount(), msg.getRequestId());
    rejectCounter.incrementAndGet();
  }
}

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

ThreadPoolExecutor threadPoolExecutor = (ThreadPoolExecutor) executor;
int threads = url.getParameter(Constants.THREADS_KEY, 0);
int max = threadPoolExecutor.getMaximumPoolSize();
int core = threadPoolExecutor.getCorePoolSize();
if (threads > 0 && (threads != max || threads != core)) {

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

ThreadPoolExecutor threadPoolExecutor = (ThreadPoolExecutor) executor;
int threads = url.getParameter(Constants.THREADS_KEY, 0);
int max = threadPoolExecutor.getMaximumPoolSize();
int core = threadPoolExecutor.getCorePoolSize();
if (threads > 0 && (threads != max || threads != core)) {

内容来源于网络，如有侵权，请联系作者删除！

threadpoolexecutor

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    ThreadPoolExecutor类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com