Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 389 for Duration (0.11 sec)

  1. guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java

    import com.google.common.annotations.GwtIncompatible;
    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;
    
    /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 13:00:28 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/ServiceManager.java

       *     by startup time.
       * @since 31.0 (but only since 33.4.0 in the Android flavor)
       */
      @J2ObjCIncompatible
      public ImmutableMap<Service, Duration> startupDurations() {
        return ImmutableMap.copyOf(
            Maps.<Service, Long, Duration>transformValues(startupTimes(), Duration::ofMillis));
      }
    
      @Override
      public String toString() {
        return MoreObjects.toStringHelper(ServiceManager.class)
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/CallKotlinTest.kt

        proxySelector.proxies.add(Proxy.NO_PROXY)
        server.shutdown()
    
        client =
          client.newBuilder()
            .proxySelector(proxySelector)
            .readTimeout(Duration.ofMillis(100))
            .connectTimeout(Duration.ofMillis(100))
            .build()
    
        val request = Request(server.url("/"))
        assertFailsWith<IOException> {
          client.newCall(request).execute()
        }.also { expected ->
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

      }
    
      /** Determines whether the given method takes a Duration as its last parameter. */
      private static boolean isDurationBased(Method method) {
        Class<?>[] parameterTypes = method.getParameterTypes();
        return parameterTypes.length >= 1
            && parameterTypes[parameterTypes.length - 1] == Duration.class;
      }
    
      /** Determines whether the given method returns a boolean value. */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:18:12 UTC 2024
    - 27.1K bytes
    - Viewed (0)
  5. common-protos/k8s.io/apimachinery/pkg/apis/testapigroup/v1/generated.proto

      // +optional
      optional string restartPolicy = 3;
    
      // Optional duration in seconds the carp needs to terminate gracefully. May be decreased in delete request.
      // Value must be non-negative integer. The value zero indicates delete immediately.
      // If this value is nil, the default grace period will be used instead.
      // The grace period is the duration in seconds after the processes running in the carp are sent
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

      }
    
      /** Determines whether the given method takes a Duration as its last parameter. */
      private static boolean isDurationBased(Method method) {
        Class<?>[] parameterTypes = method.getParameterTypes();
        return parameterTypes.length >= 1
            && parameterTypes[parameterTypes.length - 1] == Duration.class;
      }
    
      /** Determines whether the given method returns a boolean value. */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 27.1K bytes
    - Viewed (0)
  7. internal/ioutil/ioutil.go

    }
    
    // DeadlineWorker implements the deadline/timeout resiliency pattern.
    type DeadlineWorker struct {
    	timeout time.Duration
    }
    
    // NewDeadlineWorker constructs a new DeadlineWorker with the given timeout.
    // To return values, use the WithDeadline helper instead.
    func NewDeadlineWorker(timeout time.Duration) *DeadlineWorker {
    	dw := &DeadlineWorker{
    		timeout: timeout,
    	}
    	return dw
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  8. doc/next/6-stdlib/99-minor/testing/62516.md

    The new [T.Chdir] and [B.Chdir] methods can be used to change the working
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Aug 20 16:48:51 UTC 2024
    - 125 bytes
    - Viewed (0)
  9. cmd/globals.go

    	Interface                 string
    
    	RootUser, RootPwd string
    
    	FTP  []string
    	SFTP []string
    
    	MemLimit uint64
    
    	UserTimeout         time.Duration
    	IdleTimeout         time.Duration
    	ReadHeaderTimeout   time.Duration
    	MaxIdleConnsPerHost int
    
    	SendBufSize, RecvBufSize int
    	CrossDomainXML           string
    	// The layout of disks as interpreted
    	Layout disksLayout
    }
    
    var (
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  10. cmd/batch-rotate.go

    		}
    	}
    	return nil
    }
    
    // BatchKeyRotateFilter holds all the filters currently supported for batch replication
    type BatchKeyRotateFilter struct {
    	NewerThan     time.Duration `yaml:"newerThan,omitempty" json:"newerThan"`
    	OlderThan     time.Duration `yaml:"olderThan,omitempty" json:"olderThan"`
    	CreatedAfter  time.Time     `yaml:"createdAfter,omitempty" json:"createdAfter"`
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 14.7K bytes
    - Viewed (0)
Back to top