- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 61 for Timer (0.03 sec)
-
guava-tests/test/com/google/common/collect/QueuesTest.java
producer.beganProducing.await(); // make sure we time out Stopwatch timer = Stopwatch.createStarted(); int drained = drain(q, newArrayList(), 2, 10, MILLISECONDS, interruptibly); assertThat(drained).isAtMost(1); assertThat(timer.elapsed(MILLISECONDS)).isAtLeast(10L);
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 02:42:09 UTC 2024 - 12.1K bytes - Viewed (0) -
src/main/java/org/codelibs/core/timer/TimeoutManager.java
import org.codelibs.core.log.Logger; /** * Timerを扱うクラスです。 * * @author higa * */ public class TimeoutManager implements Runnable { private static final Logger logger = Logger.getLogger(TimeoutManager.class); /** * シングルトンのためのインスタンスです。 */ protected static final TimeoutManager instance = new TimeoutManager(); /** * Timerのための{@link Thread}です。 */
Registered: Fri Nov 01 20:58:10 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/exec/SuggestCreator.java
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.helper.SuggestHelper; import org.codelibs.fess.timer.SystemMonitorTarget;
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 10K bytes - Viewed (0) -
cmd/data-scanner.go
} if maxWait > 0 && wantSleep > maxWait { wantSleep = maxWait } timer := time.NewTimer(wantSleep) select { case <-ctx.Done(): if !timer.Stop() { <-timer.C if d.isScanner { globalScannerMetrics.incTime(scannerMetricYield, wantSleep) } } return case <-timer.C: if d.isScanner { globalScannerMetrics.incTime(scannerMetricYield, wantSleep)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 22 21:10:34 UTC 2024 - 48.4K bytes - Viewed (0) -
cmd/lock-rest-server.go
lkTimer := time.NewTimer(lockMaintenanceInterval) // Stop the timer upon returning. defer lkTimer.Stop() for { // Verifies every minute for locks held more than 2 minutes. select { case <-ctx.Done(): return case <-lkTimer.C: globalLockServer.expireOldLocks(lockValidityDuration) // Reset the timer for next cycle. lkTimer.Reset(lockMaintenanceInterval) } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 5.8K bytes - Viewed (0) -
cmd/erasure-sets.go
wg.Wait() // Reset for the next interval timer.Reset(globalAPIConfig.getDeleteCleanupInterval()) } } } func (s *erasureSets) cleanupStaleUploads(ctx context.Context) { timer := time.NewTimer(globalAPIConfig.getStaleUploadsCleanupInterval()) defer timer.Stop() for { select { case <-ctx.Done(): return case <-timer.C: var wg sync.WaitGroup for _, set := range s.sets {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 27 10:41:37 UTC 2024 - 37K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/ExecJob.java
import org.apache.commons.io.FileUtils; 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.TimeoutTask; import org.codelibs.fess.Constants; import org.codelibs.fess.es.config.exentity.ScheduledJob; import org.codelibs.fess.util.ComponentUtil;
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Fri Oct 11 21:11:58 UTC 2024 - 7.7K bytes - Viewed (0) -
src/main/java/org/codelibs/core/timer/TimeoutTarget.java
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, * either express or implied. See the License for the specific language * governing permissions and limitations under the License. */ package org.codelibs.core.timer; /** * タイムアウトを処理するインターフェースです。 * * @author higa * */ @FunctionalInterface public interface TimeoutTarget { /** * タイムアウトの処理を記述します。 */ void expired();
Registered: Fri Nov 01 20:58:10 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 904 bytes - Viewed (0) -
cmd/mrf.go
// 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 if u.BitrotScan { scan = madmin.HealDeepScan } if u.Object == "" { healBucket(u.Bucket, scan) } else {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 13 22:26:05 UTC 2024 - 6.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/job/AllJobScheduler.java
*/ package org.codelibs.fess.app.job; 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.fess.Constants; import org.codelibs.fess.app.logic.AccessContextLogic; import org.codelibs.fess.app.service.ScheduledJobService; import org.codelibs.fess.es.config.exbhv.JobLogBhv;
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 3.8K bytes - Viewed (0)