- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for ThreadLocal (0.05 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)