Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 31 - 40 of 264 for TimeUnit (0.06 seconds)

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

  1. guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

        Preconditions.checkNotNull(command, "command must not be null");
        Preconditions.checkNotNull(unit, "unit must not be null!");
        return schedule(callable(command), delay, unit);
      }
    
      @Override
      public <V> ListenableScheduledFuture<V> schedule(
          Callable<V> callable, long delay, TimeUnit unit) {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:37:28 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  2. src/test/java/org/codelibs/fess/suggest/concurrent/DeferredTest.java

    import static org.junit.Assert.assertEquals;
    import static org.junit.Assert.assertTrue;
    import static org.junit.Assert.fail;
    
    import java.util.Collections;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.TimeUnit;
    
    import org.codelibs.fess.suggest.exception.SuggesterException;
    import org.codelibs.fess.suggest.request.suggest.SuggestResponse;
    import org.junit.Test;
    
    public class DeferredTest {
        @Test
    Created: Sat Dec 20 13:04:59 GMT 2025
    - Last Modified: Sat Mar 15 06:51:20 GMT 2025
    - 4.8K bytes
    - Click Count (0)
  3. guava/src/com/google/common/util/concurrent/MoreExecutors.java

        }
    
        final ScheduledExecutorService getExitingScheduledExecutorService(
            ScheduledThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) {
          useDaemonThreadFactory(executor);
          ScheduledExecutorService service = unconfigurableScheduledExecutorService(executor);
          addDelayedShutdownHook(executor, terminationTimeout, timeUnit);
          return service;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Oct 08 18:55:33 GMT 2025
    - 45.2K bytes
    - Click Count (0)
  4. samples/guide/src/main/java/okhttp3/recipes/kt/ConfigureTimeouts.kt

    package okhttp3.recipes.kt
    
    import java.util.concurrent.TimeUnit
    import okhttp3.OkHttpClient
    import okhttp3.Request
    
    class ConfigureTimeouts {
      private val client: OkHttpClient =
        OkHttpClient
          .Builder()
          .connectTimeout(5, TimeUnit.SECONDS)
          .writeTimeout(5, TimeUnit.SECONDS)
          .readTimeout(5, TimeUnit.SECONDS)
          .callTimeout(10, TimeUnit.SECONDS)
          .build()
    
      fun run() {
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 1.3K bytes
    - Click Count (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/internal/UtilTest.kt

      }
    
      @Test
      fun testDurationTimeUnit() {
        assertThat(checkDuration("timeout", 0, TimeUnit.MILLISECONDS)).isEqualTo(0)
        assertThat(checkDuration("timeout", 1, TimeUnit.MILLISECONDS)).isEqualTo(1)
    
        assertThat(
          assertThrows<IllegalStateException> {
            checkDuration("timeout", -1, TimeUnit.MILLISECONDS)
          },
        ).hasMessage("timeout < 0")
        assertThat(
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Dec 27 13:39:56 GMT 2024
    - 3K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/util/concurrent/DirectExecutorService.java

    package com.google.common.util.concurrent;
    
    import static java.util.concurrent.TimeUnit.NANOSECONDS;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.collect.ImmutableList;
    import com.google.errorprone.annotations.concurrent.GuardedBy;
    import java.util.List;
    import java.util.concurrent.RejectedExecutionException;
    import java.util.concurrent.TimeUnit;
    
    /** See newDirectExecutorService javadoc for behavioral notes. */
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Dec 16 14:23:59 GMT 2025
    - 3.4K bytes
    - Click Count (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/CacheCorruptionTest.kt

                "Last-Modified",
                formatDate(-1, TimeUnit.HOURS)!!,
                "Expires",
                formatDate(1, TimeUnit.HOURS)!!,
              ),
            body = "ABC.1",
          ),
        )
        server.enqueue(
          MockResponse(
            headers =
              headersOf(
                "Last-Modified",
                formatDate(-1, TimeUnit.HOURS)!!,
                "Expires",
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Jun 18 12:28:21 GMT 2025
    - 6K bytes
    - Click Count (0)
  8. src/main/java/jcifs/internal/smb2/lease/DirectoryLeaseManager.java

    import java.util.List;
    import java.util.Map;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.Executors;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.TimeUnit;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    import jcifs.CIFSContext;
    import jcifs.Configuration;
    import jcifs.smb.SmbFile;
    
    /**
     * Manager for directory leases and caching
     */
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 23 01:47:47 GMT 2025
    - 12.3K bytes
    - Click Count (0)
  9. mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/KotlinSourceModernTest.kt

        mockResponse = mockResponse.throttleBody(0L, 0L, TimeUnit.SECONDS)
        var throttleBytesPerPeriod: Long = mockResponse.throttleBytesPerPeriod
        throttleBytesPerPeriod = mockResponse.throttleBytesPerPeriod
        var throttlePeriod: Long = mockResponse.getThrottlePeriod(TimeUnit.SECONDS)
        mockResponse = mockResponse.setBodyDelay(0L, TimeUnit.SECONDS)
        val bodyDelay: Long = mockResponse.getBodyDelay(TimeUnit.SECONDS)
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 7.3K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/util/concurrent/ListeningScheduledExecutorService.java

       */
      @Override
      ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit);
    
      /**
       * @since 15.0 (previously returned ScheduledFuture)
       */
      @Override
      <V extends @Nullable Object> ListenableScheduledFuture<V> schedule(
          Callable<V> callable, long delay, TimeUnit unit);
    
      /**
       * @since 15.0 (previously returned ScheduledFuture)
       */
      @Override
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Feb 11 17:30:04 GMT 2025
    - 2.1K bytes
    - Click Count (0)
Back to Top