CommandScheduler.hpp

Go to the documentation of this file.

// Copyright (c) FIRST and other WPILib contributors.
// Open Source Software; you can modify and/or share it under the terms of
// the WPILib BSD license file in the root directory of this project.
 
#pragma once
 
#include <concepts>
#include <functional>
#include <initializer_list>
#include <memory>
#include <optional>
#include <span>
#include <utility>
 
#include "wpi/event/EventLoop.hpp"
#include "wpi/system/Errors.hpp"
#include "wpi/system/Watchdog.hpp"
#include "wpi/units/time.hpp"
#include "wpi/util/FunctionExtras.hpp"
#include "wpi/util/sendable/Sendable.hpp"
#include "wpi/util/sendable/SendableHelper.hpp"
 
namespace wpi::cmd {
class Command;
class CommandPtr;
class Subsystem;
 
/**
 * The scheduler responsible for running Commands.  A Command-based robot should
 * call Run() on the singleton instance in its periodic block in order to run
 * commands synchronously from the main loop.  Subsystems should be registered
 * with the scheduler using RegisterSubsystem() in order for their Periodic()
 * methods to be called and for their default commands to be scheduled.
 *
 * This class is provided by the NewCommands VendorDep
 */
class CommandScheduler final
    : public wpi::util::Sendable,
      public wpi::util::SendableHelper<CommandScheduler> {
 public:
  /**
   * Returns the Scheduler instance.
   *
   * @return the instance
   */
  static CommandScheduler& GetInstance();
 
  ~CommandScheduler() override;
  CommandScheduler(const CommandScheduler&) = delete;
  CommandScheduler& operator=(const CommandScheduler&) = delete;
 
  using Action = std::function<void(const Command&)>;
  using InterruptAction =
      std::function<void(const Command&, const std::optional<Command*>&)>;
 
  /**
   * Changes the period of the loop overrun watchdog. This should be kept in
   * sync with the TimedRobot period.
   */
  void SetPeriod(wpi::units::second_t period);
 
  /**
   * Get the active button poll.
   *
   * @return a reference to the current {@link wpi::EventLoop} object polling
   * buttons.
   */
  wpi::EventLoop* GetActiveButtonLoop() const;
 
  /**
   * Replace the button poll with another one.
   *
   * @param loop the new button polling loop object.
   */
  void SetActiveButtonLoop(wpi::EventLoop* loop);
 
  /**
   * Get the default button poll.
   *
   * @return a reference to the default {@link wpi::EventLoop} object polling
   * buttons.
   */
  wpi::EventLoop* GetDefaultButtonLoop() const;
 
  /**
   * Schedules a command for execution. Does nothing if the command is already
   * scheduled. If a command's requirements are not available, it will only be
   * started if all the commands currently using those requirements are
   * interruptible. If this is the case, they will be interrupted and the
   * command will be scheduled.
   *
   * @warning Using this function directly can often lead to unexpected behavior
   * and should be avoided. Instead Triggers should be used to schedule
   * Commands.
   *
   * @param command the command to schedule
   */
  void Schedule(const CommandPtr& command);
 
  /**
   * Schedules a command for execution. Does nothing if the command is already
   * scheduled. If a command's requirements are not available, it will only be
   * started if all the commands currently using those requirements are
   * interruptible. If this is the case, they will be interrupted and the
   * command will be scheduled.
   *
   * @param command the command to schedule
   */
  void Schedule(CommandPtr&& command);
 
  /**
   * Schedules a command for execution. Does nothing if the command is already
   * scheduled. If a command's requirements are not available, it will only be
   * started if all the commands currently using those requirements have been
   * scheduled as interruptible. If this is the case, they will be interrupted
   * and the command will be scheduled.
   *
   * The pointer must remain valid through the entire lifecycle of the command.
   *
   * @warning Using this function directly can often lead to unexpected behavior
   * and should be avoided. Instead Triggers should be used to schedule
   * Commands.
   *
   * @param command the command to schedule
   */
  void Schedule(Command* command);
 
  /**
   * Schedules multiple commands for execution. Does nothing for commands
   * already scheduled.
   *
   * @warning Using this function directly can often lead to unexpected behavior
   * and should be avoided. Instead Triggers should be used to schedule
   * Commands.
   *
   * @param commands the commands to schedule
   */
  void Schedule(std::span<Command* const> commands);
 
  /**
   * Schedules multiple commands for execution. Does nothing for commands
   * already scheduled.
   *
   * @warning Using this function directly can often lead to unexpected behavior
   * and should be avoided. Instead Triggers should be used to schedule
   * Commands.
   *
   * @param commands the commands to schedule
   */
  void Schedule(std::initializer_list<Command*> commands);
 
  /**
   * Runs a single iteration of the scheduler.  The execution occurs in the
   * following order:
   *
   * <p>Subsystem periodic methods are called.
   *
   * <p>Button bindings are polled, and new commands are scheduled from them.
   *
   * <p>Currently-scheduled commands are executed.
   *
   * <p>End conditions are checked on currently-scheduled commands, and commands
   * that are finished have their end methods called and are removed.
   *
   * <p>Any subsystems not being used as requirements have their default methods
   * started.
   */
  void Run();
 
  /**
   * Registers subsystems with the scheduler.  This must be called for the
   * subsystem's periodic block to run when the scheduler is run, and for the
   * subsystem's default command to be scheduled.  It is recommended to call
   * this from the constructor of your subsystem implementations.
   *
   * @param subsystem the subsystem to register
   */
  void RegisterSubsystem(Subsystem* subsystem);
 
  /**
   * Un-registers subsystems with the scheduler.  The subsystem will no longer
   * have its periodic block called, and will not have its default command
   * scheduled.
   *
   * @param subsystem the subsystem to un-register
   */
  void UnregisterSubsystem(Subsystem* subsystem);
 
  void RegisterSubsystem(std::initializer_list<Subsystem*> subsystems);
  void RegisterSubsystem(std::span<Subsystem* const> subsystems);
 
  void UnregisterSubsystem(std::initializer_list<Subsystem*> subsystems);
  void UnregisterSubsystem(std::span<Subsystem* const> subsystems);
 
  /**
   * Un-registers all registered Subsystems with the scheduler. All currently
   * registered subsystems will no longer have their periodic block called, and
   * will not have their default command scheduled.
   */
  void UnregisterAllSubsystems();
 
  /**
   * Sets the default command for a subsystem.  Registers that subsystem if it
   * is not already registered.  Default commands will run whenever there is no
   * other command currently scheduled that requires the subsystem.  Default
   * commands should be written to never end (i.e. their IsFinished() method
   * should return false), as they would simply be re-scheduled if they do.
   * Default commands must also require their subsystem.
   *
   * @param subsystem      the subsystem whose default command will be set
   * @param defaultCommand the default command to associate with the subsystem
   */
  template <std::derived_from<Command> T>
  void SetDefaultCommand(Subsystem* subsystem, T&& defaultCommand) {
    if (!defaultCommand.HasRequirement(subsystem)) {
      throw WPILIB_MakeError(wpi::err::CommandIllegalUse,
                             "Default commands must require their subsystem!");
    }
    SetDefaultCommandImpl(subsystem, std::make_unique<std::decay_t<T>>(
                                         std::forward<T>(defaultCommand)));
  }
 
  /**
   * Sets the default command for a subsystem.  Registers that subsystem if it
   * is not already registered.  Default commands will run whenever there is no
   * other command currently scheduled that requires the subsystem.  Default
   * commands should be written to never end (i.e. their IsFinished() method
   * should return false), as they would simply be re-scheduled if they do.
   * Default commands must also require their subsystem.
   *
   * @param subsystem      the subsystem whose default command will be set
   * @param defaultCommand the default command to associate with the subsystem
   */
  void SetDefaultCommand(Subsystem* subsystem, CommandPtr&& defaultCommand);
 
  /**
   * Removes the default command for a subsystem. The current default command
   * will run until another command is scheduled that requires the subsystem, at
   * which point the current default command will not be re-scheduled.
   *
   * @param subsystem the subsystem whose default command will be removed
   */
  void RemoveDefaultCommand(Subsystem* subsystem);
 
  /**
   * Gets the default command associated with this subsystem.  Null if this
   * subsystem has no default command associated with it.
   *
   * @param subsystem the subsystem to inquire about
   * @return the default command associated with the subsystem
   */
  Command* GetDefaultCommand(const Subsystem* subsystem) const;
 
  /**
   * Cancels commands. The scheduler will only call Command::End()
   * method of the canceled command with true, indicating they were
   * canceled (as opposed to finishing normally).
   *
   * <p>Commands will be canceled even if they are not scheduled as
   * interruptible.
   *
   * @param command the command to cancel
   */
  void Cancel(Command* command);
 
  /**
   * Cancels commands. The scheduler will only call Command::End()
   * method of the canceled command with true, indicating they were
   * canceled (as opposed to finishing normally).
   *
   * <p>Commands will be canceled even if they are not scheduled as
   * interruptible.
   *
   * @param command the command to cancel
   */
  void Cancel(const CommandPtr& command);
 
  /**
   * Cancels commands. The scheduler will only call Command::End()
   * method of the canceled command with true, indicating they were
   * canceled (as opposed to finishing normally).
   *
   * <p>Commands will be canceled even if they are not scheduled as
   * interruptible.
   *
   * @param commands the commands to cancel
   */
  void Cancel(std::span<Command* const> commands);
 
  /**
   * Cancels commands. The scheduler will only call Command::End()
   * method of the canceled command with true, indicating they were
   * canceled (as opposed to finishing normally).
   *
   * <p>Commands will be canceled even if they are not scheduled as
   * interruptible.
   *
   * @param commands the commands to cancel
   */
  void Cancel(std::initializer_list<Command*> commands);
 
  /**
   * Cancels all commands that are currently scheduled.
   */
  void CancelAll();
 
  /**
   * Whether the given commands are running.  Note that this only works on
   * commands that are directly scheduled by the scheduler; it will not work on
   * commands inside of CommandGroups, as the scheduler does not see them.
   *
   * @param commands the command to query
   * @return whether the command is currently scheduled
   */
  bool IsScheduled(std::span<const Command* const> commands) const;
 
  /**
   * Whether the given commands are running.  Note that this only works on
   * commands that are directly scheduled by the scheduler; it will not work on
   * commands inside of CommandGroups, as the scheduler does not see them.
   *
   * @param commands the command to query
   * @return whether the command is currently scheduled
   */
  bool IsScheduled(std::initializer_list<const Command*> commands) const;
 
  /**
   * Whether a given command is running.  Note that this only works on commands
   * that are directly scheduled by the scheduler; it will not work on commands
   * inside of CommandGroups, as the scheduler does not see them.
   *
   * @param command the command to query
   * @return whether the command is currently scheduled
   */
  bool IsScheduled(const Command* command) const;
 
  /**
   * Whether a given command is running.  Note that this only works on commands
   * that are directly scheduled by the scheduler; it will not work on commands
   * inside of CommandGroups, as the scheduler does not see them.
   *
   * @param command the command to query
   * @return whether the command is currently scheduled
   */
  bool IsScheduled(const CommandPtr& command) const;
 
  /**
   * Returns the command currently requiring a given subsystem.  Null if no
   * command is currently requiring the subsystem
   *
   * @param subsystem the subsystem to be inquired about
   * @return the command currently requiring the subsystem
   */
  Command* Requiring(const Subsystem* subsystem) const;
 
  /**
   * Disables the command scheduler.
   */
  void Disable();
 
  /**
   * Enables the command scheduler.
   */
  void Enable();
 
  /**
   * Prints list of epochs added so far and their times.
   */
  void PrintWatchdogEpochs();
 
  /**
   * Adds an action to perform on the initialization of any command by the
   * scheduler.
   *
   * @param action the action to perform
   */
  void OnCommandInitialize(Action action);
 
  /**
   * Adds an action to perform on the execution of any command by the scheduler.
   *
   * @param action the action to perform
   */
  void OnCommandExecute(Action action);
 
  /**
   * Adds an action to perform on the interruption of any command by the
   * scheduler.
   *
   * @param action the action to perform
   */
  void OnCommandInterrupt(Action action);
 
  /**
   * Adds an action to perform on the interruption of any command by the
   * scheduler. The action receives the interrupted command and an optional
   * containing the interrupting command, or nullopt if it was not canceled by a
   * command (e.g., by Cancel()).
   *
   * @param action the action to perform
   */
  void OnCommandInterrupt(InterruptAction action);
 
  /**
   * Adds an action to perform on the finishing of any command by the scheduler.
   *
   * @param action the action to perform
   */
  void OnCommandFinish(Action action);
 
  /**
   * Requires that the specified command hasn't already been added to a
   * composition.
   *
   * @param command The command to check
   * @throws if the given commands have already been composed.
   */
  void RequireUngrouped(const Command* command);
 
  /**
   * Requires that the specified commands have not already been added to a
   * composition.
   *
   * @param commands The commands to check
   * @throws if the given commands have already been composed.
   */
  void RequireUngrouped(std::span<const std::unique_ptr<Command>> commands);
 
  /**
   * Requires that the specified commands have not already been added to a
   * composition.
   *
   * @param commands The commands to check
   * @throws IllegalArgumentException if the given commands have already been
   * composed.
   */
  void RequireUngrouped(std::initializer_list<const Command*> commands);
 
  /**
   * Requires that the specified command has not already been added to a
   * composition and is not currently scheduled.
   *
   * @param command The command to check
   * @throws IllegalArgumentException if the given command has already been
   * composed or scheduled.
   */
  void RequireUngroupedAndUnscheduled(const Command* command);
 
  /**
   * Requires that the specified commands have not already been added to a
   * composition and are not currently scheduled.
   *
   * @param commands The commands to check
   * @throws IllegalArgumentException if the given commands have already been
   * composed.
   */
  void RequireUngroupedAndUnscheduled(
      std::span<const std::unique_ptr<Command>> commands);
 
  /**
   * Requires that the specified commands have not already been added to a
   * composition and are not currently scheduled.
   *
   * @param commands The commands to check
   * @throws IllegalArgumentException if the given commands have already been
   * composed or scheduled.
   */
  void RequireUngroupedAndUnscheduled(
      std::initializer_list<const Command*> commands);
 
  void InitSendable(wpi::util::SendableBuilder& builder) override;
 
 private:
  // Constructor; private as this is a singleton
  CommandScheduler();
 
  void SetDefaultCommandImpl(Subsystem* subsystem,
                             std::unique_ptr<Command> command);
 
  void Cancel(Command* command, std::optional<Command*> interruptor);
 
  class Impl;
  std::unique_ptr<Impl> m_impl;
 
  wpi::Watchdog m_watchdog;
 
  friend class CommandTestBase;
 
  template <typename T>
  friend class CommandTestBaseWithParam;
};
}  // namespace wpi::cmd