- Sort Score
- Num 10 results
- Language All
Results 981 - 990 of 1,325 for concurrency (0.14 seconds)
-
src/main/java/org/codelibs/fess/suggest/index/SuggestIndexer.java
import java.time.ZonedDateTime; import java.util.Map; import java.util.concurrent.ExecutorService; import java.util.function.Supplier; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.core.lang.StringUtil; import org.codelibs.fess.suggest.analysis.SuggestAnalyzer; import org.codelibs.fess.suggest.concurrent.Deferred; import org.codelibs.fess.suggest.converter.ReadingConverter;
Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Sat Mar 14 02:35:38 GMT 2026 - 20.9K bytes - Click Count (0) -
guava/src/com/google/common/collect/MoreCollectors.java
* with a {@code com.google.common} type. * * @author Louis Wasserman * @since 21.0 */ @GwtCompatible public final class MoreCollectors { /* * TODO(lowasser): figure out if we can convert this to a concurrent AtomicReference-based * collector without breaking j2cl? */ private static final Collector<Object, ?, Optional<Object>> TO_OPTIONAL = Collector.of( () -> new ToOptionalState<>(null),Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Feb 18 16:22:33 GMT 2026 - 6.1K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/dict/DictionaryManager.java
} } return OptionalEntity.empty(); } /** * Stores or updates a dictionary file in the ConfigSync storage. * This method checks for concurrent modifications by comparing timestamps * and uploads the file content to the ConfigSync API. * * @param dictFile the dictionary file metadata to storeCreated: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 8K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AtomicDoubleTest.java
/* * Source: * http://gee.cs.oswego.edu/cgi-bin/viewcvs.cgi/jsr166/src/test/tck-jsr166e/AtomicDoubleTest.java?revision=1.8 * (Modified to adapt to guava coding conventions) */ package com.google.common.util.concurrent; import static com.google.common.truth.Truth.assertThat; import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import org.jspecify.annotations.NullUnmarked;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Mar 13 13:01:07 GMT 2026 - 7.3K bytes - Click Count (0) -
cmd/metacache.go
metacacheBlockSize = 5000 // metacacheSharePrefix controls whether prefixes on dirty paths are always shared. // This will make `test/a` and `test/b` share listings if they are concurrent. // Enabling this will make cache sharing more likely and cause less IO, // but may cause additional latency to some calls. metacacheSharePrefix = false ) //go:generate msgp -file $GOFILE -unexported
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Jul 12 16:23:16 GMT 2024 - 6K bytes - Click Count (0) -
CLAUDE.md
├── entity/ # Domain models (SuggestItem, etc.) ├── normalizer/ # Text normalizers ├── converter/ # Reading converters (katakana, romaji) ├── concurrent/ # Async patterns (Deferred/Promise) └── util/ # Utilities ``` ### Key Design Patterns - **Builder**: SuggesterBuilder, SuggestRequestBuilder
Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Thu Mar 12 03:39:53 GMT 2026 - 8.1K bytes - Click Count (0) -
docs/features/connections.md
Since version 5.0, `OkHttpClient` supports fast fallback, which is our implementation of Happy Eyeballs [RFC 6555](https://datatracker.ietf.org/doc/html/rfc6555). With fast fallback, OkHttp attempts to connect to multiple web servers concurrently. It keeps whichever route connects first and cancels all of the others. Its rules are: * Prefer to alternate IP addresses from different address families, (IPv6 / IPv4), starting with IPv6.
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Mar 15 09:01:42 GMT 2026 - 5.4K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/internal/impl/DefaultSession.java
import java.nio.file.Path; import java.time.Instant; import java.util.Collection; import java.util.Collections; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import org.apache.maven.RepositoryUtils; import org.apache.maven.api.Project; import org.apache.maven.api.RemoteRepository; import org.apache.maven.api.Session; import org.apache.maven.api.Version;
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Jun 06 14:28:57 GMT 2025 - 8.9K bytes - Click Count (0) -
docs/fr/docs/deployment/manually.md
En ajoutant `standard`, Uvicorn va installer et utiliser quelques dépendances supplémentaires recommandées. Cela inclut `uvloop`, le remplaçant hautes performances de `asyncio`, qui fournit le gros gain de performance en matière de concurrence. Lorsque vous installez FastAPI avec quelque chose comme `pip install "fastapi[standard]"`, vous obtenez déjà `uvicorn[standard]` aussi. /// ## Exécuter le programme serveur { #run-the-server-program }
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:37:13 GMT 2026 - 7.4K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2ExchangeCodec.kt
* limitations under the License. */ package okhttp3.internal.http2 import java.io.IOException import java.net.ProtocolException import java.util.Locale import java.util.concurrent.TimeUnit import okhttp3.Headers import okhttp3.OkHttpClient import okhttp3.Protocol import okhttp3.Request import okhttp3.Response import okhttp3.internal.headersContentLength
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jul 29 21:11:09 GMT 2025 - 7K bytes - Click Count (0)