Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 74 for Timer (0.04 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

        assertThat(startupTimes).hasSize(2);
        assertThat(startupTimes.get(a)).isAtLeast(150);
        // Service b startup takes at least 353 millis, but starting the timer is delayed by at least
        // 150 milliseconds. so in a perfect world the timing would be 353-150=203ms, but since either
        // of our sleep calls can be arbitrarily delayed we should just assert that there is a time
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 25.5K bytes
    - Viewed (0)
  2. cmd/erasure-multipart.go

    					if err == nil {
    						modTime = time.Unix(0, t)
    					}
    				}
    			}
    			// Fallback for older uploads without time in the ID.
    			if modTime.IsZero() {
    				wait := deleteMultipartCleanupSleeper.Timer(ctx)
    				fi, err := disk.ReadVersion(ctx, "", minioMetaMultipartBucket, uploadIDPath, "", ReadOptions{})
    				if err != nil {
    					return nil
    				}
    				modTime = fi.ModTime
    				wait()
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

            setState(finalState);
            return true;
          }
    
          /**
           * Blocks until the task is complete or the timeout expires. Throws a {@link TimeoutException}
           * if the timer expires, otherwise behaves like {@link #get()}.
           */
          V get(long nanos)
              throws TimeoutException, CancellationException, ExecutionException, InterruptedException {
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  4. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/HcHttpClient.java

    import org.codelibs.core.io.CloseableUtil;
    import org.codelibs.core.io.CopyUtil;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.core.misc.Pair;
    import org.codelibs.core.timer.TimeoutManager;
    import org.codelibs.core.timer.TimeoutTask;
    import org.codelibs.fess.crawler.Constants;
    import org.codelibs.fess.crawler.CrawlerContext;
    import org.codelibs.fess.crawler.client.AbstractCrawlerClient;
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu May 09 09:29:26 UTC 2024
    - 41K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

         */
        ServiceManagerState(ImmutableCollection<Service> services) {
          this.numberOfServices = services.size();
          servicesByState.putAll(NEW, services);
        }
    
        /**
         * Attempts to start the timer immediately prior to the service being started via {@link
         * Service#startAsync()}.
         */
        void tryStartTiming(Service service) {
          monitor.enter();
          try {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.5K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/ServiceManager.java

         */
        ServiceManagerState(ImmutableCollection<Service> services) {
          this.numberOfServices = services.size();
          servicesByState.putAll(NEW, services);
        }
    
        /**
         * Attempts to start the timer immediately prior to the service being started via {@link
         * Service#startAsync()}.
         */
        void tryStartTiming(Service service) {
          monitor.enter();
          try {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  7. common-protos/k8s.io/api/batch/v1/generated.proto

      // may be continuously active before the system tries to terminate it; value
      // must be positive integer. If a Job is suspended (at creation or through an
      // update), this timer will effectively be stopped and reset when the Job is
      // resumed again.
      // +optional
      optional int64 activeDeadlineSeconds = 3;
    
      // Specifies the policy of handling failed pods. In particular, it allows to
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 21.1K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/core/io/FileUtil.java

    import java.nio.charset.Charset;
    import java.nio.file.Files;
    
    import org.codelibs.core.exception.IORuntimeException;
    import org.codelibs.core.net.URLUtil;
    import org.codelibs.core.nio.ChannelUtil;
    import org.codelibs.core.timer.TimeoutManager;
    
    /**
     * {@link File}を扱うユーティリティ・クラスです。
     *
     * @author higa
     */
    public abstract class FileUtil {
    
        /** UTF-8のエンコーディング名 */
        private static final String UTF8 = "UTF-8";
    
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 9K bytes
    - Viewed (0)
  9. cmd/iam.go

    		randAmt := time.Duration(r.Float64() * float64(baseInterval))
    		return baseInterval/2 + randAmt
    	}
    
    	timer := time.NewTimer(waitInterval())
    	defer timer.Stop()
    
    	lastPurgeHour := -1
    	for {
    		select {
    		case <-timer.C:
    			// Load all IAM items (except STS creds) periodically.
    			refreshStart := time.Now()
    			if err := sys.Load(ctx, false); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 29 16:01:48 UTC 2024
    - 74.6K bytes
    - Viewed (0)
  10. cmd/erasure.go

    				w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout())
    				return w.Run(func() error {
    					wait := deleteCleanupSleeper.Timer(ctx)
    					removeAll(pathJoin(drivePath, minioMetaTmpDeletedBucket, ddir))
    					wait()
    					return nil
    				})
    			})
    		}(disk)
    	}
    	wg.Wait()
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 16.1K bytes
    - Viewed (0)
Back to top