Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 64 for Schedules (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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;
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Aug 09 01:14:59 GMT 2025
    - 27.7K bytes
    - Click Count (0)
  2. okhttp/src/jvmTest/kotlin/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)
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Feb 03 22:17:59 GMT 2026
    - 23K bytes
    - Click Count (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java

          // use a bunch of threads so that weird overlapping schedules are more likely to happen.
          return newScheduledThreadPool(10);
        }
    
        @Override
        protected Scheduler scheduler() {
          return new CustomScheduler() {
            @Override
            protected Schedule getNextSchedule() throws Exception {
              return new Schedule(DELAY, UNIT);
            }
          };
        }
      }
    
    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)
  4. guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java

          // use a bunch of threads so that weird overlapping schedules are more likely to happen.
          return newScheduledThreadPool(10);
        }
    
        @Override
        protected Scheduler scheduler() {
          return new CustomScheduler() {
            @Override
            protected Schedule getNextSchedule() throws Exception {
              return new Schedule(DELAY, UNIT);
            }
          };
        }
      }
    
    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)
  5. 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)
  6. cmd/prepare-storage.go

    		go removeAll(file)
    	}
    
    	// Remove the entire folder in case there are leftovers that didn't get cleaned up before restart.
    	go removeAll(pathJoin(diskPath, minioMetaTmpBucket+"-old"))
    
    	// Renames and schedules for purging all bucket metacache.
    	go renameAllBucketMetacache(diskPath)
    }
    
    // Following error message is added to fix a regression in release
    // RELEASE.2018-03-16T22-52-12Z after migrating v1 to v2 to v3. This
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Jul 12 20:51:54 GMT 2024
    - 11.1K bytes
    - Click Count (1)
  7. src/main/java/org/codelibs/fess/helper/JobHelper.java

        /**
         * Registers a scheduled job with the job manager.
         *
         * @param scheduledJob the scheduled job to register
         */
        public void register(final ScheduledJob scheduledJob) {
            final JobManager jobManager = ComponentUtil.getJobManager();
            jobManager.schedule(cron -> register(cron, scheduledJob));
        }
    
        /**
         * Registers a scheduled job with the specified cron scheduler.
         *
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 10.9K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/app/web/admin/scheduler/AdminSchedulerAction.java

    import jakarta.annotation.Resource;
    
    /**
     * Admin action for Scheduler management.
     *
     */
    public class AdminSchedulerAction extends FessAdminAction {
    
        /**
         * Default constructor.
         */
        public AdminSchedulerAction() {
            super();
        }
    
        /** Role name for admin scheduler operations */
        public static final String ROLE = "admin-scheduler";
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Nov 20 13:56:35 GMT 2025
    - 21.8K bytes
    - Click Count (0)
  9. CHANGELOG/CHANGELOG-1.2.md

    PersistentVolumeClaim.
      * Run multiple schedulers in parallel, e.g. one or more custom schedulers
    alongside the default Kubernetes scheduler, using pod annotations to select
    among the schedulers for each pod. Documentation is [here](http://kubernetes.io/docs/admin/multiple-schedulers.md), design doc is [here](docs/proposals/multiple-schedulers.md).
      * More expressive node affinity syntax, and support for “soft” node affinity.
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Fri Dec 04 06:36:19 GMT 2020
    - 41.4K bytes
    - Click Count (0)
  10. 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)
Back to Top