Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 915 for timer (0.16 sec)

  1. doc/next/6-stdlib/1-time.md

    ### Timer changes
    
    Go 1.23 makes two significant changes to the implementation of
    [time.Timer] and [time.Ticker].
    
    First, `Timer`s and `Ticker`s that are no longer referred to by the program
    become eligible for garbage collection immediately, even if their
    `Stop` methods have not been called.
    Earlier versions of Go did not collect unstopped `Timer`s until after
    they had fired and never collected unstopped `Ticker`s.
    
    Plain Text
    - Registered: Tue May 07 11:14:38 GMT 2024
    - Last Modified: Fri Apr 12 20:57:18 GMT 2024
    - 1.5K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

        Future<?> localTimer = timer;
        // Try to cancel the timer as an optimization.
        // timer may be null if this call to run was by the timer task since there is no happens-before
        // edge between the assignment to timer and an execution of the timer task.
        if (localTimer != null) {
          localTimer.cancel(false);
        }
    
        delegateRef = null;
        timer = null;
      }
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 7.7K bytes
    - Viewed (0)
  3. internal/http/server.go

    				_ = pprof.Lookup("goroutine").WriteTo(tmp, 1)
    				tmp.Close()
    				return errors.New("timed out. some connections are still active. goroutines written to " + tmp.Name())
    			}
    			return errors.New("timed out. some connections are still active")
    		case <-timer.C:
    			if atomic.LoadInt32(&srv.requestCount) <= 0 {
    				return nil
    			}
    			timer.Reset(nextPollInterval())
    		}
    	}
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 09 21:25:16 GMT 2024
    - 7.7K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/exec/ThumbnailGenerator.java

    import org.codelibs.core.misc.DynamicProperties;
    import org.codelibs.core.timer.TimeoutManager;
    import org.codelibs.core.timer.TimeoutTask;
    import org.codelibs.fess.Constants;
    import org.codelibs.fess.crawler.client.FesenClient;
    import org.codelibs.fess.es.client.SearchEngineClient;
    import org.codelibs.fess.exception.ContainerNotAvailableException;
    import org.codelibs.fess.timer.SystemMonitorTarget;
    import org.codelibs.fess.util.ComponentUtil;
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 8.2K bytes
    - Viewed (0)
  5. cmd/data-scanner.go

    		d.mu.RUnlock()
    		// Don't sleep for really small amount of time
    		wantSleep := time.Duration(float64(base) * factor)
    		if wantSleep <= minWait {
    			return
    		}
    		if maxWait > 0 && wantSleep > maxWait {
    			wantSleep = maxWait
    		}
    		timer := time.NewTimer(wantSleep)
    		select {
    		case <-ctx.Done():
    			if !timer.Stop() {
    				<-timer.C
    				if d.isScanner {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 11:18:58 GMT 2024
    - 47.6K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/helper/JobHelper.java

    import java.util.Map;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.core.timer.TimeoutManager;
    import org.codelibs.core.timer.TimeoutTarget;
    import org.codelibs.core.timer.TimeoutTask;
    import org.codelibs.fess.Constants;
    import org.codelibs.fess.es.config.exbhv.JobLogBhv;
    import org.codelibs.fess.es.config.exbhv.ScheduledJobBhv;
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 8.1K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/thumbnail/impl/CommandGenerator.java

        protected File baseDir;
    
        private Timer destoryTimer;
    
        @PostConstruct
        public void init() {
            if (logger.isDebugEnabled()) {
                logger.debug("Initialize {}", this.getClass().getSimpleName());
            }
            if (baseDir == null) {
                baseDir = new File(System.getProperty("java.io.tmpdir"));
            }
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 9.6K bytes
    - Viewed (0)
  8. doc/godebug.md

    ### Go 1.23
    
    Go 1.23 changed the channels created by package time to be unbuffered
    (synchronous), which makes correct use of the [`Timer.Stop`](/pkg/time/#Timer.Stop)
    and [`Timer.Reset`](/pkg/time/#Timer.Reset) method results much easier.
    The [`asynctimerchan` setting](/pkg/time/#NewTimer) disables this change.
    There are no runtime metrics for this change,
    Plain Text
    - Registered: Tue May 07 11:14:38 GMT 2024
    - Last Modified: Tue Apr 16 17:29:58 GMT 2024
    - 13.5K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/exec/SuggestCreator.java

        }
    
        private int purge(final LocalDateTime time) {
            final SuggestHelper suggestHelper = ComponentUtil.getSuggestHelper();
    
            try {
                suggestHelper.purgeDocumentSuggest(time);
                final long cleanupDay = ComponentUtil.getFessConfig().getPurgeSuggestSearchLogDay();
                if (cleanupDay > 0) {
                    suggestHelper.purgeSearchlogSuggest(time.minusDays(cleanupDay));
                }
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 10K bytes
    - Viewed (0)
  10. cmd/mrf.go

    					continue
    				}
    			}
    
    			now := time.Now()
    			if now.Sub(u.queued) < time.Second {
    				// let recently failed networks to reconnect
    				// making MRF wait for 1s before retrying,
    				// i.e 4 reconnect attempts.
    				time.Sleep(time.Second)
    			}
    
    			// wait on timer per heal
    			wait := healSleeper.Timer(context.Background())
    
    			scan := madmin.HealNormalScan
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 3.2K bytes
    - Viewed (0)
Back to top