Search Options

Results per page
Sort
Preferred Languages
Advance

Results 401 - 410 of 958 for concurrence (0.09 sec)

  1. mockwebserver/src/test/java/mockwebserver3/CustomDispatcherTest.kt

     */
    package mockwebserver3
    
    import assertk.assertThat
    import assertk.assertions.isEqualTo
    import java.io.IOException
    import java.net.HttpURLConnection
    import java.util.concurrent.CountDownLatch
    import java.util.concurrent.atomic.AtomicInteger
    import org.junit.jupiter.api.BeforeEach
    import org.junit.jupiter.api.Test
    import org.junit.jupiter.api.Timeout
    
    @Timeout(30)
    class CustomDispatcherTest {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  2. common-protos/k8s.io/api/flowcontrol/v1beta3/generated.proto

      // borrowing seats from this level.
      // The server's concurrency limit (ServerCL) is divided among the
      // Limited priority levels in proportion to their NCS values:
      //
      // NominalCL(i)  = ceil( ServerCL * NCS(i) / sum_ncs )
      // sum_ncs = sum[limited priority level k] NCS(k)
      //
      // Bigger numbers mean a larger nominal concurrency limit,
      // at the expense of every other Limited priority level.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 19.5K bytes
    - Viewed (0)
  3. pyproject.toml

        ]
    
    [tool.tiangolo._internal-slim-build.packages.fastapi-slim.project]
    name = "fastapi-slim"
    
    [tool.mypy]
    strict = true
    
    [[tool.mypy.overrides]]
    module = "fastapi.concurrency"
    warn_unused_ignores = false
    ignore_missing_imports = true
    
    [[tool.mypy.overrides]]
    module = "fastapi.tests.*"
    ignore_missing_imports = true
    check_untyped_defs = true
    
    [[tool.mypy.overrides]]
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Oct 22 14:19:56 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

    import java.util.IdentityHashMap;
    import java.util.Map;
    import java.util.concurrent.Callable;
    import java.util.concurrent.CancellationException;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.Executor;
    import java.util.concurrent.Future;
    import java.util.concurrent.RejectedExecutionException;
    import java.util.concurrent.atomic.AtomicReference;
    import javax.annotation.CheckForNull;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 08 19:36:35 UTC 2024
    - 98.5K bytes
    - Viewed (0)
  5. compat/maven-resolver-provider/src/test/java/org/apache/maven/repository/internal/util/ConsoleTransferListener.java

    package org.apache.maven.repository.internal.util;
    
    import java.io.PrintStream;
    import java.text.DecimalFormat;
    import java.text.DecimalFormatSymbols;
    import java.util.Locale;
    import java.util.Map;
    import java.util.concurrent.ConcurrentHashMap;
    
    import org.eclipse.aether.transfer.AbstractTransferListener;
    import org.eclipse.aether.transfer.TransferEvent;
    import org.eclipse.aether.transfer.TransferResource;
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/eventbus/SubscriberRegistry.java

    import com.google.common.util.concurrent.UncheckedExecutionException;
    import com.google.j2objc.annotations.Weak;
    import java.lang.reflect.Method;
    import java.util.Arrays;
    import java.util.Collection;
    import java.util.Iterator;
    import java.util.List;
    import java.util.Map;
    import java.util.Map.Entry;
    import java.util.Set;
    import java.util.concurrent.ConcurrentMap;
    import java.util.concurrent.CopyOnWriteArraySet;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 15:16:45 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  7. guava/src/com/google/common/collect/TreeMultimap.java

     * support them). All optional multimap methods are supported, and all returned views are
     * modifiable.
     *
     * <p>This class is not threadsafe when any concurrent operations update the multimap. Concurrent
     * read operations will work correctly. To allow concurrent update operations, wrap your multimap
     * with a call to {@link Multimaps#synchronizedSortedSetMultimap}.
     *
     * <p>See the Guava User Guide article on <a href=
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Mar 09 00:21:17 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/cache/NullCacheTest.java

    import static com.google.common.truth.Truth.assertThat;
    import static java.util.concurrent.TimeUnit.SECONDS;
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.cache.CacheLoader.InvalidCacheLoadException;
    import com.google.common.cache.TestingRemovalListeners.QueuingRemovalListener;
    import com.google.common.util.concurrent.UncheckedExecutionException;
    import junit.framework.TestCase;
    
    /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 4.4K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/cache/NullCacheTest.java

    import static com.google.common.truth.Truth.assertThat;
    import static java.util.concurrent.TimeUnit.SECONDS;
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.cache.CacheLoader.InvalidCacheLoadException;
    import com.google.common.cache.TestingRemovalListeners.QueuingRemovalListener;
    import com.google.common.util.concurrent.UncheckedExecutionException;
    import junit.framework.TestCase;
    
    /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 4.4K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/UncheckedExecutionException.java

     * the License.
     */
    
    package com.google.common.util.concurrent;
    
    import com.google.common.annotations.GwtCompatible;
    import javax.annotation.CheckForNull;
    
    /**
     * Unchecked variant of {@link java.util.concurrent.ExecutionException}. As with {@code
     * ExecutionException}, the exception's {@linkplain #getCause() cause} comes from a failed task,
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Mar 07 17:52:19 UTC 2024
    - 4.1K bytes
    - Viewed (0)
Back to top