- Sort Score
- Num 10 results
- Language All
Results 411 - 420 of 830 for concurrent (0.06 seconds)
-
mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt
import java.net.HttpURLConnection import java.net.ProtocolException import java.net.SocketTimeoutException import java.nio.charset.StandardCharsets import java.util.Arrays import java.util.concurrent.TimeUnit import java.util.concurrent.atomic.AtomicBoolean import javax.net.ssl.HttpsURLConnection import kotlin.test.assertFailsWith import okhttp3.Headers import okhttp3.Protocol import okhttp3.RecordingHostnameVerifier
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Thu Jul 03 13:16:34 GMT 2025 - 22.3K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/ConnectionCoalescingTest.kt
import java.net.InetAddress import java.net.InetSocketAddress import java.net.Proxy import java.security.cert.X509Certificate import java.util.Arrays import java.util.concurrent.CountDownLatch import java.util.concurrent.atomic.AtomicInteger import java.util.concurrent.atomic.AtomicReference import javax.net.ssl.HostnameVerifier import javax.net.ssl.SSLPeerUnverifiedException import javax.net.ssl.SSLSession
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Thu Jun 19 11:44:16 GMT 2025 - 19.1K bytes - Click Count (0) -
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 Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 9.2K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/concurrent/TaskLoggerTest.kt
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3.internal.concurrent import assertk.assertThat import assertk.assertions.isEqualTo import org.junit.jupiter.api.Test class TaskLoggerTest { @Suppress("ktlint") @Test fun formatTime() {Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Dec 27 13:39:56 GMT 2024 - 3.6K bytes - Click Count (0) -
android/guava/src/com/google/common/cache/ForwardingLoadingCache.java
import com.google.common.annotations.GwtIncompatible; import com.google.common.base.Preconditions; import com.google.common.collect.ImmutableMap; import com.google.errorprone.annotations.CanIgnoreReturnValue; import java.util.concurrent.ExecutionException; /** * A cache which forwards all its method calls to another cache. Subclasses should override one or * more methods to modify the behavior of the backing cache as desired per the <a
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sat Dec 21 03:10:51 GMT 2024 - 2.9K bytes - Click Count (0) -
impl/maven-core/src/test/java/org/apache/maven/lifecycle/DelegatingMojoExecutionListener.java
* under the License. */ package org.apache.maven.lifecycle; import javax.inject.Named; import javax.inject.Singleton; import java.util.List; import java.util.concurrent.CopyOnWriteArrayList; import org.apache.maven.execution.MojoExecutionEvent; import org.apache.maven.execution.MojoExecutionListener; import org.apache.maven.plugin.MojoExecutionException; @Named @Singleton
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Jun 06 14:28:57 GMT 2025 - 2.2K bytes - Click Count (0) -
samples/guide/src/main/java/okhttp3/recipes/PerCallSettings.java
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3.recipes; import java.io.IOException; import java.util.concurrent.TimeUnit; import okhttp3.OkHttpClient; import okhttp3.Request; import okhttp3.Response; public final class PerCallSettings { private final OkHttpClient client = new OkHttpClient();Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sun May 22 01:29:42 GMT 2016 - 1.9K bytes - Click Count (0) -
build-logic-commons/basics/src/main/kotlin/gradlebuild/basics/PublicApi.kt
"org/gradle/authentication/**", "org/gradle/build/**", "org/gradle/buildconfiguration/**", "org/gradle/buildinit/**", "org/gradle/caching/**", "org/gradle/concurrent/**", "org/gradle/deployment/**", "org/gradle/external/javadoc/**", "org/gradle/ide/**", "org/gradle/ivy/**", "org/gradle/jvm/**", "org/gradle/language/**",Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Wed Jun 12 23:20:08 GMT 2024 - 2.4K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/cache/CacheBuilderSpecTest.java
import static com.google.common.truth.Truth.assertThat; import static com.google.common.truth.Truth.assertWithMessage; import static java.util.concurrent.TimeUnit.DAYS; import static java.util.concurrent.TimeUnit.HOURS; import static java.util.concurrent.TimeUnit.MINUTES; import static java.util.concurrent.TimeUnit.SECONDS; import static org.junit.Assert.assertThrows; import com.google.common.base.Suppliers;
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Sep 30 22:03:28 GMT 2025 - 20.8K bytes - Click Count (0) -
okhttp/api/jvm/okhttp.api
public final fun maxAge (ILjava/util/concurrent/TimeUnit;)Lokhttp3/CacheControl$Builder; public final fun maxAge-LRDsOJo (J)Lokhttp3/CacheControl$Builder; public final fun maxStale (ILjava/util/concurrent/TimeUnit;)Lokhttp3/CacheControl$Builder; public final fun maxStale-LRDsOJo (J)Lokhttp3/CacheControl$Builder; public final fun minFresh (ILjava/util/concurrent/TimeUnit;)Lokhttp3/CacheControl$Builder;
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Nov 05 18:28:35 GMT 2025 - 70.2K bytes - Click Count (0)