- Sort Score
- Num 10 results
- Language All
Results 111 - 120 of 1,216 for Concurrent (0.24 seconds)
-
android/guava-testlib/src/com/google/common/collect/testing/Helpers.java
* the size method */ public static <T extends @Nullable Object> Collection<T> misleadingSizeCollection(int delta) { // It would be nice to be able to return a real concurrent // collection like ConcurrentLinkedQueue, so that e.g. concurrent // iteration would work, but that would not be GWT-compatible. // We are not "just" inheriting from ArrayList here as this doesn't work for J2kt. return new AbstractList<T>() {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 23 21:06:42 GMT 2026 - 17.2K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/admin/group/EditForm.java
*/ @ValidateTypeFailure public Long updatedTime; /** * The version number of the group for optimistic locking. * This field is required to prevent concurrent modification conflicts * by ensuring the group hasn't been modified by another process. */ @Required @ValidateTypeFailure public Integer versionNo;Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Jul 17 08:28:31 GMT 2025 - 2.2K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/ds/callback/FileListIndexUpdateCallbackImplTest.java
try { for (int j = 0; j < urlsPerThread; j++) { // Access is synchronized internally in the actual implementation // Here we just verify no concurrent modification exceptions occur String url = "http://example.com/thread" + threadIndex + "/doc" + j; // Simulate the synchronized access that happens in deleteDocument()Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Wed Jan 14 14:29:07 GMT 2026 - 19.7K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java
import java.time.Duration; import java.util.concurrent.BlockingQueue; import java.util.concurrent.CancellationException; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import java.util.concurrent.Future; import java.util.concurrent.Semaphore; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jan 29 23:24:32 GMT 2026 - 22.5K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/Tags.kt
*/ package okhttp3.internal import java.util.concurrent.atomic.AtomicReference import kotlin.reflect.KClass /** * An immutable collection of key-value pairs implemented as a singly-linked list. * * Build up a collection by starting with [EmptyTags] and repeatedly calling [plus]. Each such call * returns a new instance. * * This collection is optimized for safe concurrent access over a very small number of elements. *
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 3.9K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/collect/testing/testers/ConcurrentMapReplaceEntryTester.java
import com.google.common.collect.testing.features.MapFeature; import java.util.concurrent.ConcurrentMap; import org.jspecify.annotations.NullMarked; import org.junit.Ignore; /** * A generic JUnit test which tests {@code replace(K, V, V)} operations on a concurrent map. Can't * be invoked directly; please see {@link * com.google.common.collect.testing.ConcurrentMapTestSuiteBuilder}. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Dec 21 14:50:24 GMT 2024 - 5.5K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/admin/relatedcontent/EditForm.java
*/ @ValidateTypeFailure public Long updatedTime; /** * The version number of the related content configuration for optimistic locking. * This field is required to prevent concurrent modification conflicts * by ensuring the configuration hasn't been modified by another process. */ @Required @ValidateTypeFailure public Integer versionNo;Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Jul 17 08:28:31 GMT 2025 - 2.4K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/admin/webauth/EditForm.java
*/ @ValidateTypeFailure public Long updatedTime; /** * The version number of the web authentication configuration for optimistic locking. * This field is required to prevent concurrent modification conflicts * by ensuring the configuration hasn't been modified by another process. */ @Required @ValidateTypeFailure public Integer versionNo;Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Jul 17 08:28:31 GMT 2025 - 2.4K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/admin/dataconfig/EditForm.java
*/ @ValidateTypeFailure public Long updatedTime; /** * The version number of the data configuration for optimistic locking. * This field is required to prevent concurrent modification conflicts * by ensuring the configuration hasn't been modified by another process. */ @Required @ValidateTypeFailure public Integer versionNo;Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Jul 17 08:28:31 GMT 2025 - 2.3K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/admin/pathmap/EditForm.java
*/ @ValidateTypeFailure public Long updatedTime; /** * The version number of the path mapping configuration for optimistic locking. * This field is required to prevent concurrent modification conflicts * by ensuring the configuration hasn't been modified by another process. */ @Required @ValidateTypeFailure public Integer versionNo;Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Jul 17 08:28:31 GMT 2025 - 2.3K bytes - Click Count (0)