- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 99 for schedule (0.19 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
// If the task is already scheduled, take the earlier of the two times. val existingIndex = futureTasks.indexOf(task) if (existingIndex != -1) { if (task.nextExecuteNanoTime <= executeNanoTime) { taskRunner.logger.taskLog(task, this) { "already scheduled" } return false } futureTasks.removeAt(existingIndex) // Already scheduled later: reschedule below! }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerRealBackendTest.kt
} @Test fun taskFailsWithUncheckedException() { queue.schedule("task", TimeUnit.MILLISECONDS.toNanos(100)) { log.put("failing task running") throw RuntimeException("boom!") } queue.schedule("task", TimeUnit.MILLISECONDS.toNanos(200)) { log.put("normal task running") return@schedule -1L } queue.idleLatch().await(500, TimeUnit.MILLISECONDS)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.5K bytes - Viewed (0) -
.github/dependabot.yml
Others - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Mar 29 17:59:22 GMT 2021 - 440 bytes - Viewed (0) -
.github/dependabot.yml
--- version: 2 updates: - package-ecosystem: gomod directory: / schedule: interval: weekly - package-ecosystem: github-actions directory: / schedule: interval: weekly - package-ecosystem: gomod directory: /tests schedule:
Others - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Mon Aug 09 05:16:25 GMT 2021 - 287 bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/Task.kt
* ---------- * * Tasks control their recurrence schedule. The [runOnce] function returns -1L to signify that the * task should not be executed again. Otherwise it returns a delay until the next execution. * * A task has at most one next execution. If the same task instance is scheduled multiple times, the * earliest one wins. This applies to both executions scheduled with [TaskRunner.Queue.schedule] and * those implied by the returned execution delay.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/WrappingScheduledExecutorService.java
} @Override public final ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) { return delegate.schedule(wrapTask(command), delay, unit); } @Override public final <V extends @Nullable Object> ScheduledFuture<V> schedule( Callable<V> task, long delay, TimeUnit unit) { return delegate.schedule(wrapTask(task), delay, unit); } @Override
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 2.4K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java
return new NoOpScheduledExecutorService(); } /** * Creates a scheduled executor service that runs each task in the thread that invokes {@code * execute/submit/schedule}, as in {@link CallerRunsPolicy}. This applies both to individually * submitted tasks and to collections of tasks submitted via {@code invokeAll}, {@code invokeAny}, * {@code schedule}, {@code scheduleAtFixedRate}, and {@code scheduleWithFixedDelay}. In the case
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Fri May 26 22:04:00 GMT 2023 - 6.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ListeningScheduledExecutorServiceTest.java
@Override public ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) { recordedCommand = command; recordedDelay = delay; recordedTimeUnit = unit; return ImmediateScheduledFuture.of("schedule"); } @Override public <V> ListenableScheduledFuture<V> schedule( Callable<V> callable, long delay, TimeUnit unit) {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Mar 17 20:45:59 GMT 2020 - 6.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/job/AllJobScheduler.java
logger.debug("Updating scheduled jobs. time:{}", schedulerTime); } final long now = systemHelper.getCurrentTimeAsLong(); scheduledJobService.getScheduledJobListAfter(schedulerTime).forEach(scheduledJob -> { if (logger.isDebugEnabled()) { logger.debug("Updating job schedule:{}", scheduledJob.getName()); } try {
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 3.8K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java
@Override public ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) { Preconditions.checkNotNull(command, "command must not be null"); Preconditions.checkNotNull(unit, "unit must not be null!"); return schedule(java.util.concurrent.Executors.callable(command), delay, unit); } @Override public <V> ListenableScheduledFuture<V> schedule(
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Oct 06 00:47:57 GMT 2021 - 6.4K bytes - Viewed (0)