- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,107 for schedules (0.11 sec)
-
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/eventclock/real.go
type Real struct { clock.RealClock } var _ Interface = Real{} // EventAfterDuration schedules an EventFunc func (Real) EventAfterDuration(f EventFunc, d time.Duration) { ch := time.After(d) go func() { t := <-ch f(t) }() } // EventAfterTime schedules an EventFunc func (r Real) EventAfterTime(f EventFunc, t time.Time) { r.EventAfterDuration(f, time.Until(t))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Aug 07 04:07:31 UTC 2021 - 1K bytes - Viewed (0) -
pkg/controller/cronjob/utils.go
} t := schedule.Next(*mostRecentTime).Add(nextScheduleDelta).Sub(now) return &t } // nextScheduleTime returns the time.Time of the next schedule after the last scheduled // and before now, or nil if no unmet schedule times, and an error. // If there are too many (>100) unstarted times, it will also record a warning.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 10.7K 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)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 23K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/buildtree/BuildTreeLifecycleController.java
*/ <T> T withEmptyBuild(Function<? super SettingsInternal, T> action); /** * Schedules the work graph for the tasks specified in the {@link org.gradle.StartParameter} associated with the build, runs the scheduled work and finishes up the build. * When this method returns, all user code will have completed, including 'build finished' hooks. *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 02 00:39:25 UTC 2022 - 2.9K bytes - Viewed (0) -
platforms/core-configuration/kotlin-dsl/src/main/kotlin/org/gradle/kotlin/dsl/concurrent/IO.kt
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 01 13:09:45 UTC 2024 - 2.3K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/build/BuildWorkGraph.java
import java.util.Collection; import java.util.function.BiConsumer; import java.util.function.Consumer; public interface BuildWorkGraph extends Stoppable { /** * Schedules the given tasks and all of their dependencies in this work graph. */ boolean schedule(Collection<ExportedTaskNode> taskNodes); /** * Adds tasks and other nodes to this work graph. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 31 05:15:28 UTC 2023 - 1.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/testing/eventclock/fake.go
// GetNextTime returns the next time at which there is work scheduled, // and a bool indicating whether there is any such time func (fec *Fake) GetNextTime() (time.Time, bool) { fec.waitersLock.RLock() defer fec.waitersLock.RUnlock() if len(fec.waiters) > 0 { return fec.waiters[0].targetTime, true } return time.Time{}, false } // Run runs all the events scheduled, and all the events they
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Dec 18 04:27:38 UTC 2022 - 7.9K bytes - Viewed (0) -
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;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Dec 13 19:45:20 UTC 2023 - 27.5K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/composite/internal/BuildController.java
/** * Queues the given task for execution. Does not schedule the task, use {@link #scheduleQueuedTasks()} for this. */ void queueForExecution(ExportedTaskNode taskNode); /** * Schedules any queued tasks. When this method returns true, then some tasks where scheduled for this build and
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 31 05:15:28 UTC 2023 - 2.5K bytes - Viewed (0) -
subprojects/composite-builds/src/integTest/groovy/org/gradle/integtests/composite/CompositeBuildTaskLifecycleIntegrationTest.groovy
assertTaskExecuted(':', ':a') assertTaskNotExecuted(':buildB', ':c') where: method << ["shouldRunAfter", "mustRunAfter"] } def "finalizedBy task within included build schedules finalizer for execution"() { given: buildA.buildFile << """ task a { dependsOn gradle.includedBuild('buildB').task(':b') } """
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Aug 03 19:28:39 UTC 2022 - 3K bytes - Viewed (0)