Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 19 for ThreadLocal (0.05 sec)

  1. fess-crawler/src/main/java/org/codelibs/fess/crawler/util/CrawlingParameterUtil.java

     * <p>Note: If a parameter is set to {@code null}, the corresponding ThreadLocal variable is removed.</p>
     */
    public final class CrawlingParameterUtil {
        private static final ThreadLocal<UrlQueue<?>> URL_QUEUE_THREAD_LOCAL = new ThreadLocal<>();
    
        private static final ThreadLocal<CrawlerContext> CRAWLER_CONTEXT_THREAD_LOCAL = new ThreadLocal<>();
    
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sat Nov 22 13:28:22 UTC 2025
    - 6.4K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/escape/Platform.java

        return requireNonNull(DEST_TL.get());
      }
    
      /**
       * A thread-local destination buffer to keep us from creating new buffers. The starting size is
       * 1024 characters. If we grow past this we don't put it back in the threadlocal, we just keep
       * going and grow as needed.
       */
      private static final ThreadLocal<char[]> DEST_TL =
          new ThreadLocal<char[]>() {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 1.5K bytes
    - Viewed (0)
  3. guava/src/com/google/common/eventbus/Dispatcher.java

        /** Per-thread queue of events to dispatch. */
        @SuppressWarnings("ThreadLocalUsage") // Each Dispatcher needs its own state.
        private final ThreadLocal<Queue<Event>> queue =
            new ThreadLocal<Queue<Event>>() {
              @Override
              protected Queue<Event> initialValue() {
                return new ArrayDeque<>();
              }
            };
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 7.4K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/crawler/serializer/DataSerializer.java

        /** Constant for Kryo serializer type. */
        protected static final String KRYO = "kryo";
    
        /** ThreadLocal container for Kryo instances to ensure thread safety. */
        protected final ThreadLocal<Kryo> kryoThreadLocal;
    
        /**
         * Constructs a new DataSerializer.
         * <p>
         * Initializes the ThreadLocal Kryo instances with appropriate configuration.
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Wed Nov 19 07:09:17 UTC 2025
    - 6.5K bytes
    - Viewed (3)
  5. guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

       *
       * <p>This class would certainly be simpler and easier to reason about if it were built with
       * ThreadLocal; however, ThreadLocal is not well optimized for the case where the ThreadLocal is
       * non-static, and is initialized/removed frequently - this causes churn in the Thread specific
       * hashmaps. Using a static ThreadLocal to avoid that overhead would mean that different
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 01:35:55 UTC 2025
    - 22.1K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/io/SourceSinkFactories.java

      }
    
      private abstract static class FileFactory {
    
        private static final Logger logger = Logger.getLogger(FileFactory.class.getName());
    
        private final ThreadLocal<File> fileThreadLocal = new ThreadLocal<>();
    
        File createFile() throws IOException {
          File file = File.createTempFile("SinkSourceFile", "txt");
          fileThreadLocal.set(file);
          return file;
        }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 17.9K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

       *
       * <p>This class would certainly be simpler and easier to reason about if it were built with
       * ThreadLocal; however, ThreadLocal is not well optimized for the case where the ThreadLocal is
       * non-static, and is initialized/removed frequently - this causes churn in the Thread specific
       * hashmaps. Using a static ThreadLocal to avoid that overhead would mean that different
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 01:35:55 UTC 2025
    - 22.1K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

            public void run() {}
          };
    
      public void testDirectExecutorServiceServiceInThreadExecution() throws Exception {
        ListeningExecutorService executor = newDirectExecutorService();
        ThreadLocal<Integer> threadLocalCount =
            new ThreadLocal<Integer>() {
              @Override
              protected Integer initialValue() {
                return 0;
              }
            };
        Runnable incrementTask =
            new Runnable() {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Dec 12 00:25:21 UTC 2025
    - 26.5K bytes
    - Viewed (0)
  9. fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerContext.java

         */
        protected Set<String> robotsTxtUrlSet = new LruHashSet<>(10000);
    
        /**
         * Thread-local storage for sitemaps.
         */
        protected ThreadLocal<String[]> sitemapsLocal = new ThreadLocal<>();
    
        /** The number of threads used by the crawler */
        protected int numOfThread = 10;
    
        /** The maximum number of times to check for active threads. */
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 8.9K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

            public void run() {}
          };
    
      public void testDirectExecutorServiceServiceInThreadExecution() throws Exception {
        ListeningExecutorService executor = newDirectExecutorService();
        ThreadLocal<Integer> threadLocalCount =
            new ThreadLocal<Integer>() {
              @Override
              protected Integer initialValue() {
                return 0;
              }
            };
        Runnable incrementTask =
            new Runnable() {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Dec 12 00:25:21 UTC 2025
    - 26.5K bytes
    - Viewed (0)
Back to top