- Sort Score
- Num 10 results
- Language All
Results 91 - 100 of 257 for scheduled (0.16 seconds)
-
android/guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java
} }; TestCustomScheduler scheduler = new TestCustomScheduler(); Cancellable future = scheduler.schedule(null, newScheduledThreadPool(10), task); firstBarrier.await(); assertEquals(1, scheduler.scheduleCounter.get()); secondBarrier.await(); firstBarrier.await(); assertEquals(2, scheduler.scheduleCounter.get()); shouldWait.set(false); secondBarrier.await();Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 22.8K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java
} }; TestCustomScheduler scheduler = new TestCustomScheduler(); Cancellable future = scheduler.schedule(null, newScheduledThreadPool(10), task); firstBarrier.await(); assertEquals(1, scheduler.scheduleCounter.get()); secondBarrier.await(); firstBarrier.await(); assertEquals(2, scheduler.scheduleCounter.get()); shouldWait.set(false); secondBarrier.await();Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 22.8K bytes - Click Count (0) -
CHANGELOG/CHANGELOG-1.7.md
- [Load Balancing](#load-balancing) - [**Node Components**](#node-components) - [Container Runtime Interface](#container-runtime-interface) - [**Scheduling**](#scheduling-1) - [Scheduler Extender](#scheduler-extender) - [**Storage**](#storage-1) - [Local Storage](#local-storage) - [Volume Plugins](#volume-plugins) - [Metrics](#metrics)Created: Fri Apr 03 09:05:14 GMT 2026 - Last Modified: Thu May 05 13:44:43 GMT 2022 - 308.7K bytes - Click Count (1) -
CHANGELOG/CHANGELOG-1.23.md
- Migrate `pkg/scheduler/framework/plugins/interpodaffinity/filtering.go`,`pkg/scheduler/framework/plugins/podtopologyspread/filtering.go`, `pkg/scheduler/framework/plugins/volumezone/volume_zone.go` to structured logging (#105931, @mengjiao-liu) [SIG Instrumentation and Scheduling]
Created: Fri Apr 03 09:05:14 GMT 2026 - Last Modified: Tue Feb 28 21:06:52 GMT 2023 - 424.5K bytes - Click Count (0) -
CHANGELOG/CHANGELOG-1.8.md
* Fix metrics API group name in audit configuration ([#53493](https://github.com/kubernetes/kubernetes/pull/53493), [@piosz](https://github.com/piosz)) * Use separate client for leader election in scheduler to avoid starving leader election by regular scheduler operations. ([#53793](https://github.com/kubernetes/kubernetes/pull/53793), [@wojtek-t](https://github.com/wojtek-t))
Created: Fri Apr 03 09:05:14 GMT 2026 - Last Modified: Tue Feb 20 15:45:02 GMT 2024 - 312.2K bytes - Click Count (0) -
CHANGELOG/CHANGELOG-1.16.md
- kube-scheduler - Migrate scheduler to use v1beta1 Event API. any tool targeting scheduler events needs to use v1beta1 Event API ([#78447](https://github.com/kubernetes/kubernetes/pull/78447), [@yastij](https://github.com/yastij)) - kubeadm
Created: Fri Apr 03 09:05:14 GMT 2026 - Last Modified: Wed Oct 23 20:13:20 GMT 2024 - 345.2K bytes - Click Count (0) -
src/main/java/jcifs/internal/witness/WitnessClient.java
this.asyncNotifyTasks = new ConcurrentHashMap<>(); this.scheduler = Executors.newScheduledThreadPool(3); // Increased for async notifications this.rpcClient = rpcClient; // Schedule periodic tasks schedulePeriodicTasks(); } /** * Schedules periodic tasks for heartbeat and registration monitoring. */
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 20.8K bytes - Click Count (0) -
docs/smb3-features/06-witness-protocol-design.md
this.listeners = new ConcurrentHashMap<>(); this.scheduler = Executors.newScheduledThreadPool(2); this.rpcClient = new WitnessRpcClient(witnessServer, context); // Schedule periodic tasks schedulePeriodicTasks(); } private void schedulePeriodicTasks() { // Heartbeat monitoring scheduler.scheduleAtFixedRate(this::checkHeartbeats, 30, 30, TimeUnit.SECONDS);
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 02:53:50 GMT 2025 - 42K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/it/CrawlTestBase.java
final String schedulerId = getSchedulerIds(namePrefix).get(0); final Response response = checkMethodBase(requestBody).put("/api/admin/scheduler/" + schedulerId + "/start"); if (response.getBody().jsonPath().getInt("response.status") == 0) { logger.info("Start scheduler \"{}\"", schedulerId); return; }
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sun Jan 11 08:43:05 GMT 2026 - 10.6K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/multichannel/ChannelManager.java
this.channelCounter = new AtomicInteger(0); this.multiChannelEnabled = false; // Schedule periodic health checks scheduler.scheduleAtFixedRate(this::performHealthCheck, 10, 10, TimeUnit.SECONDS); // Schedule interface discovery scheduler.scheduleAtFixedRate(this::discoverInterfaces, 0, 30, TimeUnit.SECONDS); } /** * Initialize multi-channel support
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 21 11:13:46 GMT 2025 - 20K bytes - Click Count (0)