Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 71 - 80 of 264 for TimeUnit (0.06 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. android/guava/src/com/google/common/util/concurrent/ForwardingBlockingQueue.java

      @CanIgnoreReturnValue // TODO(kak): consider removing this
      @Override
      public boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException {
        return delegate().offer(e, timeout, unit);
      }
    
      @CanIgnoreReturnValue // TODO(kak): consider removing this
      @Override
      public @Nullable E poll(long timeout, TimeUnit unit) throws InterruptedException {
        return delegate().poll(timeout, unit);
      }
    
      @Override
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 3K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/TestPlatform.java

    import static com.google.common.util.concurrent.FuturesTest.pseudoTimedGetUninterruptibly;
    import static com.google.common.util.concurrent.Uninterruptibles.getUninterruptibly;
    import static java.util.concurrent.TimeUnit.MILLISECONDS;
    import static java.util.concurrent.TimeUnit.SECONDS;
    import static junit.framework.Assert.assertFalse;
    import static junit.framework.Assert.fail;
    
    import com.google.common.annotations.GwtCompatible;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 2.7K bytes
    - Click Count (0)
  3. impl/maven-core/src/test/java/org/apache/maven/lifecycle/internal/builder/multithreaded/SmartProjectComparatorTest.java

    import java.util.Arrays;
    import java.util.List;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.atomic.AtomicReference;
    
    import org.apache.maven.execution.ProjectDependencyGraph;
    import org.apache.maven.lifecycle.internal.stub.ProjectDependencyGraphStub;
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Wed Aug 06 12:03:40 GMT 2025
    - 8.9K bytes
    - Click Count (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/ConnectionReuseTest.kt

        client =
          client
            .newBuilder()
            .connectionPool(ConnectionPool(0, 5, TimeUnit.SECONDS))
            .build()
        server.enqueue(
          MockResponse
            .Builder()
            .code(301)
            .addHeader("Location: /b")
            .bodyDelay(1, TimeUnit.SECONDS)
            .body("a")
            .build(),
        )
        server.enqueue(MockResponse(body = "b"))
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Jun 20 11:46:46 GMT 2025
    - 12.2K bytes
    - Click Count (1)
  5. android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

    import static java.util.concurrent.Executors.newCachedThreadPool;
    import static java.util.concurrent.Executors.newSingleThreadExecutor;
    import static java.util.concurrent.TimeUnit.MILLISECONDS;
    import static java.util.concurrent.TimeUnit.SECONDS;
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.util.concurrent.ListenableFuture;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Fri Jul 11 18:52:30 GMT 2025
    - 6.1K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/suggest/concurrent/Deferred.java

            public RESPONSE getResponse() {
                return getResponse(1, TimeUnit.MINUTES);
            }
    
            /**
             * Returns the response.
             * @param time The time to wait.
             * @param unit The time unit.
             * @return The response.
             */
            public RESPONSE getResponse(final long time, final TimeUnit unit) {
                try {
    Created: Sat Dec 20 13:04:59 GMT 2025
    - Last Modified: Fri Jul 04 14:00:23 GMT 2025
    - 7.8K bytes
    - Click Count (0)
  7. guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java

    import com.google.common.annotations.J2ktIncompatible;
    import com.google.errorprone.annotations.CanIgnoreReturnValue;
    import java.time.Duration;
    import java.util.concurrent.Executor;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    
    /**
     * Base class for services that can implement {@link #startUp}, {@link #run} and {@link #shutDown}
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Fri Jul 11 18:52:30 GMT 2025
    - 7.5K bytes
    - Click Count (0)
  8. okhttp/src/jvmTest/kotlin/okhttp3/InterceptorTest.kt

    import java.util.concurrent.BlockingQueue
    import java.util.concurrent.LinkedBlockingQueue
    import java.util.concurrent.SynchronousQueue
    import java.util.concurrent.ThreadPoolExecutor
    import java.util.concurrent.TimeUnit
    import java.util.concurrent.atomic.AtomicReference
    import kotlin.test.assertFailsWith
    import mockwebserver3.MockResponse
    import mockwebserver3.MockWebServer
    import mockwebserver3.SocketEffect.ShutdownConnection
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Nov 04 16:11:23 GMT 2025
    - 28.2K bytes
    - Click Count (0)
  9. guava/src/com/google/common/util/concurrent/ForwardingBlockingQueue.java

      @CanIgnoreReturnValue // TODO(kak): consider removing this
      @Override
      public boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException {
        return delegate().offer(e, timeout, unit);
      }
    
      @CanIgnoreReturnValue // TODO(kak): consider removing this
      @Override
      public @Nullable E poll(long timeout, TimeUnit unit) throws InterruptedException {
        return delegate().poll(timeout, unit);
      }
    
      @Override
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 3K bytes
    - Click Count (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

      /** The maximum number of idle connections across all addresses. */
      private val maxIdleConnections: Int,
      keepAliveDuration: Long,
      timeUnit: TimeUnit,
      internal val connectionListener: ConnectionListener,
    ) {
      internal val keepAliveDurationNs: Long = timeUnit.toNanos(keepAliveDuration)
    
      private val cleanupQueue: TaskQueue = taskRunner.newQueue()
      private val cleanupTask =
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Oct 08 03:50:05 GMT 2025
    - 11.1K bytes
    - Click Count (0)
Back to Top