- Sort Score
- Num 10 results
- Language All
Results 241 - 250 of 713 for reread (0.04 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
android/guava/src/com/google/common/cache/AbstractCache.java
*/ void recordHits(int count); /** * Records cache misses. This should be called when a cache request returns a value that was not * found in the cache. This method should be called by the loading thread, as well as by threads * blocking on the load. Multiple concurrent calls to {@link Cache} lookup methods with the same * key on an absent value should result in a single call to either {@code recordLoadSuccess} orCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue May 13 17:27:14 GMT 2025 - 9.1K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/admin/general/MailForm.java
} /** The incremental crawling setting. */ public String incrementalCrawling; /** The day for cleanup setting. */ public String dayForCleanup; /** The crawling thread count setting. */ public String crawlingThreadCount; /** The search log setting. */ public String searchLog; /** The user info setting. */ public String userInfo;Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Thu Jul 17 08:28:31 GMT 2025 - 2.6K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/plugin/LegacySupport.java
/** * Sets the currently active session. Some legacy components are basically stateful and their API is missing * parameters that would be required to delegate to a stateless component. Saving the session (in a thread-local * variable) is our best effort to record any state that is required to enable proper delegation. * * @param session The currently active session, may be {@code null}. */Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Oct 25 12:31:46 GMT 2024 - 2.1K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java
assertEquals(1, listenerLatch.getCount()); assertFalse(task.isDone()); assertFalse(task.isCancelled()); // Start the task to put it in the RUNNING state. Have to use a separate // thread because the task will block on the task latch after unblocking // the run latch. exec.execute(task); runLatch.await(); assertEquals(1, listenerLatch.getCount()); assertFalse(task.isDone());
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 11 21:00:51 GMT 2025 - 4.8K bytes - Click Count (0) -
src/main/java/jcifs/smb/SmbTransportPoolImpl.java
private long lastHealthCheck = System.currentTimeMillis(); // Advanced health monitoring private final ScheduledExecutorService healthCheckExecutor = Executors.newSingleThreadScheduledExecutor(r -> { Thread t = new Thread(r, "SmbTransportPool-HealthCheck"); t.setDaemon(true); return t; }); private ScheduledFuture<?> healthCheckTask; private volatile boolean healthCheckingEnabled = true;
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 33.4K bytes - Click Count (0) -
cmd/tier-handlers.go
writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, errTierReservedName), r.URL) return } // Refresh from the disk in case we had missed notifications about edits from peers. if err := globalTierConfigMgr.Reload(ctx, objAPI); err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } err = globalTierConfigMgr.Add(ctx, cfg, ignoreInUse) if err != nil {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Sep 12 20:44:05 GMT 2024 - 7.5K bytes - Click Count (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/gcs/GcsClientTest.java
org.codelibs.core.timer.TimeoutTask accessTimeoutTask = null; if (accessTimeout != null) { accessTimeoutTarget = new org.codelibs.fess.crawler.client.AccessTimeoutTarget(Thread.currentThread()); accessTimeoutTask = org.codelibs.core.timer.TimeoutManager.getInstance() .addTimeoutTarget(accessTimeoutTarget, accessTimeout, false); }Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Thu Dec 11 08:38:29 GMT 2025 - 19.6K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/internal/impl/DefaultProject.java
this.session = session; this.project = project; ClassLoader ttcl = Thread.currentThread().getContextClassLoader(); try { Thread.currentThread().setContextClassLoader(project.getClassRealm()); this.packaging = session.requirePackaging(project.getPackaging()); } finally { Thread.currentThread().setContextClassLoader(ttcl); } }Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Mon Mar 24 22:23:23 GMT 2025 - 8.7K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ForwardingBlockingDeque.java
* invoke methods, they invoke methods on the {@code ForwardingBlockingDeque}. * * <p>The {@code standard} methods are not guaranteed to be thread-safe, even when all of the * methods that they depend on are thread-safe. * * @author Emily Soldal * @since 21.0 (since 14.0 as {@link com.google.common.collect.ForwardingBlockingDeque}) */ @J2ktIncompatible @GwtIncompatibleCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 4.3K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb1/com/SmbComRenameTest.java
@DisplayName("Test writeBytesWireFormat with very long file names") public void testWriteBytesWireFormatLongFileNames() { // Given String longOldFileName = "a".repeat(255); // Max filename length String longNewFileName = "b".repeat(255); byte[] dst = new byte[1024]; smbComRename = new SmbComRename(config, longOldFileName, longNewFileName); int dstIndex = 0; // WhenCreated: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 12.5K bytes - Click Count (0)