- Sort Score
- Num 10 results
- Language All
Results 501 - 510 of 830 for concurrent (0.05 seconds)
-
android/guava/src/com/google/common/collect/MapMakerInternalMap.java
import java.util.Set; import java.util.concurrent.CancellationException; import java.util.concurrent.ConcurrentMap; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicReferenceArray; import java.util.concurrent.locks.ReentrantLock; import org.jspecify.annotations.NullUnmarked; import org.jspecify.annotations.Nullable; /** * The concurrent hash map implementation built by {@link MapMaker}. *Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 22 18:35:44 GMT 2025 - 89.9K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/RealInterceptorChain.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3.internal.http import java.io.IOException import java.util.concurrent.TimeUnit import okhttp3.Call import okhttp3.Connection import okhttp3.Interceptor import okhttp3.Request import okhttp3.Response import okhttp3.internal.checkDuration import okhttp3.internal.connection.Exchange
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Dec 27 13:39:56 GMT 2024 - 4.2K bytes - Click Count (0) -
build-logic/build-update-utils/src/test/groovy/gradlebuild/buildutils/tasks/UpdateReleasedVersionsTest.groovy
import gradlebuild.buildutils.model.ReleasedVersion import gradlebuild.buildutils.model.ReleasedVersions import spock.lang.Specification import java.text.SimpleDateFormat import static java.util.concurrent.TimeUnit.DAYS class UpdateReleasedVersionsTest extends Specification { def format = new SimpleDateFormat('yyyyMMddHHmmssZ') def setup() { format.timeZone = TimeZone.getTimeZone("UTC") }Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Wed Dec 09 08:14:05 GMT 2020 - 5.4K bytes - Click Count (0) -
guava/src/com/google/common/collect/ImmutableEnumSet.java
import com.google.common.annotations.GwtCompatible; import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import com.google.errorprone.annotations.concurrent.LazyInit; import java.io.InvalidObjectException; import java.io.ObjectInputStream; import java.io.Serializable; import java.util.Collection; import java.util.EnumSet; import java.util.Spliterator;
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 4.5K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt
import okhttp3.Protocol import okhttp3.Request import okhttp3.Route import okhttp3.internal.closeQuietly import okhttp3.internal.concurrent.TaskRunner import okhttp3.internal.concurrent.withLock import okhttp3.internal.connection.RoutePlanner.ConnectResult import okhttp3.internal.http.ExchangeCodec import okhttp3.internal.http1.Http1ExchangeCodec import okhttp3.internal.platform.Platform import okhttp3.internal.tls.OkHostnameVerifier
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Oct 08 03:50:05 GMT 2025 - 19.3K bytes - Click Count (2) -
guava/src/com/google/common/collect/DescendingMultiset.java
* limitations under the License. */ package com.google.common.collect; import com.google.common.annotations.GwtCompatible; import com.google.errorprone.annotations.concurrent.LazyInit; import com.google.j2objc.annotations.WeakOuter; import java.util.Comparator; import java.util.Iterator; import java.util.NavigableSet; import java.util.Set; import org.jspecify.annotations.Nullable;
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 22 18:35:44 GMT 2025 - 4.4K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/CacheStrategy.kt
import java.net.HttpURLConnection.HTTP_NO_CONTENT import java.net.HttpURLConnection.HTTP_OK import java.net.HttpURLConnection.HTTP_REQ_TOO_LONG import java.util.Date import java.util.concurrent.TimeUnit.SECONDS import okhttp3.Request import okhttp3.Response import okhttp3.internal.http.HTTP_PERM_REDIRECT import okhttp3.internal.http.HTTP_TEMP_REDIRECT import okhttp3.internal.http.toHttpDateOrNull
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 12K bytes - Click Count (0) -
misc/ios/go_ios_exec.go
// works, but only when running one binary at a time. // Use a file lock to make sure only one wrapper is running at a time. // // The lock file is never deleted, to avoid concurrent locks on distinct // files with the same path. lockName := filepath.Join(os.TempDir(), "go_ios_exec-"+deviceID+".lock") lock, err = os.OpenFile(lockName, os.O_CREATE|os.O_RDONLY, 0666) if err != nil { return 1, err
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Tue Sep 16 00:34:45 GMT 2025 - 8.7K bytes - Click Count (0) -
internal/grid/README.md
# MinIO Grid The MinIO Grid is a package that provides two-way communication between servers. It uses a single two-way connection to send and receive messages between servers. It includes built in muxing of concurrent requests as well as congestion handling for streams. Requests can be "Single Payload" or "Streamed". Use the MinIO Grid for: * Small, frequent requests with low latency requirements.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Oct 10 18:57:03 GMT 2025 - 9.4K bytes - Click Count (0) -
mockwebserver-junit5/src/test/java/mockwebserver3/junit5/StartStopTest.kt
* limitations under the License. */ package mockwebserver3.junit5 import assertk.assertThat import assertk.assertions.isFalse import assertk.assertions.isTrue import java.util.concurrent.CopyOnWriteArrayList import mockwebserver3.Dispatcher import mockwebserver3.MockResponse import mockwebserver3.MockWebServer import mockwebserver3.RecordedRequest import org.junit.jupiter.api.Test
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Jun 18 11:13:17 GMT 2025 - 3.3K bytes - Click Count (1)