- Sort Score
- Result 10 results
- Languages All
Results 621 - 630 of 977 for concurrents (0.07 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)