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

ThreadPool.searchThreadPoolSize介绍

暂无

代码示例

代码示例来源：origin: org.elasticsearch/elasticsearch

static int defaultMaxConcurrentSearches(int availableProcessors, ClusterState state) {
  int numDateNodes = state.getNodes().getDataNodes().size();
  // availableProcessors will never be larger than 32, so max defaultMaxConcurrentSearches will never be larger than 49,
  // but we don't know about about other search requests that are being executed so lets cap at 10 per node
  int defaultSearchThreadPoolSize = Math.min(ThreadPool.searchThreadPoolSize(availableProcessors), 10);
  return Math.max(1, numDateNodes * defaultSearchThreadPoolSize);
}

代码示例来源：origin: org.elasticsearch/elasticsearch

builders.put(Names.ANALYZE, new FixedExecutorBuilder(settings, Names.ANALYZE, 1, 16));
builders.put(Names.SEARCH, new AutoQueueAdjustingExecutorBuilder(settings,
        Names.SEARCH, searchThreadPoolSize(availableProcessors), 1000, 1000, 1000, 2000));
builders.put(Names.SEARCH_THROTTLED, new AutoQueueAdjustingExecutorBuilder(settings,
  Names.SEARCH_THROTTLED, 1, 100, 100, 100, 200));

代码示例来源：origin: apache/servicemix-bundles

static int defaultMaxConcurrentSearches(int availableProcessors, ClusterState state) {
  int numDateNodes = state.getNodes().getDataNodes().size();
  // availableProcessors will never be larger than 32, so max defaultMaxConcurrentSearches will never be larger than 49,
  // but we don't know about about other search requests that are being executed so lets cap at 10 per node
  int defaultSearchThreadPoolSize = Math.min(ThreadPool.searchThreadPoolSize(availableProcessors), 10);
  return Math.max(1, numDateNodes * defaultSearchThreadPoolSize);
}

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

static int defaultMaxConcurrentSearches(int availableProcessors, ClusterState state) {
  int numDateNodes = state.getNodes().getDataNodes().size();
  // availableProcessors will never be larger than 32, so max defaultMaxConcurrentSearches will never be larger than 49,
  // but we don't know about about other search requests that are being executed so lets cap at 10 per node
  int defaultSearchThreadPoolSize = Math.min(ThreadPool.searchThreadPoolSize(availableProcessors), 10);
  return Math.max(1, numDateNodes * defaultSearchThreadPoolSize);
}

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

static int defaultMaxConcurrentSearches(int availableProcessors, ClusterState state) {
  int numDateNodes = state.getNodes().getDataNodes().size();
  // availableProcessors will never be larger than 32, so max defaultMaxConcurrentSearches will never be larger than 49,
  // but we don't know about about other search requests that are being executed so lets cap at 10 per node
  int defaultSearchThreadPoolSize = Math.min(ThreadPool.searchThreadPoolSize(availableProcessors), 10);
  return Math.max(1, numDateNodes * defaultSearchThreadPoolSize);
}

代码示例来源：origin: apache/servicemix-bundles

builders.put(Names.ANALYZE, new FixedExecutorBuilder(settings, Names.ANALYZE, 1, 16));
builders.put(Names.SEARCH, new AutoQueueAdjustingExecutorBuilder(settings,
        Names.SEARCH, searchThreadPoolSize(availableProcessors), 1000, 1000, 1000, 2000));
builders.put(Names.MANAGEMENT, new ScalingExecutorBuilder(Names.MANAGEMENT, 1, 5, TimeValue.timeValueMinutes(5)));

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

builders.put(Names.ANALYZE, new FixedExecutorBuilder(settings, Names.ANALYZE, 1, 16));
builders.put(Names.SEARCH, new AutoQueueAdjustingExecutorBuilder(settings,
        Names.SEARCH, searchThreadPoolSize(availableProcessors), 1000, 1000, 1000, 2000));
builders.put(Names.SEARCH_THROTTLED, new AutoQueueAdjustingExecutorBuilder(settings,
  Names.SEARCH_THROTTLED, 1, 100, 100, 100, 200));

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

builders.put(Names.BULK, new FixedExecutorBuilder(settings, Names.BULK, availableProcessors, 200)); // now that we reuse bulk for index/delete ops
builders.put(Names.GET, new FixedExecutorBuilder(settings, Names.GET, availableProcessors, 1000));
builders.put(Names.SEARCH, new FixedExecutorBuilder(settings, Names.SEARCH, searchThreadPoolSize(availableProcessors), 1000));
builders.put(Names.MANAGEMENT, new ScalingExecutorBuilder(Names.MANAGEMENT, 1, 5, TimeValue.timeValueMinutes(5)));