- Sort Score
- Num 10 results
- Language All
Results 271 - 280 of 890 for thread (0.42 seconds)
-
src/main/java/org/codelibs/core/misc/DynamicProperties.java
* <li>{@link IORuntimeException} - Thrown if there are I/O errors during file operations.</li> * </ul> * * <p>Thread Safety: * This class uses synchronization to ensure thread-safe access to the properties. * * @see Properties */ public class DynamicProperties extends Properties { private static final long serialVersionUID = 1L; /**
Created: Fri Apr 03 20:58:12 GMT 2026 - Last Modified: Sat Jul 05 00:11:05 GMT 2025 - 13.1K bytes - Click Count (0) -
src/test/java/jcifs/util/SmbCircuitBreakerTest.java
// Trip circuit circuitBreaker.trip(); Thread.sleep(100); long afterTripTime = circuitBreaker.getTimeSinceLastStateChange(); assertTrue(afterTripTime >= 100, "Time should have advanced"); assertTrue(afterTripTime < 200, "Time should be reasonable"); // Reset circuit circuitBreaker.reset(); Thread.sleep(50);Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 23.2K bytes - Click Count (0) -
android/guava/src/com/google/common/base/FinalizableSoftReference.java
import java.lang.ref.ReferenceQueue; import java.lang.ref.SoftReference; import org.jspecify.annotations.Nullable; /** * Soft reference with a {@code finalizeReferent()} method which a background thread invokes after * the garbage collector reclaims the referent. This is a simpler alternative to using a {@link * ReferenceQueue}. * * @author Bob Lee * @since 2.0 */ @J2ktIncompatible @GwtIncompatibleCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 1.5K bytes - Click Count (0) -
guava/src/com/google/common/base/FinalizableSoftReference.java
import java.lang.ref.ReferenceQueue; import java.lang.ref.SoftReference; import org.jspecify.annotations.Nullable; /** * Soft reference with a {@code finalizeReferent()} method which a background thread invokes after * the garbage collector reclaims the referent. This is a simpler alternative to using a {@link * ReferenceQueue}. * * @author Bob Lee * @since 2.0 */ @J2ktIncompatible @GwtIncompatibleCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 1.5K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/multichannel/ChannelFailover.java
* * @param manager channel manager */ public ChannelFailover(ChannelManager manager) { this.manager = manager; this.executor = Executors.newCachedThreadPool(r -> { Thread t = new Thread(r, "MultiChannelFailover"); t.setDaemon(true); return t; }); this.failoverStates = new ConcurrentHashMap<>(); } /** * Handle channel failure *Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 21 11:13:46 GMT 2025 - 11.6K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/MapMaker.java
* accommodate as many threads as will ever concurrently modify the table. Using a significantly * higher value than you need can waste space and time, and a significantly lower value can lead * to thread contention. But overestimates and underestimates within an order of magnitude do not * usually have much noticeable impact. A value of one permits only one thread to modify the map
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 12.8K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
import okhttp3.internal.okHttpName /** * A set of tasks that are executed in sequential order. * * Work within queues is not concurrent. This is equivalent to each queue having a dedicated thread * for its work; in practice a set of queues may share a set of threads to save resources. */ class TaskQueue internal constructor( internal val taskRunner: TaskRunner, internal val name: String, ) { internal var shutdown = false
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed May 28 23:28:25 GMT 2025 - 7.3K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AbstractService.java
* requests, responding to them with {@link #notifyStarted()} and {@link #notifyStopped()} * callbacks. Its subclasses must manage threads manually; consider {@link * AbstractExecutionThreadService} if you need only a single execution thread. * * @author Jesse Wilson * @author Luke Sandberg * @since 1.0 */ @GwtIncompatible @J2ktIncompatibleCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Feb 19 21:24:11 GMT 2025 - 20.3K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/admin/crawlinginfo/AdminCrawlinginfoAction.java
throwValidationError(messages -> messages.addErrorsCrudCouldNotFindCrudTable(GLOBAL, id), this::asListHtml); return null; }); } /** * Print a thread dump. * @param form The edit form. * @return The HTML response. */ @Execute @Secured({ ROLE }) public HtmlResponse threaddump(final EditForm form) {
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Nov 20 13:56:35 GMT 2025 - 11K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/base/FinalizableReferenceQueueTest.java
public void finalizeReferent() { finalizeReferentCalled = true; } } /** * Keeps a weak reference to the underlying reference queue. When this reference is cleared, we * know that the background thread has stopped and released its strong reference. */ private WeakReference<ReferenceQueue<Object>> queueReference; @Test public void testThatFinalizerStops() { weaklyReferenceQueue();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Feb 27 21:20:19 GMT 2026 - 8.6K bytes - Click Count (0)