- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for availableProcessors (0.32 sec)
-
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/util/OpenSearchCrawlerConfig.java
protected String filterIndex = ".crawler.filter"; protected int queueShards = Runtime.getRuntime().availableProcessors() * 2; protected int dataShards = Runtime.getRuntime().availableProcessors() * 2; protected int filterShards = Runtime.getRuntime().availableProcessors() * 2; protected int queueReplicas = 1; protected int dataReplicas = 1; protected int filterReplicas = 1;
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 2.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/SuggesterBuilder.java
protected Normalizer normalizer; protected SuggestAnalyzer analyzer; protected ExecutorService threadPool; protected int threadPoolSize = Runtime.getRuntime().availableProcessors(); public SuggesterBuilder settings(final SuggestSettings settings) { this.settings = settings; settingsBuilder = null; return this; }
Registered: Fri Nov 08 09:08:12 UTC 2024 - Last Modified: Sat Oct 12 00:10:39 UTC 2024 - 4.2K bytes - Viewed (0) -
build.gradle.kts
javaLauncher.set(javaToolchains.launcherFor { languageVersion.set(JavaLanguageVersion.of(testJavaVersion)) }) maxParallelForks = Runtime.getRuntime().availableProcessors() * 2 testLogging { exceptionFormat = TestExceptionFormat.FULL } systemProperty("okhttp.platform", platform) systemProperty("junit.jupiter.extensions.autodetection.enabled", "true")
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Jun 23 17:02:02 UTC 2024 - 9K bytes - Viewed (0) -
src/main/java/org/codelibs/core/timer/TimeoutManager.java
*/ public synchronized int getTimeoutTaskCount() { return timeoutTaskList.size(); } @Override public void run() { int nThreads = Runtime.getRuntime().availableProcessors() / 2; final String value = System.getProperty("corelib.timeout_task.num_of_threads"); if (StringUtil.isNotBlank(value)) { try { nThreads = Integer.parseInt(value);
Registered: Fri Nov 01 20:58:10 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 8K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/Striped64.java
/** Generator of new random hash codes */ static final Random rng = new Random(); /** Number of CPUS, to place bound on table size */ static final int NCPU = Runtime.getRuntime().availableProcessors(); /** Table of cells. When non-null, size is a power of 2. */ @CheckForNull transient volatile Cell[] cells; /**
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Jun 14 17:55:55 UTC 2024 - 11.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/mylasta/direction/FessProp.java
} return value; } Integer getProcessorsAsInteger(); default int availableProcessors() { final int num = getProcessorsAsInteger(); if (num > 0) { return num; } return Runtime.getRuntime().availableProcessors(); } Integer getCrawlerHttpThreadPoolSizeAsInteger(); default int getCrawlerHttpProcessors() {
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Sat Oct 12 01:54:15 UTC 2024 - 87.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/rank/fusion/RankFusionProcessor.java
int numThreads = ComponentUtil.getFessConfig().getRankFusionThreadsAsInteger(); if (numThreads <= 0) { numThreads = Runtime.getRuntime().availableProcessors() * 3 / 2 + 1; } executorService = Executors.newFixedThreadPool(numThreads); } } }
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Fri Oct 11 21:20:39 UTC 2024 - 18.3K bytes - Viewed (0) -
guava/src/com/google/common/hash/Striped64.java
/** Generator of new random hash codes */ static final Random rng = new Random(); /** Number of CPUS, to place bound on table size */ static final int NCPU = Runtime.getRuntime().availableProcessors(); /** Table of cells. When non-null, size is a power of 2. */ @CheckForNull transient volatile Cell[] cells; /**
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Jun 14 17:55:55 UTC 2024 - 11.5K bytes - Viewed (0) -
compat/maven-embedder/src/test/java/org/apache/maven/cli/MavenCliTest.java
assertThrows(IllegalArgumentException.class, () -> cli.calculateDegreeOfConcurrency("XXXC")); int cpus = Runtime.getRuntime().availableProcessors(); assertEquals((int) (cpus * 2.2), cli.calculateDegreeOfConcurrency("2.2C")); assertEquals(1, cli.calculateDegreeOfConcurrency("0.0001C"));
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 30.3K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Striped.java
* and memory footprint. For example, if a set of tasks are CPU-bound, one could easily create a * very compact {@code Striped<Lock>} of {@code availableProcessors() * 4} stripes, instead of * possibly thousands of locks which could be created in a {@code Map<K, Lock>} structure. * * @author Dimitris Andreou * @since 13.0 */ @J2ktIncompatible @GwtIncompatible
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Jun 26 12:58:35 UTC 2024 - 20.6K bytes - Viewed (0)