Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 61 for Timer (0.04 sec)

  1. src/main/java/org/codelibs/fess/job/GenerateThumbnailJob.java

    import org.apache.commons.lang3.SystemUtils;
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.core.timer.TimeoutTask;
    import org.codelibs.fess.Constants;
    import org.codelibs.fess.exception.JobProcessingException;
    import org.codelibs.fess.exec.ThumbnailGenerator;
    import org.codelibs.fess.helper.ProcessHelper;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/job/SuggestJob.java

    import org.apache.commons.lang3.SystemUtils;
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.core.timer.TimeoutTask;
    import org.codelibs.fess.Constants;
    import org.codelibs.fess.exception.JobProcessingException;
    import org.codelibs.fess.exec.SuggestCreator;
    import org.codelibs.fess.helper.ProcessHelper;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sun Jun 23 04:13:47 UTC 2024
    - 10K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. cmd/metrics-resource.go

    	collectLocalResourceMetrics()
    
    	for {
    		select {
    		case <-GlobalContext.Done():
    			return
    		case <-metricsTimer.C:
    			collectLocalResourceMetrics()
    
    			// Reset the timer for next cycle.
    			metricsTimer.Reset(resourceMetricsCollectionInterval)
    		}
    	}
    }
    
    // minioResourceCollector is the Collector for resource metrics
    type minioResourceCollector struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 23:30:33 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  10. 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)
Back to top