Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 264 for Concurrent (0.06 sec)

  1. android/guava-testlib/src/com/google/common/testing/ArbitraryInstances.java

    import java.util.UUID;
    import java.util.concurrent.BlockingDeque;
    import java.util.concurrent.BlockingQueue;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.ConcurrentMap;
    import java.util.concurrent.ConcurrentNavigableMap;
    import java.util.concurrent.ConcurrentSkipListMap;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.Executor;
    import java.util.concurrent.LinkedBlockingDeque;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 20.9K bytes
    - Viewed (0)
  2. mockwebserver-deprecated/api/mockwebserver.api

    	public fun clone ()Lokhttp3/mockwebserver/MockResponse;
    	public final fun getBody ()Lokio/Buffer;
    	public final fun getBodyDelay (Ljava/util/concurrent/TimeUnit;)J
    	public final fun getHeaders ()Lokhttp3/Headers;
    	public final fun getHeadersDelay (Ljava/util/concurrent/TimeUnit;)J
    	public final fun getHttp2ErrorCode ()I
    	public final fun getPushPromises ()Ljava/util/List;
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Jul 22 12:28:51 UTC 2023
    - 10.2K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt

    import okhttp3.internal.concurrent.assertLockHeld
    import okhttp3.internal.concurrent.assertLockNotHeld
    import okhttp3.internal.concurrent.withLock
    import okhttp3.internal.http.ExchangeCodec
    import okhttp3.internal.http.RealInterceptorChain
    import okhttp3.internal.http1.Http1ExchangeCodec
    import okhttp3.internal.http2.ConnectionShutdownException
    import okhttp3.internal.http2.ErrorCode
    import okhttp3.internal.http2.FlowControlListener
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 14.9K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

    import java.util.List;
    import java.util.Queue;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.CyclicBarrier;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.Executor;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Future;
    import java.util.concurrent.RejectedExecutionException;
    import java.util.concurrent.atomic.AtomicBoolean;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  5. android/guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java

    import com.google.common.util.concurrent.AbstractFutureBenchmarks.OldAbstractFuture;
    import com.google.errorprone.annotations.concurrent.GuardedBy;
    import java.util.LinkedList;
    import java.util.Queue;
    import java.util.concurrent.ArrayBlockingQueue;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.Executor;
    import java.util.concurrent.Future;
    import java.util.concurrent.ThreadPoolExecutor;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 15.8K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/AbstractAbstractFutureTest.java

    import static com.google.common.util.concurrent.TestPlatform.getDoneFromTimeoutOverload;
    import static com.google.common.util.concurrent.TestPlatform.verifyGetOnPendingFuture;
    import static com.google.common.util.concurrent.TestPlatform.verifyTimedGetOnPendingFuture;
    import static java.util.concurrent.TimeUnit.NANOSECONDS;
    import static java.util.concurrent.TimeUnit.SECONDS;
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 15.4K bytes
    - Viewed (0)
  7. 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;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 19.8K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/TestThread.java

     * method equivalent to {@link java.util.concurrent.locks.ReentrantLock#hasQueuedThread(Thread)}. If
     * the {@link #callAndAssertWaits} method is ever called in a test, the lock-like object must have a
     * method equivalent to {@link
     * java.util.concurrent.locks.ReentrantLock#hasWaiters(java.util.concurrent.locks.Condition)},
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

    import java.util.concurrent.Executor;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.Future;
    import java.util.concurrent.RejectedExecutionException;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.ScheduledFuture;
    import java.util.concurrent.ScheduledThreadPoolExecutor;
    import java.util.concurrent.ThreadFactory;
    import java.util.concurrent.ThreadPoolExecutor;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 28K bytes
    - Viewed (0)
  10. okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt

    import android.annotation.SuppressLint
    import java.util.concurrent.ThreadFactory
    import java.util.concurrent.TimeUnit
    import java.util.logging.Handler
    import java.util.logging.Level
    import java.util.logging.LogManager
    import java.util.logging.LogRecord
    import java.util.logging.Logger
    import okhttp3.internal.buildConnectionPool
    import okhttp3.internal.concurrent.TaskRunner
    import okhttp3.internal.concurrent.withLock
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri May 30 21:28:20 UTC 2025
    - 10.5K bytes
    - Viewed (0)
Back to top