Search Options

Results per page
Sort
Preferred Languages
Advance

Results 621 - 630 of 977 for concurrents (0.07 sec)

  1. guava-tests/test/com/google/common/io/MoreFilesTest.java

    import java.nio.file.SimpleFileVisitor;
    import java.nio.file.attribute.BasicFileAttributes;
    import java.nio.file.attribute.FileTime;
    import java.util.EnumSet;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.Future;
    import junit.framework.TestCase;
    import junit.framework.TestSuite;
    
    /**
     * Tests for {@link MoreFiles}.
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 27.4K 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. okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/LoggingEventListener.kt

     * limitations under the License.
     */
    package okhttp3.logging
    
    import java.io.IOException
    import java.net.InetAddress
    import java.net.InetSocketAddress
    import java.net.Proxy
    import java.util.concurrent.TimeUnit
    import okhttp3.Call
    import okhttp3.Connection
    import okhttp3.EventListener
    import okhttp3.Handshake
    import okhttp3.HttpUrl
    import okhttp3.OkHttpClient
    import okhttp3.Protocol
    import okhttp3.Request
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 01 11:07:32 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/taglib/FessFunctions.java

    import java.util.Calendar;
    import java.util.Date;
    import java.util.Enumeration;
    import java.util.List;
    import java.util.Locale;
    import java.util.Map;
    import java.util.Objects;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.TimeUnit;
    import java.util.regex.Matcher;
    import java.util.regex.Pattern;
    import java.util.stream.Collectors;
    
    import org.apache.commons.lang3.time.DurationFormatUtils;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/cache/PopulatedCachesTest.java

    import static com.google.common.cache.TestingCacheLoaders.identityLoader;
    import static com.google.common.truth.Truth.assertThat;
    import static java.util.concurrent.TimeUnit.DAYS;
    import static java.util.concurrent.TimeUnit.SECONDS;
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.base.Function;
    import com.google.common.cache.CacheBuilderFactory.DurationSpec;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 02 18:21:29 UTC 2024
    - 15K bytes
    - Viewed (0)
  6. 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)
  7. android/guava-testlib/src/com/google/common/collect/testing/testers/ListListIteratorTester.java

    import com.google.common.collect.testing.features.ListFeature;
    import java.lang.reflect.Method;
    import java.util.List;
    import java.util.ListIterator;
    import java.util.Set;
    import java.util.concurrent.CopyOnWriteArraySet;
    import org.checkerframework.checker.nullness.qual.Nullable;
    import org.junit.Ignore;
    
    /**
     * A generic JUnit test which tests {@code listIterator} operations on a list. Can't be invoked
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 5K bytes
    - Viewed (0)
  8. guava/src/com/google/common/escape/ParametricNullness.java

     *       you can set {@code
     *       -XepOpt:NullAway:CustomNullableAnnotations=com.google.common.base.ParametricNullness,...,com.google.common.util.concurrent.ParametricNullness},
     *       where the {@code ...} contains the names of all the other {@code ParametricNullness}
     *       annotations in Guava. Or you might prefer to omit Guava from your {@code AnnotatedPackages}
     *       list.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Aug 10 21:27:51 UTC 2022
    - 4.1K bytes
    - Viewed (0)
  9. okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceHttpTest.kt

     * limitations under the License.
     */
    package okhttp3.sse.internal
    
    import assertk.assertThat
    import assertk.assertions.containsExactly
    import assertk.assertions.isEqualTo
    import java.util.concurrent.TimeUnit
    import mockwebserver3.MockResponse
    import mockwebserver3.MockWebServer
    import okhttp3.OkHttpClientTestRule
    import okhttp3.RecordingEventListener
    import okhttp3.Request
    import okhttp3.sse.EventSource
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Jan 14 10:20:09 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/io/CharSequenceReader.java

       * such as:
       *
       * - Make checkOpen return the non-null `seq`. Then callers can assign that to a local variable or
       *   even back to `this.seq`. However, that may suggest that we're defending against concurrent
       *   mutation, which is not an actual risk because we use `synchronized`.
       * - Make `remaining` require a non-null `seq` argument. But this is a bit weird because the
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 4.5K bytes
    - Viewed (0)
Back to top