Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 981 - 990 of 1,325 for concurrency (0.14 seconds)

  1. 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)
  2. 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)
  3. 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 store
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 8K bytes
    - Click Count (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top