Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for executorService (0.16 sec)

  1. src/main/java/org/codelibs/fess/exec/ThumbnailGenerator.java

            int count = 1;
            final ExecutorService executorService = Executors.newFixedThreadPool(options.numOfThreads);
            try {
                while (count != 0) {
                    count = ComponentUtil.getThumbnailManager().generate(executorService, options.cleanup);
                    totalCount += count;
                }
                executorService.shutdown();
                executorService.awaitTermination(60, TimeUnit.SECONDS);
    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/rank/fusion/RankFusionProcessor.java

                this.windowSize = windowSize;
            }
        }
    
        @Override
        @PreDestroy
        public void close() throws Exception {
            if (executorService != null) {
                try {
                    executorService.shutdown();
                    executorService.awaitTermination(60, TimeUnit.SECONDS);
                } catch (final InterruptedException e) {
                    if (logger.isDebugEnabled()) {
    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)
  3. src/main/java/org/codelibs/fess/ds/callback/FileListIndexUpdateCallbackImpl.java

    import java.util.ArrayList;
    import java.util.Deque;
    import java.util.HashSet;
    import java.util.LinkedList;
    import java.util.List;
    import java.util.Map;
    import java.util.Set;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.LinkedBlockingQueue;
    import java.util.concurrent.ThreadPoolExecutor;
    import java.util.concurrent.TimeUnit;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    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)
  4. src/main/java/org/codelibs/fess/thumbnail/ThumbnailManager.java

            }
            final ThumbnailQueueBhv thumbnailQueueBhv = ComponentUtil.getComponent(ThumbnailQueueBhv.class);
            thumbnailQueueBhv.batchInsert(list);
        }
    
        public int generate(final ExecutorService executorService, final boolean cleanup) {
            final FessConfig fessConfig = ComponentUtil.getFessConfig();
            final List<String> idList = new ArrayList<>();
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 21.5K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/sso/aad/AzureAdAuthenticator.java

    import java.util.Collections;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Locale;
    import java.util.Map;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.Future;
    import java.util.concurrent.TimeUnit;
    import java.util.stream.Collectors;
    
    import javax.annotation.PostConstruct;
    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)
Back to top