- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for newFixedThreadPool (0.21 sec)
-
src/main/java/org/codelibs/fess/exec/ThumbnailGenerator.java
logger.warn("Failed to create system properties file.", e); } } int totalCount = 0; int count = 1; final ExecutorService executorService = Executors.newFixedThreadPool(options.numOfThreads); try { while (count != 0) { count = ComponentUtil.getThumbnailManager().generate(executorService, options.cleanup); totalCount += count;
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 8.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/ds/callback/FileListIndexUpdateCallbackImpl.java
executor = newFixedThreadPool(nThreads < 1 ? 1 : nThreads); final FessConfig fessConfig = ComponentUtil.getFessConfig(); maxDeleteDocumentCacheSize = fessConfig.getIndexerDataMaxDeleteCacheSizeAsInteger(); maxRedirectCount = fessConfig.getIndexerDataMaxRedirectCountAsInteger(); } protected ExecutorService newFixedThreadPool(final int nThreads) {
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 16.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/sso/aad/AzureAdAuthenticator.java
logger.debug("refreshToken: {}, authority: {}", refreshToken, authority); } ExecutorService service = null; try { service = Executors.newFixedThreadPool(1); final AuthenticationContext context = new AuthenticationContext(authority, true, service); final Future<AuthenticationResult> future =
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 28.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/rank/fusion/RankFusionProcessor.java
if (numThreads <= 0) { numThreads = (Runtime.getRuntime().availableProcessors() * 3) / 2 + 1; } executorService = Executors.newFixedThreadPool(numThreads); } } }
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 16.5K bytes - Viewed (0)