Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 22 for ThreadLocal (0.1 sec)

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

    public final class CrawlingParameterUtil {
        private static final ThreadLocal<UrlQueue<?>> URL_QUEUE_THREAD_LOCAL = new ThreadLocal<>();
    
        private static final ThreadLocal<CrawlerContext> ROBOT_CONTEXT_THREAD_LOCAL = new ThreadLocal<>();
    
        private static final ThreadLocal<UrlQueueService<UrlQueue<?>>> URL_QUEUE_SERVICE_THREAD_LOCAL = new ThreadLocal<>();
    
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 2.9K 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Dec 15 19:31:54 UTC 2023
    - 1.6K bytes
    - Viewed (0)
  3. 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
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  4. guava/src/com/google/common/eventbus/Dispatcher.java

        private final ThreadLocal<Queue<Event>> queue =
            new ThreadLocal<Queue<Event>>() {
              @Override
              protected Queue<Event> initialValue() {
                return Queues.newArrayDeque();
              }
            };
    
        /** Per-thread dispatch state, used to avoid reentrant event dispatching. */
        private final ThreadLocal<Boolean> dispatching =
            new ThreadLocal<Boolean>() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Dec 15 19:31:54 UTC 2023
    - 7.3K bytes
    - Viewed (0)
  5. fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerContext.java

        protected RuleManager ruleManager;
    
        protected IntervalController intervalController;
    
        protected Set<String> robotsTxtUrlSet = new LruHashSet<>(10000);
    
        protected ThreadLocal<String[]> sitemapsLocal = new ThreadLocal<>();
    
        /** The number of a thread */
        protected int numOfThread = 10;
    
        protected int maxThreadCheckCount = 20;
    
        /** a max depth for crawling. -1 is no depth check. */
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Sat Oct 12 01:40:57 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  6. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 22.1K bytes
    - Viewed (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 */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 14 17:55:55 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

          };
    
      public void testDirectExecutorServiceServiceInThreadExecution() throws Exception {
        final ListeningExecutorService executor = newDirectExecutorService();
        final ThreadLocal<Integer> threadLocalCount =
            new ThreadLocal<Integer>() {
              @Override
              protected Integer initialValue() {
                return 0;
              }
            };
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

          };
    
      public void testDirectExecutorServiceServiceInThreadExecution() throws Exception {
        final ListeningExecutorService executor = newDirectExecutorService();
        final ThreadLocal<Integer> threadLocalCount =
            new ThreadLocal<Integer>() {
              @Override
              protected Integer initialValue() {
                return 0;
              }
            };
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  10. src/test/java/org/codelibs/fess/helper/CrawlerStatsHelperTest.java

        private static final Logger logger = LogManager.getLogger(CrawlerStatsHelperTest.class);
    
        private CrawlerStatsHelper crawlerStatsHelper;
    
        private ThreadLocal<String> localLogMsg = new ThreadLocal<>();
    
        @Override
        public void setUp() throws Exception {
            super.setUp();
            ComponentUtil.register(new SystemHelper(), "systemHelper");
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 6K bytes
    - Viewed (0)
Back to top