- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,106 for schedular (0.7 sec)
-
pkg/scheduler/scheduler.go
frameworkruntime "k8s.io/kubernetes/pkg/scheduler/framework/runtime" internalcache "k8s.io/kubernetes/pkg/scheduler/internal/cache" cachedebugger "k8s.io/kubernetes/pkg/scheduler/internal/cache/debugger" internalqueue "k8s.io/kubernetes/pkg/scheduler/internal/queue" "k8s.io/kubernetes/pkg/scheduler/metrics" "k8s.io/kubernetes/pkg/scheduler/profile" ) const ( // Duration the scheduler will wait before expiring an assumed pod.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 20.8K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/schedule.go
return true } return false } // Schedule the Values in each Block. After this phase returns, the // order of b.Values matters and is the order in which those values // will appear in the assembly output. For now it generates a // reasonable valid schedule using a priority queue. TODO(khr): // schedule smarter. func schedule(f *Func) { // reusable priority queue priq := new(ValHeap)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 08 15:53:17 UTC 2024 - 16.4K bytes - Viewed (0) -
src/runtime/mprof.go
return } // saveg calls gentraceback, which may call cgo traceback functions. When // called from the scheduler, this is on the system stack already so // traceback.go:cgoContextPCs will avoid calling back into the scheduler. // // When called from the goroutine coordinating the profile, we still have // set gp1.goroutineProfiled to goroutineProfileInProgress and so are still
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 53.3K 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) -
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;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Dec 13 19:45:20 UTC 2023 - 25.8K bytes - Viewed (0) -
cmd/kube-scheduler/scheduler.go
_ "k8s.io/component-base/metrics/prometheus/clientgo" _ "k8s.io/component-base/metrics/prometheus/version" // for version metric registration "k8s.io/kubernetes/cmd/kube-scheduler/app" ) func main() { command := app.NewSchedulerCommand() code := cli.Run(command) os.Exit(code)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 30 11:46:49 UTC 2021 - 998 bytes - Viewed (0) -
cluster/gce/manifests/kube-scheduler.manifest
{ "apiVersion": "v1", "kind": "Pod", "metadata": { "name":"kube-scheduler", "namespace": "kube-system", "labels": { "tier": "control-plane", "component": "kube-scheduler" } }, "spec":{ "securityContext": { "seccompProfile": { "type": "RuntimeDefault" }, "runAsUser": {{runAsUser}}, "runAsGroup": {{runAsGroup}} }, "priorityClassName": "system-node-critical", "priority": 2000001000,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 14 20:50:53 UTC 2021 - 1.8K bytes - Viewed (0) -
.github/workflows/osv-scanner-scheduled.yml
name: OSV-Scanner Scheduled Scan on: schedule: - cron: 0 4 * * 1 permissions: # Require writing security events to upload SARIF file to security tab security-events: write # Only need to read contents contents: read jobs: scan-scheduled: if: github.repository == 'tensorflow/tensorflow'
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Feb 06 17:09:49 UTC 2024 - 1.6K 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) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java
} } }; TestCustomScheduler scheduler = new TestCustomScheduler(); Cancellable future = scheduler.schedule(null, Executors.newScheduledThreadPool(10), task); firstBarrier.await(); assertEquals(1, scheduler.scheduleCounter.get()); secondBarrier.await(); firstBarrier.await(); assertEquals(2, scheduler.scheduleCounter.get()); shouldWait.set(false);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 22.5K bytes - Viewed (0)