use anyhow::anyhow;
use std::fmt;
use tch::{IndexOp, Tensor};
pub trait Optimizer: Send + Sync + fmt::Display {
fn optimize(&self, function: &dyn Fn(&Tensor) -> Tensor, x0: &Tensor)
-> anyhow::Result<Tensor>;
}
pub struct Newton {
max_steps: usize,
gtol: Option<f64>,
ftol: Option<f64>,
}
pub struct BFGS {
max_steps: usize,
gtol: Option<f64>,
ftol: Option<f64>,
}
pub struct Halley {
max_steps: usize,
gtol: Option<f64>,
ftol: Option<f64>,
}
pub struct CG {
max_steps: usize,
gtol: Option<f64>,
ftol: Option<f64>,
}
pub(crate) fn differentiate(function: &dyn Fn(&Tensor) -> Tensor, x: &Tensor) -> Tensor {
let x_with_grad = x.detach().copy().set_requires_grad(true);
let y = function(&x_with_grad);
tch::Tensor::run_backward(&[y], &[x_with_grad], false, false)[0].copy()
}
pub(crate) fn gradient_and_hessian(function: &dyn Fn(&Tensor) -> Tensor, x: &Tensor) -> (Tensor, Tensor) {
let x_with_grad = x.detach().copy().set_requires_grad(true);
let y = function(&x_with_grad);
let grad = Tensor::run_backward(&[y], &[&x_with_grad], true, true)[0].copy();
let grad_len = grad.size()[0];
let grad_kind = grad.kind();
let grad_device = grad.device();
if !grad.requires_grad() {
return (grad, Tensor::zeros([grad_len, grad_len], (grad_kind, grad_device)));
}
let mut vectors = Vec::<Tensor>::with_capacity(grad_len as usize);
for i in 0..grad_len {
vectors.append(&mut Tensor::run_backward(
&[grad.i(i)],
&[&x_with_grad],
true,
false,
));
}
let grad = grad.detach();
let hessian = Tensor::stack(&vectors, 0).detach();
(grad, hessian)
}
pub(crate) fn derivative_tensors_123(function: &dyn Fn(&Tensor) -> Tensor, x: &Tensor) -> (Tensor, Tensor, Tensor) {
let x_with_grad = x.detach().copy().set_requires_grad(true);
let y = function(&x_with_grad);
let grad = Tensor::run_backward(&[y], &[&x_with_grad], true, true)[0].copy();
let grad_len = grad.size()[0];
let grad_kind = grad.kind();
let grad_device = grad.device();
if !grad.requires_grad() {
return (
grad,
Tensor::zeros([grad_len, grad_len], (grad_kind, grad_device)),
Tensor::zeros([grad_len, grad_len, grad_len], (grad_kind, grad_device))
);
}
let mut vectors = Vec::<Tensor>::with_capacity(grad_len as usize);
for i in 0..grad_len {
vectors.append(&mut Tensor::run_backward(
&[grad.i(i)],
&[&x_with_grad],
true,
true,
));
}
let hessian = Tensor::stack(&vectors, 0);
if !hessian.requires_grad() {
return (
grad,
hessian,
Tensor::zeros([grad_len, grad_len, grad_len], (grad_kind, grad_device))
);
}
let mut vectors2 = Vec::<Tensor>::with_capacity(grad_len as usize);
for i in 0..grad_len {
let mut vectors1 = Vec::<Tensor>::with_capacity(grad_len as usize);
for j in 0..grad_len {
vectors1.append(&mut Tensor::run_backward(
&[hessian.i((i, j))],
&[&x_with_grad],
true,
false,
));
}
vectors2.push(Tensor::stack(&vectors1, 0));
}
let grad = grad.detach();
let hessian = hessian.detach();
let d3_tensor = Tensor::stack(&vectors2, 0).detach();
(grad, hessian, d3_tensor)
}
const P0: f64 = 0.0000000001f64;
const PHI2: f64 = 2.618033988749894848207f64;
const RPHI: f64 = 0.618033988749894848207f64;
fn choose_step_golden_section(
x0: &Tensor,
direction: &Tensor,
function: &dyn Fn(&Tensor) -> Tensor,
atol: f64,
) -> Tensor {
let (mut x1, mut x2, mut x3, mut x4): (f64, f64, f64, f64);
let (fx1, mut fx3, mut fx4): (f64, f64, f64);
fx1 = function(&x0).double_value(&[]);
x1 = 0.;
let fx_guess = function(&(x0 + direction * atol * 15.)).double_value(&[]);
x2 = if !fx_guess.is_finite() || fx_guess > fx1 {
P0
} else {
atol * 15.
};
let mut fx = function(&(x0 + direction * x2)).double_value(&[]);
while fx <= fx1 {
let new_x2 = x1 + (x2 - x1) * PHI2;
fx = function(&(x0 + direction * new_x2)).double_value(&[]);
if !fx.is_finite() {
break;
}
x2 = new_x2;
}
x3 = x2 - (x2 - x1) * RPHI;
x4 = x1 + (x2 - x1) * RPHI;
fx3 = function(&(x0 + direction * x3)).double_value(&[]);
fx4 = function(&(x0 + direction * x4)).double_value(&[]);
while x2 - x1 > atol {
if fx3 < fx4 {
x2 = x4;
fx4 = fx3;
x3 = x2 - (x2 - x1) * RPHI;
x4 = x1 + (x2 - x1) * RPHI;
fx3 = function(&(x0 + direction * x3)).double_value(&[]);
} else {
x1 = x3;
fx3 = fx4;
x3 = x2 - (x2 - x1) * RPHI;
x4 = x1 + (x2 - x1) * RPHI;
fx4 = function(&(x0 + direction * x4)).double_value(&[]);
}
}
direction * ((x1 + x2) / 2.)
}
fn choose_step_backtracking(
x0: &Tensor,
direction: &Tensor,
function: &dyn Fn(&Tensor) -> Tensor,
grad: &Tensor,
alpha: f64,
beta: f64,
) -> Tensor {
let fx0 = function(&x0).double_value(&[]);
let mut t = 1f64;
while {
let fx = function(&(x0 + direction * t)).double_value(&[]);
if !fx.is_finite() {
true
} else {
fx > fx0 + grad.reshape([-1]).dot(&direction.reshape([-1])).double_value(&[]) * alpha * t
}
}
{
t *= beta;
}
direction.copy() * t
}
impl CG {
pub fn new(max_steps: usize, gtol: Option<f64>, ftol: Option<f64>) -> Self {
Self {
max_steps,
gtol,
ftol,
}
}
}
impl Optimizer for CG {
fn optimize(
&self,
function: &dyn Fn(&Tensor) -> Tensor,
x0: &Tensor,
) -> anyhow::Result<Tensor> {
if x0.size().len() != 1 {
return Err(anyhow!("`x0` must have rank 1"));
}
let mut prev3_step_norm = 0f64;
let mut prev2_step_norm = 0f64;
let mut prev_step_norm = 0f64;
let mut prev_grad = Tensor::zeros_like(&x0);
let mut prev_direction = Tensor::zeros_like(&x0);
let mut prev_y: Option<Tensor> = None;
let mut x = x0.copy();
for step_num in 0..self.max_steps {
let grad = differentiate(function, &x);
if let Some(gtol) = self.gtol {
if grad.norm().double_value(&[]) < gtol {
return Ok(x);
}
} else {
if grad.norm().double_value(&[]) == 0. {
return Ok(x);
}
}
let direction = match step_num {
0 => -&grad,
_ => {
let orthogonality_measure = grad.reshape([-1]).dot(&prev_grad.reshape([-1])).abs()
/ grad.reshape([-1]).dot(&grad.reshape([-1]));
if orthogonality_measure.double_value(&[]) > 0.2 {
-&grad
} else {
let beta = grad.reshape([-1]).dot(&(&grad - &prev_grad).reshape([-1]))
/ prev_grad.reshape([-1]).dot(&prev_grad.reshape([-1]));
let beta = if beta.double_value(&[]) > 0. {
beta
} else {
tch::Tensor::zeros_like(&beta)
};
let beta = if beta.double_value(&[]) > 1000000000000. {
tch::Tensor::ones_like(&beta) * 1000000000000.
} else {
beta
};
-&grad + beta * &prev_direction
}
}
};
let linesearch_atol =
P0.max(prev_step_norm.min(prev2_step_norm).min(prev3_step_norm) / 1000.);
let step = choose_step_golden_section(&x, &direction, &function, linesearch_atol);
prev3_step_norm = prev2_step_norm;
prev2_step_norm = prev_step_norm;
prev_step_norm = step.norm().double_value(&[]);
x = x + step;
let y = function(&x);
if let (Some(prev_y), Some(ftol)) = (prev_y, self.ftol) {
if (&prev_y - &y).double_value(&[]) < ftol {
return Ok(x);
}
}
prev_y = Some(y);
prev_grad = grad;
prev_direction = direction;
}
Ok(x)
}
}
impl fmt::Display for CG {
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
let mut string = String::from("CG(");
string = string + "max_steps=" + self.max_steps.to_string().as_str();
if let Some(gtol) = self.gtol {
string = string + ", gtol=" + gtol.to_string().as_str();
}
if let Some(ftol) = self.ftol {
string = string + ", ftol=" + ftol.to_string().as_str();
}
string = string + ")";
write!(f, "{}", string)
}
}
impl BFGS {
pub fn new(max_steps: usize, gtol: Option<f64>, ftol: Option<f64>) -> Self {
Self {
max_steps,
gtol,
ftol,
}
}
}
impl Optimizer for BFGS {
fn optimize(
&self,
function: &dyn Fn(&Tensor) -> Tensor,
x0: &Tensor,
) -> anyhow::Result<Tensor> {
if x0.size().len() != 1 {
return Err(anyhow!("`x0` must have rank 1"));
}
let kind = x0.kind();
let device = x0.device();
let mut prev3_step_norm = 0f64;
let mut prev2_step_norm = 0f64;
let mut prev_step_norm = 0f64;
let x0_length = x0.size()[0];
let identity = match Tensor::f_eye(x0_length, (kind, device)) {
Ok(matrix) => matrix,
Err(tch::TchError::Torch(_)) => {
return Err(anyhow!(
"Could not allocate {}x{} matrix. Maybe try less resourcefull algorithm.",
x0_length,
x0_length
));
}
e => e.unwrap(),
};
let mut x = x0.copy();
let mut appr_inv_h = identity.copy();
let mut curr_grad = differentiate(function, &x);
let mut curr_y = function(&x);
if curr_y.size() != Vec::<i64>::new() {
return Err(anyhow!("Output of function `function` must be scalar"));
}
for _ in 0..self.max_steps {
if let Some(gtol) = self.gtol {
if curr_grad.norm().double_value(&[]) < gtol {
return Ok(x);
}
} else {
if curr_grad.norm().double_value(&[]) == 0. {
return Ok(x);
}
}
let direction = (-appr_inv_h.mm(&curr_grad.reshape([-1, 1]))).reshape([-1]);
let linesearch_atol =
P0.max(prev_step_norm.min(prev2_step_norm).min(prev3_step_norm) / 100.);
let step = choose_step_golden_section(&x, &direction, function, linesearch_atol);
prev3_step_norm = prev2_step_norm;
prev2_step_norm = prev_step_norm;
prev_step_norm = step.norm().double_value(&[]);
x = x + &step;
let y = function(&x);
if let Some(ftol) = self.ftol {
if (curr_y.double_value(&[]) - y.double_value(&[])) < ftol {
return Ok(x);
}
}
curr_y = y;
let grad = differentiate(function, &x);
let gdiff = &grad - &curr_grad;
let gamma = {
let delta = 0.0001;
let sty = step.dot(&gdiff).double_value(&[]);
let step_norm_sq = step.dot(&step).double_value(&[]);
let theta = if sty >= delta * step_norm_sq {
1.
} else {
let numerator = (1. - delta) * step_norm_sq;
let denominator = step_norm_sq - sty;
if denominator.abs() < 1e-10 {
1.
} else {
(numerator / denominator).min(1.)
}
};
let projection_factor = if step_norm_sq < 1e-10 {
0.
} else {
sty / step_norm_sq
};
let gdiff_prime = &gdiff * theta + &step * ((1. - theta) * projection_factor);
let sty_prime = step.dot(&gdiff_prime).double_value(&[]);
if sty_prime.abs() < 1e-10 {
1. / (delta * step_norm_sq + 1e-10)
} else {
1. / sty_prime
}
};
appr_inv_h = (&identity - gamma * step.reshape([-1, 1]).mm(&gdiff.reshape([1, -1])))
.mm(&appr_inv_h)
.mm(&(&identity - gamma * gdiff.reshape([-1, 1]).mm(&step.reshape([1, -1]))))
+ gamma * step.reshape([-1, 1]).mm(&step.reshape([1, -1]));
curr_grad = grad;
}
Ok(x)
}
}
impl fmt::Display for BFGS {
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
let mut string = String::from("BFGS(");
string = string + "max_steps=" + self.max_steps.to_string().as_str();
if let Some(gtol) = self.gtol {
string = string + ", gtol=" + gtol.to_string().as_str();
}
if let Some(ftol) = self.ftol {
string = string + ", ftol=" + ftol.to_string().as_str();
}
string = string + ")";
write!(f, "{}", string)
}
}
impl Newton {
pub fn new(max_steps: usize, gtol: Option<f64>, ftol: Option<f64>) -> Self {
Self {
max_steps,
gtol,
ftol,
}
}
}
impl Optimizer for Newton {
fn optimize(
&self,
function: &dyn Fn(&Tensor) -> Tensor,
x0: &Tensor,
) -> anyhow::Result<Tensor> {
if x0.size().len() != 1 {
return Err(anyhow!("`x0` must have rank 1"));
}
let kind = x0.kind();
let device = x0.device();
let x0_length = x0.size()[0];
let _ = match Tensor::f_eye(x0_length, (kind, device)) {
Ok(matrix) => matrix,
Err(tch::TchError::Torch(_)) => {
return Err(anyhow!(
"Could not allocate {}x{} matrix. Maybe try less resourcefull algorithm.",
x0_length,
x0_length
));
}
e => e.unwrap(),
};
let mut x = x0.copy();
let mut curr_y = function(&x);
if curr_y.size() != Vec::<i64>::new() {
return Err(anyhow!("Output of function `function` must be scalar"));
}
for _ in 0..self.max_steps {
let (curr_grad, curr_hessian) = gradient_and_hessian(function, &x);
if let Some(gtol) = self.gtol {
if curr_grad.norm().double_value(&[]) < gtol {
return Ok(x);
}
} else {
if curr_grad.norm().double_value(&[]) == 0. {
return Ok(x);
}
}
let negative_grad = -curr_grad.reshape([-1, 1]); let mut lambda = (negative_grad.norm().double_value(&[]) * 1e-3).max(1e-8); let direction = loop {
let damped_hessian =
&curr_hessian + Tensor::eye(x0_length, (kind, device)) * lambda;
match damped_hessian.f_linalg_cholesky(false) {
Ok(lower_triangular) => {
let y = lower_triangular.linalg_solve_triangular(
&negative_grad,
false,
true,
false,
);
break lower_triangular
.transpose(0, 1)
.linalg_solve_triangular(&y, true, true, false)
.reshape([-1]);
}
Err(_) => {
lambda *= 10.;
if lambda > 1e10 {
break curr_hessian
.linalg_pinv(1e-14, false)
.mm(&negative_grad)
.reshape([-1]);
}
}
}
};
let step = choose_step_backtracking(&x, &direction, function, &curr_grad, 0.1, 0.9);
x = x + &step;
let y = function(&x);
if let Some(ftol) = self.ftol {
if (curr_y.double_value(&[]) - y.double_value(&[])) < ftol {
return Ok(x);
}
}
curr_y = y;
}
Ok(x)
}
}
impl fmt::Display for Newton {
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
let mut string = String::from("Newton(");
string = string + "max_steps=" + self.max_steps.to_string().as_str();
if let Some(gtol) = self.gtol {
string = string + ", gtol=" + gtol.to_string().as_str();
}
if let Some(ftol) = self.ftol {
string = string + ", ftol=" + ftol.to_string().as_str();
}
string = string + ")";
write!(f, "{}", string)
}
}
impl Halley {
pub fn new(max_steps: usize, gtol: Option<f64>, ftol: Option<f64>) -> Self {
Self {
max_steps,
gtol,
ftol,
}
}
}
impl Optimizer for Halley {
fn optimize(
&self,
function: &dyn Fn(&Tensor) -> Tensor,
x0: &Tensor,
) -> anyhow::Result<Tensor> {
if x0.size().len() != 1 {
return Err(anyhow!("`x0` must have rank 1"));
}
let kind = x0.kind();
let device = x0.device();
let x0_length = x0.size()[0];
let _ = match Tensor::f_zeros([x0_length, x0_length, x0_length], (kind, device)) {
Ok(matrix) => matrix,
Err(tch::TchError::Torch(_)) => {
return Err(anyhow!(
"Could not allocate {}x{}x{} tensor. Maybe try less resourcefull algorithm.",
x0_length,
x0_length,
x0_length
));
}
e => e.unwrap(),
};
let mut x = x0.copy();
let mut curr_y = function(&x);
if curr_y.size() != Vec::<i64>::new() {
return Err(anyhow!("Output of function `function` must be scalar"));
}
for _ in 0..self.max_steps {
let (curr_grad, curr_hessian, curr_d3_tensor) = derivative_tensors_123(function, &x);
if let Some(gtol) = self.gtol {
if curr_grad.norm().double_value(&[]) < gtol {
return Ok(x);
}
} else {
if curr_grad.norm().double_value(&[]) == 0. {
return Ok(x);
}
}
let hessian_pinv = curr_hessian.linalg_pinv(1e-14, false);
let neg_newton_dir = hessian_pinv.mm(&curr_grad.reshape([-1, 1]));
let direction = -hessian_pinv.mm(&(curr_grad.reshape([-1, 1]) + curr_d3_tensor.matmul(&neg_newton_dir).reshape([x0_length, x0_length]).mm(&neg_newton_dir)*0.5)).reshape([-1]);
let step = choose_step_backtracking(&x, &direction, function, &curr_grad, 0.1, 0.9);
x = x + &step;
let y = function(&x);
if let Some(ftol) = self.ftol {
if (curr_y.double_value(&[]) - y.double_value(&[])) < ftol {
return Ok(x);
}
}
curr_y = y;
}
Ok(x)
}
}
impl fmt::Display for Halley {
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
let mut string = String::from("Halley(");
string = string + "max_steps=" + self.max_steps.to_string().as_str();
if let Some(gtol) = self.gtol {
string = string + ", gtol=" + gtol.to_string().as_str();
}
if let Some(ftol) = self.ftol {
string = string + ", ftol=" + ftol.to_string().as_str();
}
string = string + ")";
write!(f, "{}", string)
}
}