R/ContextAsync.R

In bbotk: Black-Box Optimization Toolkit

#' @title Asynchronous Optimization Context
#'
#' @description
#' A [CallbackAsync] accesses and modifies data during the optimization via the `ContextAsync`.
#' See the section on active bindings for a list of modifiable objects.
#' See [callback_async()] for a list of stages which access `ContextAsync`.
#'
#' @details
#' Changes to `$instance` and `$optimizer` in the stages executed on the workers are not reflected in the main process.
#'
#' @export
ContextAsync = R6Class("ContextAsync",
  inherit = Context,
  public = list(

    #' @field instance ([OptimInstance]).
    instance = NULL,

    #' @field optimizer ([Optimizer]).
    optimizer = NULL,

    #' @description
    #' Creates a new instance of this [R6][R6::R6Class] class.
    #'
    #' @param inst ([OptimInstance]).
    #' @param optimizer ([Optimizer]).
    initialize = function(inst, optimizer) {
      self$instance = assert_instance_async(inst)
      self$optimizer = optimizer
    }
  ),

  active = list(

    #' @field xs (list())\cr
    #' The point to be evaluated in `instance$.eval_point()`.
    xs = function(rhs) {
      if (missing(rhs)) {
        get_private(self$instance)$.xs
      } else {
        get_private(self$instance, ".xs") = rhs
      }
    },

    #' @field xs_trafoed (list())\cr
    #' The transformed point to be evaluated in `instance$.eval_point()`.
    xs_trafoed = function(rhs) {
      if (missing(rhs)) {
        get_private(self$instance)$.xs_trafoed
      } else {
        get_private(self$instance, ".xs_trafoed") = rhs
      }
    },

    #' @field extra (list())\cr
    #' Additional information of the point to be evaluated in `instance$.eval_point()`.
    extra = function(rhs) {
      if (missing(rhs)) {
        get_private(self$instance)$.extra
      } else {
        get_private(self$instance, ".extra") = rhs
      }
    },

    #' @field ys (list())\cr
    #' The result of the evaluation in `instance$.eval_point()`.
    ys = function(rhs) {
      if (missing(rhs)) {
        get_private(self$instance)$.ys
      } else {
        get_private(self$instance, ".ys") = rhs
      }
    },

    #' @field result_xdt ([data.table::data.table])\cr
    #' The xdt passed to `instance$assign_result()`.
    result_xdt = function(rhs) {
      if (missing(rhs)) {
        return(get_private(self$instance)$.result_xdt)
      } else {
        self$instance$.__enclos_env__$private$.result_xdt = rhs
      }
    },

    #' @field result_y (`numeric(1)`)\cr
    #' The y passed to `instance$assign_result()`.
    #' Only available for single criterion optimization.
    result_y = function(rhs) {
      if (missing(rhs)) {
        return(get_private(self$instance)$.result_y)
      } else {
        self$instance$.__enclos_env__$private$.result_y = rhs
      }
    },

    #' @field result_ydt ([data.table::data.table])\cr
    #' The ydt passed to `instance$assign_result()`.
    #' Only available for multi criterion optimization.
    result_ydt = function(rhs) {
      if (missing(rhs)) {
        return(get_private(self$instance)$.result_ydt)
      } else {
        self$instance$.__enclos_env__$private$.result_ydt = rhs
      }
    },

    #' @field result_extra ([data.table::data.table])\cr
    #' Additional information about the result passed to `instance$assign_result()`.
    result_extra = function(rhs) {
      if (missing(rhs)) {
        get_private(self$instance)$.result_extra
      } else {
        get_private(self$instance, ".result_extra") = rhs
      }
    },

    #' @field result ([data.table::data.table])\cr
    #' The result of the optimization in `instance$assign_result()`.
    result = function(rhs) {
      if (missing(rhs)) {
        get_private(self$instance)$.result
      } else {
        get_private(self$instance, ".result") = rhs
      }
    }
  )
)