Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 72 for Schedules (0.06 sec)

  1. 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: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.8K bytes
    - Viewed (0)
  2. 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: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.7K bytes
    - Viewed (0)
  3. 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.
         */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 20.8K bytes
    - Viewed (0)
  4. docs/bucket/replication/README.md

    replication rules were disabled will be synced to the target cluster. Depending on the number of previously existing objects, the existing objects that are now eligible to be replicated will eventually be synced to the target cluster as the scanner schedules them. This may be slower depending on the load on the cluster, latency and size of the namespace.
    
    In the rare event that target DR site is entirely lost and previously replicated objects to the DR cluster need to be re-replicated, `mc...
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 18.3K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/Futures.java

        Future<?> scheduled = executorService.schedule(task, delay, timeUnit);
        /*
         * Even when the user interrupts the task, we pass `false` to `cancel` so that we don't
         * interrupt a second time after the interruption performed by TrustedListenableFutureTask.
         */
        task.addListener(() -> scheduled.cancel(false), directExecutor());
        return task;
      }
    
      /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 64.3K bytes
    - Viewed (0)
  6. .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: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Mon Sep 01 15:40:11 UTC 2025
    - 1.6K bytes
    - Viewed (0)
  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.
         *
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 10.8K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/app/web/api/admin/scheduler/ApiAdminSchedulerAction.java

        }
    
        /**
         * Retrieves scheduler settings with pagination.
         *
         * @param body the search parameters for filtering and pagination
         * @return JSON response containing scheduler settings list
         */
        // GET /api/admin/scheduler
        // PUT /api/admin/scheduler
        @Execute
        public JsonResponse<ApiResult> settings(final SearchBody body) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 10K bytes
    - Viewed (0)
  9. 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);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 42K bytes
    - Viewed (0)
  10. RELEASE.md

        *   Keras inputs can now be created directly from arbitrary `tf.TypeSpecs`.
        *   Two new learning rate schedules added:
            `tf.keras.optimizers.schedules.CosineDecay`
            and`tf.keras.optimizers.schedules.CosineDecayRestarts`.
    
    *   `tf.data`:
    
        *   Exposing `tf.data.experimental.ExternalStatePolicy`, which can be used
    Registered: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Mon Aug 18 20:54:38 UTC 2025
    - 740K bytes
    - Viewed (2)
Back to top