Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 857 for concurrency (0.1 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. fastapi/concurrency.py

    from typing import TypeVar
    
    import anyio.to_thread
    from anyio import CapacityLimiter
    from starlette.concurrency import iterate_in_threadpool as iterate_in_threadpool  # noqa
    from starlette.concurrency import run_in_threadpool as run_in_threadpool  # noqa
    from starlette.concurrency import (  # noqa
        run_until_first_complete as run_until_first_complete,
    )
    
    _T = TypeVar("_T")
    
    
    @asynccontextmanager
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Wed Dec 17 21:25:59 GMT 2025
    - 1.5K bytes
    - Click Count (0)
  2. cmd/speedtest.go

    			// the concurrency make sure we choose only the "start"
    			// concurrency to be equal to the lowest number of
    			// local disks per server.
    			for _, localDiskCount := range globalEndpoints.NLocalDisksPathsPerPool() {
    				if localDiskCount < concurrency {
    					concurrency = localDiskCount
    				}
    			}
    
    			// Any concurrency less than '4' just stick to '4' concurrent
    			// operations for now to begin with.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 9.2K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

    import java.time.Duration;
    import java.util.concurrent.BlockingQueue;
    import java.util.concurrent.CancellationException;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Future;
    import java.util.concurrent.Semaphore;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jan 29 23:24:32 GMT 2026
    - 22.5K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/collect/MapMaker.java

      }
    
      /**
       * Guides the allowed concurrency among update operations. Used as a hint for internal sizing. The
       * table is internally partitioned to try to permit the indicated number of concurrent updates
       * without contention. Because assignment of entries to these partitions is not necessarily
       * uniform, the actual concurrency observed may vary. Ideally, you should choose a value to
    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)
  5. guava-testlib/test/com/google/common/testing/FakeTickerTest.java

    import java.util.concurrent.Callable;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Future;
    import java.util.concurrent.TimeUnit;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    import org.jspecify.annotations.Nullable;
    
    /**
     * Unit test for {@link FakeTicker}.
     *
     * @author Jige Yu
     */
    @GwtCompatible
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 16:11:48 GMT 2026
    - 6.1K bytes
    - Click Count (0)
  6. android/guava-testlib/test/com/google/common/testing/FakeTickerTest.java

    import java.util.concurrent.Callable;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Future;
    import java.util.concurrent.TimeUnit;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    import org.jspecify.annotations.Nullable;
    
    /**
     * Unit test for {@link FakeTicker}.
     *
     * @author Jige Yu
     */
    @GwtCompatible
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 16:11:48 GMT 2026
    - 6.3K bytes
    - Click Count (0)
  7. src/main/java/org/codelibs/fess/app/web/admin/duplicatehost/EditForm.java

         * Stored as a long value representing milliseconds since epoch.
         * Used for audit trail and concurrency control.
         */
        @ValidateTypeFailure
        public Long updatedTime;
    
        /**
         * The version number of the duplicate host configuration for optimistic locking.
         * This field is required to prevent concurrent modification conflicts
         * by ensuring the configuration hasn't been modified by another process.
         */
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 2.4K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/llm/AbstractLlmClient.java

        public int getHistoryAssistantSummaryMaxChars() {
            return 800;
        }
    
        // --- Concurrency control ---
    
        /**
         * Gets the maximum number of concurrent requests to the LLM provider.
         * Default is 5. Override or configure via rag.llm.{provider}.max.concurrent.requests.
         *
         * @return the maximum concurrent requests
         */
        protected int getMaxConcurrentRequests() {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 21 06:04:58 GMT 2026
    - 72K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/cache/CacheBuilder.java

      }
    
      /**
       * Guides the allowed concurrency among update operations. Used as a hint for internal sizing. The
       * table is internally partitioned to try to permit the indicated number of concurrent updates
       * without contention. Because assignment of entries to these partitions is not necessarily
       * uniform, the actual concurrency observed may vary. Ideally, you should choose a value to
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 13:13:59 GMT 2026
    - 52K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/core/collection/LruHashMap.java

     * Map&lt;K, V&gt; syncMap = Collections.synchronizedMap(new LruHashMap&lt;&gt;(100));
     * </pre>
     * <p>
     * Alternatively, for high-concurrency scenarios, consider implementing a custom
     * LRU cache using {@link java.util.concurrent.ConcurrentHashMap} with an eviction strategy.
     * </p>
     *
     * @author koichik
     * @param <K> the key type
     * @param <V> the value type
     */
    public class LruHashMap<K, V> extends LinkedHashMap<K, V> {
    
    Created: Fri Apr 03 20:58:12 GMT 2026
    - Last Modified: Sat Nov 22 11:21:59 GMT 2025
    - 3K bytes
    - Click Count (0)
Back to Top