- Sort Score
- Result 10 results
- Languages All
Results 411 - 420 of 1,082 for concurrent (0.07 sec)
-
src/test/java/jcifs/internal/witness/MockWitnessService.java
package jcifs.internal.witness; import java.io.IOException; import java.net.InetAddress; import java.net.ServerSocket; import java.net.Socket; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicInteger; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Mock witness service for integration testing.
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 23 09:06:40 UTC 2025 - 8.2K bytes - Viewed (0) -
guava/src/com/google/common/collect/ArrayListMultimap.java
* implement {@link java.util.RandomAccess}. * * <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#synchronizedListMultimap}. * * <p>See the Guava User Guide article on <a href=Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Fri Dec 05 23:15:58 UTC 2025 - 6.8K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/cache/super/com/google/common/cache/LocalCache.java
import java.util.LinkedHashMap; import java.util.Map; import java.util.Map.Entry; import java.util.NoSuchElementException; import java.util.Set; import java.util.concurrent.Callable; import java.util.concurrent.ConcurrentMap; import java.util.concurrent.ExecutionException; import org.jspecify.annotations.NullUnmarked; import org.jspecify.annotations.Nullable; /** * LocalCache emulation for GWT. *
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 19:31:30 UTC 2025 - 21.8K bytes - Viewed (0) -
okhttp/src/jvmMain/java9/module-info.java
exports okhttp3; exports okhttp3.internal to okhttp3.logging, okhttp3.sse, okhttp3.java.net.cookiejar, okhttp3.dnsoverhttps, mockwebserver3, okhttp3.mockwebserver, okhttp3.coroutines, okhttp3.tls; exports okhttp3.internal.concurrent to mockwebserver3, okhttp3.mockwebserver; exports okhttp3.internal.connection to mockwebserver3, okhttp3.mockwebserver, okhttp3.logging; exports okhttp3.internal.http to okhttp3.logging, okhttp3.brotli, mockwebserver3;
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sun Sep 21 08:30:26 UTC 2025 - 969 bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/WholeOperationTimeoutTest.kt
import assertk.assertions.isTrue import java.io.IOException import java.io.InterruptedIOException import java.net.HttpURLConnection import java.time.Duration import java.util.concurrent.CountDownLatch import java.util.concurrent.TimeUnit import java.util.concurrent.atomic.AtomicReference import kotlin.test.assertFailsWith import mockwebserver3.MockResponse import mockwebserver3.MockWebServer import mockwebserver3.junit5.StartStop
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 10.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
*/ package com.google.common.util.concurrent; import static com.google.common.truth.Truth.assertThat; import static java.lang.Math.max; import static java.lang.reflect.Modifier.isStatic; import static java.util.concurrent.TimeUnit.MICROSECONDS; import static java.util.concurrent.TimeUnit.MILLISECONDS; import static java.util.concurrent.TimeUnit.NANOSECONDS; import static java.util.concurrent.TimeUnit.SECONDS;
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Oct 28 18:19:59 UTC 2025 - 21.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
*/ package com.google.common.util.concurrent; import static com.google.common.truth.Truth.assertThat; import static java.lang.Math.max; import static java.lang.reflect.Modifier.isStatic; import static java.util.concurrent.TimeUnit.MICROSECONDS; import static java.util.concurrent.TimeUnit.MILLISECONDS; import static java.util.concurrent.TimeUnit.NANOSECONDS; import static java.util.concurrent.TimeUnit.SECONDS;
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Oct 28 18:19:59 UTC 2025 - 21.9K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/net/protocol/storage/HandlerTest.java
import java.io.IOException; import java.net.URL; import java.net.URLConnection; import java.util.ArrayList; import java.util.List; import java.util.concurrent.CountDownLatch; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicInteger; import org.codelibs.fess.crawler.container.StandardCrawlerContainer; import org.dbflute.utflute.core.PlainTestCase; /**
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Dec 11 08:38:29 UTC 2025 - 14.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/accesstoken/EditForm.java
* Stored as a long value representing milliseconds since epoch. * Used for audit trail and concurrency control. */ @ValidateTypeFailure public Long updatedTime; /** * The version number of the access token for optimistic locking. * This field is required to prevent concurrent modification conflicts * by ensuring the token hasn't been modified by another process. */ @RequiredRegistered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 2.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/badword/EditForm.java
* Stored as a long value representing milliseconds since epoch. * Used for audit trail and concurrency control. */ @ValidateTypeFailure public Long updatedTime; /** * The version number of the bad word entry for optimistic locking. * This field is required to prevent concurrent modification conflicts * by ensuring the entry hasn't been modified by another process. */ @RequiredRegistered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 2.2K bytes - Viewed (0)