Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 29 of 29 for synchronized (0.17 sec)

  1. src/main/java/org/codelibs/fess/rank/fusion/RankFusionProcessor.java

            }
            final RankFusionSearcher[] newSearchers = Arrays.copyOf(searchers, searchers.length + 1);
            newSearchers[newSearchers.length - 1] = searcher;
            searchers = newSearchers;
            synchronized (this) {
                if (executorService == null) {
                    int numThreads = ComponentUtil.getFessConfig().getRankFusionThreadsAsInteger();
                    if (numThreads <= 0) {
    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)
  2. src/main/java/org/codelibs/fess/ingest/IngestFactory.java

    import org.apache.logging.log4j.Logger;
    
    public class IngestFactory {
        private static final Logger logger = LogManager.getLogger(IngestFactory.class);
    
        private Ingester[] ingesters = {};
    
        public synchronized void add(final Ingester ingester) {
            if (logger.isDebugEnabled()) {
                logger.debug("Loaded {}", ingester.getClass().getSimpleName());
            }
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 1.4K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/helper/SystemHelper.java

            }
        }
    
        protected short getSystemCpuPercent() {
            final long now = getCurrentTimeAsLong();
            if (now - systemCpuCheckTime > systemCpuCheckInterval) {
                synchronized (this) {
                    if (now - systemCpuCheckTime > systemCpuCheckInterval) {
                        try {
                            final OsProbe osProbe = OsProbe.getInstance();
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Sat Apr 13 11:43:03 GMT 2024
    - 26.5K bytes
    - Viewed (2)
  4. src/main/java/org/codelibs/fess/helper/ProcessHelper.java

            return startProcess(sessionId, cmdList, pbCall, InputStreamThread.MAX_BUFFER_SIZE, null);
        }
    
        public synchronized JobProcess startProcess(final String sessionId, final List<String> cmdList, final Consumer<ProcessBuilder> pbCall,
                final int bufferSize, final Consumer<String> outputCallback) {
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 6.4K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/helper/IndexingHelper.java

                            doc.remove(thumbnailField);
                        }
                    });
                }
                final CrawlingConfigHelper crawlingConfigHelper = ComponentUtil.getCrawlingConfigHelper();
                synchronized (searchEngineClient) {
                    final long deletedDocCount = deleteOldDocuments(searchEngineClient, docList);
                    if (logger.isDebugEnabled()) {
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 15.6K bytes
    - Viewed (1)
  6. src/main/java/org/codelibs/fess/es/config/exentity/FileConfig.java

                if (pattern.matcher(input).matches()) {
                    return Constants.FALSE;
                }
            }
    
            return Constants.TRUE;
    
        }
    
        protected synchronized void initDocPathPattern() {
            final SystemHelper systemHelper = ComponentUtil.getSystemHelper();
    
            if (includedDocPathPatterns == null) {
                if (StringUtil.isNotBlank(getIncludedDocPaths())) {
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 9.8K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/helper/SuggestHelper.java

            refresh();
        }
    
        public void deleteBadWord(final String badWord) {
            suggester.indexer().deleteBadWord(badWord);
            refresh();
        }
    
        public synchronized void refresh() {
            suggester.refresh();
            if (popularWordHelper != null) {
                popularWordHelper.clearCache();
            }
        }
    
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 18K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/es/config/allcommon/EsAbstractEntity.java

        }
    
        protected void registerModifiedProperty(String propertyName) {
            __modifiedProperties.addPropertyName(propertyName);
            registerSpecifiedProperty(propertyName); // synchronize if exists, basically for user's manual call
        }
    
        public void modifiedToSpecified() {
            if (__modifiedProperties.isEmpty()) {
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 10.9K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/es/log/allcommon/EsAbstractEntity.java

        }
    
        protected void registerModifiedProperty(String propertyName) {
            __modifiedProperties.addPropertyName(propertyName);
            registerSpecifiedProperty(propertyName); // synchronize if exists, basically for user's manual call
        }
    
        public void modifiedToSpecified() {
            if (__modifiedProperties.isEmpty()) {
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 10.9K bytes
    - Viewed (0)
Back to top