- Sort Score
- Num 10 results
- Language All
Results 381 - 390 of 1,325 for concurrency (0.05 seconds)
-
android/guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java
* limitations under the License. */ package com.google.common.util.concurrent; import static com.google.common.base.Preconditions.checkNotNull; import static com.google.common.util.concurrent.Uninterruptibles.joinUninterruptibly; import static java.util.concurrent.TimeUnit.MILLISECONDS; import static junit.framework.Assert.fail; import com.google.common.annotations.GwtIncompatible;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 15:38:30 GMT 2026 - 3.4K bytes - Click Count (0) -
guava/src/com/google/common/collect/ForwardingConcurrentMap.java
import com.google.common.annotations.GwtCompatible; import com.google.errorprone.annotations.CanIgnoreReturnValue; import java.util.concurrent.ConcurrentMap; import org.jspecify.annotations.Nullable; /** * A concurrent map which forwards all its method calls to another concurrent map. Subclasses should * override one or more methods to modify the behavior of the backing map as desired per the <a
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Feb 18 16:58:16 GMT 2025 - 2.6K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AggregateFutureStateFallbackAtomicHelperTest.java
import java.lang.reflect.Field; import java.lang.reflect.Method; import java.lang.reflect.Modifier; import java.net.URLClassLoader; import java.util.Set; import java.util.concurrent.atomic.AtomicIntegerFieldUpdater; import java.util.concurrent.atomic.AtomicReferenceFieldUpdater; import junit.framework.TestCase; import junit.framework.TestSuite; import org.jspecify.annotations.NullUnmarked; /**
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 6.7K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ListenableScheduledFuture.java
* or implied. See the License for the specific language governing permissions and limitations under * the License. */ package com.google.common.util.concurrent; import com.google.common.annotations.GwtCompatible; import java.util.concurrent.ScheduledFuture; import org.jspecify.annotations.Nullable; /** * Helper interface to implement both {@link ListenableFuture} and {@link ScheduledFuture}. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 1K bytes - Click Count (0) -
src/main/java/org/codelibs/core/timer/TimeoutManager.java
*/ package org.codelibs.core.timer; import java.util.ArrayList; import java.util.List; import java.util.concurrent.ExecutorService; import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; import org.codelibs.core.collection.SLinkedList; import org.codelibs.core.lang.StringUtil; import org.codelibs.core.log.Logger;
Created: Fri Apr 03 20:58:12 GMT 2026 - Last Modified: Sat May 10 01:32:17 GMT 2025 - 7.8K bytes - Click Count (0) -
regression-test/src/androidTest/java/okhttp/regression/compare/AndroidHttpEngineTest.kt
import java.net.HttpURLConnection import java.net.URL import java.nio.ByteBuffer import java.util.concurrent.CompletableFuture import java.util.concurrent.ExecutionException import java.util.concurrent.ExecutorService import java.util.concurrent.Executors import java.util.concurrent.TimeUnit import kotlin.coroutines.cancellation.CancellationException import okio.Buffer import org.junit.After
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 6.3K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java
import com.google.common.collect.Iterables; import com.google.common.util.concurrent.Service.Listener; import com.google.common.util.concurrent.Service.State; import com.google.errorprone.annotations.concurrent.GuardedBy; import java.util.ArrayList; import java.util.List; import java.util.concurrent.CountDownLatch; import java.util.concurrent.FutureTask; import java.util.concurrent.atomic.AtomicInteger; import junit.framework.TestCase;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 28.7K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java
import com.google.common.collect.Iterables; import com.google.common.util.concurrent.Service.Listener; import com.google.common.util.concurrent.Service.State; import com.google.errorprone.annotations.concurrent.GuardedBy; import java.util.ArrayList; import java.util.List; import java.util.concurrent.CountDownLatch; import java.util.concurrent.FutureTask; import java.util.concurrent.atomic.AtomicInteger; import junit.framework.TestCase;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 28.7K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
import com.google.common.util.concurrent.Service.State; import com.google.common.util.concurrent.ServiceManager.Listener; import java.time.Duration; import java.util.ArrayList; import java.util.Arrays; import java.util.Collection; import java.util.List; import java.util.Set; import java.util.concurrent.CountDownLatch; import java.util.concurrent.Executor; import java.util.concurrent.TimeUnit;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 25.6K bytes - Click Count (0) -
guava-gwt/src/com/google/common/ForceGuavaCompilation.gwt.xml
<inherits name="com.google.common.math.Math" /> <inherits name="com.google.common.net.Net" /> <inherits name="com.google.common.primitives.Primitives" /> <inherits name="com.google.common.util.concurrent.Concurrent" /> <inherits name="com.google.common.xml.Xml" /> <inherits name="com.google.thirdparty.publicsuffix.PublicSuffixPatterns" /> <inherits name="com.google.thirdparty.publicsuffix.PublicSuffixType" />
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Sep 27 15:04:14 GMT 2021 - 1.1K bytes - Click Count (0)