Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for scheduleAtFixedRate (0.08 sec)

  1. android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

       * execute/submit/schedule}, as in {@link CallerRunsPolicy}. This applies both to individually
       * submitted tasks and to collections of tasks submitted via {@code invokeAll}, {@code invokeAny},
       * {@code schedule}, {@code scheduleAtFixedRate}, and {@code scheduleWithFixedDelay}. In the case
       * of tasks submitted by {@code invokeAll} or {@code invokeAny}, tasks will run serially on the
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 6.6K bytes
    - Viewed (0)
  2. guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

       * execute/submit/schedule}, as in {@link CallerRunsPolicy}. This applies both to individually
       * submitted tasks and to collections of tasks submitted via {@code invokeAll}, {@code invokeAny},
       * {@code schedule}, {@code scheduleAtFixedRate}, and {@code scheduleWithFixedDelay}. In the case
       * of tasks submitted by {@code invokeAll} or {@code invokeAny}, tasks will run serially on the
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 6.6K bytes
    - Viewed (0)
  3. android/guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

          return 0;
        }
      }
    
      @Override
      public ListenableScheduledFuture<?> scheduleAtFixedRate(
          Runnable command, long initialDelay, long period, TimeUnit unit) {
        throw new UnsupportedOperationException("scheduleAtFixedRate is not supported.");
      }
    
      @Override
      public ListenableScheduledFuture<?> scheduleWithFixedDelay(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:37:28 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  4. guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

          return 0;
        }
      }
    
      @Override
      public ListenableScheduledFuture<?> scheduleAtFixedRate(
          Runnable command, long initialDelay, long period, TimeUnit unit) {
        throw new UnsupportedOperationException("scheduleAtFixedRate is not supported.");
      }
    
      @Override
      public ListenableScheduledFuture<?> scheduleWithFixedDelay(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:37:28 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  5. src/main/java/jcifs/internal/witness/WitnessClient.java

         */
        private void schedulePeriodicTasks() {
            // Heartbeat monitoring
            scheduler.scheduleAtFixedRate(this::checkHeartbeats, 30, 30, TimeUnit.SECONDS);
    
            // Registration monitoring
            scheduler.scheduleAtFixedRate(this::monitorRegistrations, 10, 10, TimeUnit.SECONDS);
        }
    
        /**
         * Registers for witness notifications.
         *
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 20.8K bytes
    - Viewed (0)
  6. src/main/java/jcifs/internal/smb2/lease/DirectoryLeaseManager.java

            this.scheduler = Executors.newScheduledThreadPool(1);
            this.changeNotifier = new DirectoryChangeNotifier(this);
    
            // Schedule periodic cache cleanup
            scheduler.scheduleAtFixedRate(this::cleanupExpiredEntries, 60, 60, TimeUnit.SECONDS);
        }
    
        /**
         * Request a directory lease
         *
         * @param directoryPath directory path
         * @param requestedState requested lease state
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 01:47:47 UTC 2025
    - 12.3K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

            }
          };
        }
    
        /**
         * Returns a {@link Scheduler} that schedules the task using the {@link
         * ScheduledExecutorService#scheduleAtFixedRate} method.
         *
         * @param initialDelay the time to delay first execution
         * @param period the period between successive executions of the task
         * @since 28.0 (but only since 33.4.0 in the Android flavor)
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.8K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

            }
          };
        }
    
        /**
         * Returns a {@link Scheduler} that schedules the task using the {@link
         * ScheduledExecutorService#scheduleAtFixedRate} method.
         *
         * @param initialDelay the time to delay first execution
         * @param period the period between successive executions of the task
         * @since 33.4.0 (but since 28.0 in the JRE flavor)
         */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.7K bytes
    - Viewed (0)
  9. src/main/java/jcifs/internal/smb2/multichannel/ChannelManager.java

            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
         *
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 20K bytes
    - Viewed (0)
  10. src/main/java/jcifs/internal/smb2/persistent/PersistentHandleManager.java

            }
    
            // Load persisted handles on startup
            loadPersistedHandles();
    
            // Schedule periodic persistence and cleanup
            scheduler.scheduleAtFixedRate(this::periodicMaintenance, 30, 30, TimeUnit.SECONDS);
        }
    
        /**
         * Request a new durable handle
         * @param path the file path
         * @param type the handle type
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 24 00:49:49 UTC 2025
    - 13K bytes
    - Viewed (0)
Back to top