- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 133 for schedule (0.2 sec)
-
android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
private ScheduledFuture<@Nullable Void> submitToExecutor(Schedule schedule) { return executor.schedule(this, schedule.delay, schedule.unit); } } /** * Contains the most recently submitted {@code Future}, which may be cancelled or updated, * always under a lock. */ private static final class SupplantableFuture implements Cancellable { private final ReentrantLock lock;
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 25.8K bytes - Viewed (0) -
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/TaskRunnerTest.kt
object : Task("task one") { val schedules = mutableListOf(200.µs) override fun runOnce(): Long { if (schedules.isNotEmpty()) { redQueue.schedule(this, schedules.removeAt(0)) // Add it at the end also. } log += "scheduledTasks=${redQueue.scheduledTasks}" return -1L } } redQueue.schedule(task, 100.µs)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 23K 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) -
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) -
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) -
.github/workflows/arm-ci-extended.yml
# limitations under the License. # ============================================================================== name: ARM CI Extended on: push: tags: - v2.** schedule: - cron: '0 4 * * *' permissions: contents: read jobs: build: if: github.repository == 'tensorflow/tensorflow' # Don't do this in forks runs-on: [self-hosted, linux, ARM64] strategy:
Others - Registered: Tue May 07 12:40:20 GMT 2024 - Last Modified: Tue Mar 05 10:24:16 GMT 2024 - 2.6K bytes - Viewed (0) -
.github/workflows/arm-cd.yml
- name: Upload pip wheel to PyPI if: github.event_name == 'schedule' || (github.event_name == 'push' && startsWith(github.ref, 'refs/tags/v2')) # only if it is a scheduled nightly or tagged shell: bash
Others - Registered: Tue May 07 12:40:20 GMT 2024 - Last Modified: Tue Mar 05 10:24:16 GMT 2024 - 3K bytes - Viewed (1) -
android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java
* addListener/SES.schedule. The later racy write in cancel() is not guaranteed to be observed, * however that is fine since the correctness is based on the atomic state in our base class. The * initial write to timer is never definitely visible to Fire.run since it is assigned after * SES.schedule is called. Therefore Fire.run has to check for null. However, it should be visible
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) -
common-protos/k8s.io/api/batch/v1beta1/generated.proto
} // CronJobSpec describes how the job execution will look like and when it will actually run. message CronJobSpec { // The schedule in Cron format, see https://en.wikipedia.org/wiki/Cron. optional string schedule = 1; // The time zone name for the given schedule, see https://en.wikipedia.org/wiki/List_of_tz_database_time_zones. // If not specified, this will default to the time zone of the kube-controller-manager process.
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 5.7K bytes - Viewed (0)