Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 155 for schedule (0.23 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 16:22:21 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt

        // If the task is already scheduled, take the earlier of the two times.
        val existingIndex = futureTasks.indexOf(task)
        if (existingIndex != -1) {
          if (task.nextExecuteNanoTime <= executeNanoTime) {
            taskRunner.logger.taskLog(task, this) { "already scheduled" }
            return false
          }
          futureTasks.removeAt(existingIndex) // Already scheduled later: reschedule below!
        }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  3. 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: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 29 00:33:04 UTC 2024
    - 23K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/concurrent/Task.kt

     * ----------
     *
     * Tasks control their recurrence schedule. The [runOnce] function returns -1L to signify that the
     * task should not be executed again. Otherwise it returns a delay until the next execution.
     *
     * A task has at most one next execution. If the same task instance is scheduled multiple times, the
     * earliest one wins. This applies to both executions scheduled with [TaskRunner.Queue.schedule] and
     * those implied by the returned execution delay.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  5. .teamcity/src/main/kotlin/promotion/PublishNightlyDocumentation.kt

                    schedule {
                        schedulingPolicy = daily {
                            this.hour = triggerHour
                        }
                        triggerBuild = always()
                        withPendingChangesOnly = true
                        enabled = branch.enableVcsTriggers
                        // https://www.jetbrains.com/help/teamcity/2022.04/configuring-schedule-triggers.html#general-syntax-1
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Wed Feb 07 17:05:02 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerRealBackendTest.kt

      }
    
      @Test fun taskFailsWithUncheckedException() {
        queue.schedule("task", TimeUnit.MILLISECONDS.toNanos(100)) {
          log.put("failing task running")
          throw RuntimeException("boom!")
        }
    
        queue.schedule("task", TimeUnit.MILLISECONDS.toNanos(200)) {
          log.put("normal task running")
          return@schedule -1L
        }
    
        queue.idleLatch().await(500, TimeUnit.MILLISECONDS)
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  7. .github/dependabot.yml

    version: 2
    updates:
    
      - package-ecosystem: "maven"
        directory: "/"
        schedule:
          interval: "daily"
    
      - package-ecosystem: maven
        directory: "/"
        schedule:
          interval: "daily"
        target-branch: "maven-3.9.x"
        labels:
          - "mvn3"
    
      - package-ecosystem: "github-actions"
        directory: "/"
        schedule:
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Wed Aug 21 09:07:48 UTC 2024
    - 1.1K bytes
    - Viewed (0)
  8. common-protos/k8s.io/api/batch/v1beta1/generated.proto

    }
    
    // CronJobSpec describes how the job execution will look like and when it will actually run.
    message CronJobSpec {
      // The schedule in Cron format, see https://en.wikipedia.org/wiki/Cron.
      optional string schedule = 1;
    
      // The time zone name for the given schedule, see https://en.wikipedia.org/wiki/List_of_tz_database_time_zones.
      // If not specified, this will default to the time zone of the kube-controller-manager process.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  9. .github/dependabot.yml

    # easily import the generated PRs into our internal repo.
    #  - package-ecosystem: "maven"
    #    directory: "/"
    #    schedule:
    #      interval: "weekly"
    #    groups:
    #      dependencies:
    #        applies-to: version-updates
    #        patterns:
    #          - "*"
    #  - package-ecosystem: "maven"
    #    directory: "/android"
    #    schedule:
    #      interval: "weekly"
    #    groups:
    #      dependencies:
    #        applies-to: version-updates
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jun 04 17:08:24 UTC 2024
    - 761 bytes
    - Viewed (0)
  10. android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

        return new NoOpScheduledExecutorService();
      }
    
      /**
       * Creates a scheduled executor service that runs each task in the thread that invokes {@code
       * 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
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:18:12 UTC 2024
    - 6.6K bytes
    - Viewed (0)
Back to top