- Sort Score
 - Result 10 results
 - Languages All
 
Results 381 - 390 of 711 for thread (0.05 sec)
- 
				
				
android/guava-testlib/test/com/google/common/collect/testing/OpenJdk6MapTests.java
* implementations, supports add() under JDK8. This seems problematic, but I * didn't see that discussed in the review, which included many other * changes: https://mail.openjdk.org/pipermail/core-libs-dev/2013-May/thread.html#17367 * * TODO(cpovirk): decide what the best long-term action here is: force users * to suppress (as we do now), stop testing entrySet().add() at all, make
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 3.9K bytes - Viewed (0) - 
				
				
guava-testlib/src/com/google/common/testing/FakeTicker.java
/** * A Ticker whose value can be advanced programmatically in test. * * <p>The ticker can be configured so that the time is incremented whenever {@link #read} is called: * see {@link #setAutoIncrementStep}. * * <p>This class is thread-safe. * * @author Jige Yu * @since 10.0 */ @NullMarked @GwtCompatible public class FakeTicker extends Ticker {Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Apr 14 15:16:19 UTC 2025 - 3.4K bytes - Viewed (0) - 
				
				
guava-testlib/src/com/google/common/collect/testing/MinimalIterable.java
* * <p>Note that although your APIs should be liberal in what they accept, your methods which * <i>return</i> iterables should make every attempt to return ones of the robust variety. * * <p>This testing utility is not thread-safe. * * @author Kevin Bourrillion */ @GwtCompatible public final class MinimalIterable<E extends @Nullable Object> implements Iterable<E> {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 3.1K bytes - Viewed (0) - 
				
				
okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt
override fun writeTo(sink: BufferedSink) { try { var i = 0 while (i < contentLength()) { sink.write(chunk!!) sink.flush() Thread.sleep(100) i += chunk.size } } catch (e: IOException) { ioe = e } catch (e: InterruptedException) { throw RuntimeException(e) } } }Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 60.4K bytes - Viewed (0) - 
				
				
CHANGELOG.md
* Fix: Attempt to read the response even if sending the request failed. This makes it possible to handle response statuses like `HTTP/1.1 431 "Request Header Fields Too Large`. * Fix: Handle multiple 1xx responses. * Fix: Address a performance bug in our internal task runner. We had a race condition that could result in it OkHttp starting a thread for each queued task, even when a single thread could runRegistered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Jul 07 19:32:33 UTC 2025 - 31.6K bytes - Viewed (2) - 
				
				
src/main/java/jcifs/internal/smb2/lease/DirectoryLeaseManager.java
if (!scheduler.awaitTermination(5, TimeUnit.SECONDS)) { scheduler.shutdownNow(); } } catch (InterruptedException e) { scheduler.shutdownNow(); Thread.currentThread().interrupt(); } // Stop all change watchers for (String path : directoryCache.keySet()) { changeNotifier.stopWatching(path); }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 01:47:47 UTC 2025 - 12.3K bytes - Viewed (0) - 
				
				
src/main/resources/fess_config.properties
crawler.system.monitor.interval=60 # Whether to ignore idle threads in hot thread monitoring. crawler.hotthread.ignore_idle_threads=true # Interval for hot thread monitoring (e.g., 500ms). crawler.hotthread.interval=500ms # Number of snapshots for hot thread monitoring. crawler.hotthread.snapshots=10 # Number of threads for hot thread monitoring. crawler.hotthread.threads=3 # Timeout for hot thread monitoring (e.g., 30s). crawler.hotthread.timeout=30s
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jul 05 14:45:37 UTC 2025 - 54.7K bytes - Viewed (0) - 
				
				
okhttp/src/commonJvmAndroid/kotlin/okhttp3/ResponseBody.kt
* * These examples will not work if you're consuming the response body on another thread. In such * cases the consuming thread must call [close] when it has finished reading the response * body. * * ### The response body can be consumed only once. * * This class may be used to stream very large responses. For example, it is possible to use this * class to read a response that is larger than the entire memory allocated to the current process.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue May 27 14:51:25 UTC 2025 - 11.6K bytes - Viewed (0) - 
				
				
README.md
- **Authentication**: NTLM, Kerberos, SPNEGO unified subsystem - **SLF4J Logging**: Comprehensive logging throughout the codebase - **Resource Management**: AutoCloseable patterns for file handles and connections - **Thread Safety**: Components support concurrent access - **DFS Support**: Distributed File System resolution - **Streaming Operations**: Efficient directory listings and file operations - **Buffer Caching**: Optimized buffer management
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 09:24:52 UTC 2025 - 6.2K bytes - Viewed (0) - 
				
				
fess-crawler/src/main/java/org/codelibs/fess/crawler/service/impl/DataServiceImpl.java
* <p> * The class uses a static {@code idCount} to generate unique IDs for each access result. * The {@code idCountLock} object is used to synchronize access to the {@code idCount} variable, * ensuring that IDs are generated in a thread-safe manner. * </p> * * <p> * The class also provides methods to get the count of access results for a given session, * to delete all access results for a given session, and to delete all access results. * </p>Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 6.8K bytes - Viewed (0)