Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 22 for ThreadLocal (0.11 seconds)

  1. 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[]>() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 1.5K bytes
    - Click Count (0)
  2. 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.
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Jan 10 01:54:09 GMT 2026
    - 10.5K bytes
    - Click Count (3)
  3. android/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<>();
              }
            };
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 7.4K bytes
    - Click Count (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

      public void testDirectExecutorServiceServiceInThreadExecution() throws Exception {
        ListeningExecutorService executor = newDirectExecutorService();
        ThreadLocal<Integer> threadLocalCount =
            new ThreadLocal<Integer>() {
              @Override
              protected Integer initialValue() {
                return 0;
              }
            };
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 26.1K bytes
    - Click Count (0)
  5. src/test/java/org/codelibs/fess/crawler/serializer/DataSerializerTest.java

        }
    
        /**
         * Test that ThreadLocal Kryo instances work correctly
         * This verifies that the ThreadLocal implementation doesn't cause issues
         */
        @Test
        public void test_threadLocalKryo() {
            // Perform multiple serializations to ensure ThreadLocal works
            for (int i = 0; i < 10; i++) {
                String original = "Test " + i;
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Wed Jan 14 14:29:07 GMT 2026
    - 21.6K bytes
    - Click Count (0)
  6. impl/maven-core/src/main/java/org/apache/maven/execution/MavenSession.java

        private final MavenExecutionResult result;
    
        private final RepositorySystemSession repositorySystemSession;
    
        private final Properties executionProperties;
    
        private ThreadLocal<MavenProject> currentProject = new ThreadLocal<>();
    
        /**
         * These projects have already been topologically sorted in the {@link org.apache.maven.Maven} component before
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Jan 24 17:29:44 GMT 2025
    - 16.7K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/cache/Striped64.java

          }
        }
      }
    
      /**
       * ThreadLocal holding a single-slot int array holding hash code. Unlike the JDK8 version of this
       * class, we use a suboptimal int[] representation to avoid introducing a new type that can impede
       * class-unloading when ThreadLocals are not removed.
       */
      static final ThreadLocal<int @Nullable []> threadHashCode = new ThreadLocal<>();
    
      /** Generator of new random hash codes */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 15 22:17:15 GMT 2025
    - 11.4K bytes
    - Click Count (0)
  8. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

      public void testDirectExecutorServiceServiceInThreadExecution() throws Exception {
        ListeningExecutorService executor = newDirectExecutorService();
        ThreadLocal<Integer> threadLocalCount =
            new ThreadLocal<Integer>() {
              @Override
              protected Integer initialValue() {
                return 0;
              }
            };
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 26.1K bytes
    - Click Count (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. */
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Wed Dec 31 09:07:38 GMT 2025
    - 9K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/hash/Striped64.java

          }
        }
      }
    
      /**
       * ThreadLocal holding a single-slot int array holding hash code. Unlike the JDK8 version of this
       * class, we use a suboptimal int[] representation to avoid introducing a new type that can impede
       * class-unloading when ThreadLocals are not removed.
       */
      static final ThreadLocal<int @Nullable []> threadHashCode = new ThreadLocal<>();
    
      /** Generator of new random hash codes */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 15 22:17:15 GMT 2025
    - 11.4K bytes
    - Click Count (0)
Back to Top