Search Options

Results per page
Sort
Preferred Languages
Advance

Results 201 - 210 of 227 for nThreads (0.04 sec)

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

                        numThreads = Runtime.getRuntime().availableProcessors() * 3 / 2 + 1;
                    }
                    if (logger.isDebugEnabled()) {
                        logger.debug("Initializing executor service with {} threads", numThreads);
                    }
                    executorService = Executors.newFixedThreadPool(numThreads);
                }
            }
        }
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 27.5K bytes
    - Viewed (0)
  2. docs/tr/docs/async.md

    ## Çok Teknik Detaylar
    
    /// warning
    
    Muhtemelen burayı atlayabilirsiniz.
    
    Bunlar, **FastAPI**'nin altta nasıl çalıştığına dair çok teknik ayrıntılardır.
    
    Biraz teknik bilginiz varsa (co-routines, threads, blocking, vb)ve FastAPI'nin "async def" ile normal "def" arasındaki farkı nasıl işlediğini merak ediyorsanız, devam edin.
    
    ///
    
    ### Path fonksiyonu
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sun Aug 31 09:56:21 UTC 2025
    - 21.8K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/thumbnail/ThumbnailManager.java

            }, "ThumbnailGenerator");
            thumbnailQueueThread.start();
        }
    
        /**
         * Cleans up resources when the thumbnail manager is destroyed.
         * Stops background processing and waits for threads to complete.
         */
        @PreDestroy
        public void destroy() {
            generating = false;
            thumbnailQueueThread.interrupt();
            try {
                thumbnailQueueThread.join(10000);
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 27K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/mylasta/direction/FessConfig.java

         * Get the value for the key 'crawler.hotthread.threads'. <br>
         * The value is, e.g. 3 <br>
         * comment: Number of threads for hot thread monitoring.
         * @return The value of found property. (NotNull: if not found, exception but basically no way)
         */
        String getCrawlerHotthreadThreads();
    
        /**
         * Get the value for the key 'crawler.hotthread.threads' as {@link Integer}. <br>
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Sat Dec 13 02:21:17 UTC 2025
    - 525.7K bytes
    - Viewed (2)
  5. guava/src/com/google/common/util/concurrent/Striped.java

      public abstract int size();
    
      /**
       * Returns the stripes that correspond to the passed objects, in ascending (as per {@link
       * #getAt(int)}) order. Thus, threads that use the stripes in the order returned by this method
       * are guaranteed to not deadlock each other.
       *
       * <p>It should be noted that using a {@code Striped<L>} with relatively few stripes, and {@code
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 16 22:01:32 UTC 2025
    - 20.6K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/core/collection/CollectionsUtil.java

         * @param initialCapacity the initial capacity
         * @param loadFactor the load factor threshold for resizing
         * @param concurrencyLevel the estimated number of threads for concurrent updates
         * @return a new instance of {@link ConcurrentHashMap}
         * @see ConcurrentHashMap#ConcurrentHashMap(int, float, int)
         */
    Registered: Sat Dec 20 08:55:33 UTC 2025
    - Last Modified: Thu Jul 31 08:16:49 UTC 2025
    - 49.9K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

            if (to == FAILED) {
              enqueueFailedEvent(service);
            }
    
            if (states.count(RUNNING) == numberOfServices) {
              // This means that the manager is currently healthy. N.B. If other threads call isHealthy
              // they are not guaranteed to get 'true', because any service could fail right now.
              enqueueHealthyEvent();
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 17:49:12 UTC 2025
    - 33.2K bytes
    - Viewed (1)
  8. guava/src/com/google/common/util/concurrent/ServiceManager.java

            if (to == FAILED) {
              enqueueFailedEvent(service);
            }
    
            if (states.count(RUNNING) == numberOfServices) {
              // This means that the manager is currently healthy. N.B. If other threads call isHealthy
              // they are not guaranteed to get 'true', because any service could fail right now.
              enqueueHealthyEvent();
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 17:49:12 UTC 2025
    - 32.9K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

        // A handle to the running task so that we can stop it when a shutdown has been requested.
        // These two fields are volatile because their values will be accessed from multiple threads.
        private volatile @Nullable Cancellable runningTask;
        private volatile @Nullable ScheduledExecutorService executorService;
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.8K bytes
    - Viewed (0)
  10. docs/smb3-features/03-multi-channel-design.md

                    alternativeChannel.getTransport().send(op);
                } catch (Exception e) {
                    log.error("Failed to redistribute operation", e);
                    // Notify waiting threads of failure
                    op.notifyError(e);
                }
            }
        }
        
        private void scheduleRecovery(ChannelInfo channel, FailoverState state) {
            state.incrementRetry();
            
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 39.6K bytes
    - Viewed (0)
Back to top