Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for newFixedThreadPool (0.21 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
Back to top