use crate::{
Optimizer, OptimizerError, OptimizerResult, OptimizerState, ParamGroup, ParamGroupState,
};
use parking_lot::RwLock;
use std::collections::HashMap;
use std::ops::{Add, Mul};
use std::sync::Arc;
use torsh_core::error::{Result, TorshError};
use torsh_tensor::Tensor;
pub struct SparseAdam {
param_groups: Vec<ParamGroup>,
state: HashMap<String, HashMap<String, Tensor>>,
step_count: usize,
beta1: f32,
beta2: f32,
eps: f32,
}
impl SparseAdam {
pub fn new(
params: Vec<Arc<RwLock<Tensor>>>,
lr: Option<f32>,
beta1: Option<f32>,
beta2: Option<f32>,
eps: Option<f32>,
weight_decay: Option<f32>,
) -> Self {
let lr = lr.unwrap_or(1e-3);
let beta1 = beta1.unwrap_or(0.9);
let beta2 = beta2.unwrap_or(0.999);
let eps = eps.unwrap_or(1e-8);
let weight_decay = weight_decay.unwrap_or(0.0);
let mut options = HashMap::new();
options.insert("weight_decay".to_string(), weight_decay);
let param_group = ParamGroup::new(params, lr).with_options(options);
Self {
param_groups: vec![param_group],
state: HashMap::new(),
step_count: 0,
beta1,
beta2,
eps,
}
}
fn get_param_id(param: &Arc<RwLock<Tensor>>) -> String {
format!("{:p}", Arc::as_ptr(param))
}
fn sparse_update(
&self,
param: &mut Tensor,
grad: &Tensor,
exp_avg: &mut Tensor,
exp_avg_sq: &mut Tensor,
lr: f32,
step: usize,
) -> Result<()> {
let exp_avg_update = grad.mul_scalar(1.0 - self.beta1)?;
*exp_avg = exp_avg.mul_scalar(self.beta1)?.add(&exp_avg_update)?;
let grad_sq = grad.mul(grad)?;
let exp_avg_sq_update = grad_sq.mul_scalar(1.0 - self.beta2)?;
*exp_avg_sq = exp_avg_sq.mul_scalar(self.beta2)?.add(&exp_avg_sq_update)?;
let bias_correction1 = 1.0 - self.beta1.powi(step as i32);
let bias_correction2 = 1.0 - self.beta2.powi(step as i32);
let exp_avg_corrected = exp_avg.div_scalar(bias_correction1)?;
let exp_avg_sq_corrected = exp_avg_sq.div_scalar(bias_correction2)?;
let denom = exp_avg_sq_corrected.sqrt()?.add_scalar(self.eps)?;
let update = exp_avg_corrected.div(&denom)?;
*param = param.sub(&update.mul_scalar(lr)?)?;
Ok(())
}
}
impl Optimizer for SparseAdam {
fn step(&mut self) -> OptimizerResult<()> {
self.step_count += 1;
for group in &self.param_groups {
let lr = group.lr;
let weight_decay = group.options.get("weight_decay").copied().unwrap_or(0.0);
for param in &group.params {
let param_id = Self::get_param_id(param);
let param_read = param.read();
let grad = param_read.grad().ok_or_else(|| {
TorshError::invalid_argument_with_context(
"Parameter has no gradient",
"sparse_adam_step",
)
})?;
let mut exp_avg = if let Some(state) = self.state.get(¶m_id) {
if let Some(exp_avg) = state.get("exp_avg") {
exp_avg.clone()
} else {
Tensor::zeros_like(¶m_read)?
}
} else {
Tensor::zeros_like(¶m_read)?
};
let mut exp_avg_sq = if let Some(state) = self.state.get(¶m_id) {
if let Some(exp_avg_sq) = state.get("exp_avg_sq") {
exp_avg_sq.clone()
} else {
Tensor::zeros_like(¶m_read)?
}
} else {
Tensor::zeros_like(¶m_read)?
};
let mut grad_to_use = grad.clone();
if weight_decay != 0.0 {
grad_to_use = grad_to_use.add(¶m_read.mul_scalar(weight_decay)?)?;
}
drop(param_read);
let mut param_write = param.write();
self.sparse_update(
&mut param_write,
&grad_to_use,
&mut exp_avg,
&mut exp_avg_sq,
lr,
self.step_count,
)?;
let param_state = self.state.entry(param_id.clone()).or_default();
param_state.insert("exp_avg".to_string(), exp_avg);
param_state.insert("exp_avg_sq".to_string(), exp_avg_sq);
}
}
Ok(())
}
fn zero_grad(&mut self) {
for group in &self.param_groups {
for param in &group.params {
param.write().zero_grad();
}
}
}
fn get_lr(&self) -> Vec<f32> {
self.param_groups.iter().map(|g| g.lr).collect()
}
fn set_lr(&mut self, lr: f32) {
for group in &mut self.param_groups {
group.lr = lr;
}
}
fn add_param_group(&mut self, params: Vec<Arc<RwLock<Tensor>>>, options: HashMap<String, f32>) {
let lr = options.get("lr").copied().unwrap_or(1e-3);
let group = ParamGroup::new(params, lr).with_options(options);
self.param_groups.push(group);
}
fn parameters(&self) -> Vec<Arc<RwLock<Tensor>>> {
crate::optimizer::collect_parameters(&self.param_groups)
}
fn state_dict(&self) -> OptimizerResult<OptimizerState> {
let param_groups = self
.param_groups
.iter()
.map(|g| ParamGroupState {
lr: g.lr,
options: g.options.clone(),
param_count: g.params.len(),
})
.collect();
Ok(OptimizerState {
optimizer_type: "SparseAdam".to_string(),
version: "0.1.0".to_string(),
param_groups,
state: self.state.clone(),
global_state: HashMap::new(),
})
}
fn load_state_dict(&mut self, state: OptimizerState) -> OptimizerResult<()> {
if state.param_groups.len() != self.param_groups.len() {
return Err(OptimizerError::InvalidParameter(
"Parameter group count mismatch".to_string(),
));
}
for (i, group_state) in state.param_groups.iter().enumerate() {
self.param_groups[i].lr = group_state.lr;
self.param_groups[i].options = group_state.options.clone();
}
self.state = state.state;
Ok(())
}
}
#[cfg(test)]
mod tests {
use super::*;
use torsh_tensor::creation::randn;
#[test]
fn test_sparse_adam_creation() {
let params = vec![Arc::new(RwLock::new(randn::<f32>(&[2, 2]).unwrap()))];
let optimizer = SparseAdam::new(params, None, None, None, None, None);
assert_eq!(optimizer.get_lr()[0], 1e-3);
}
#[test]
#[ignore = "Temporarily disabled due to potential deadlock"]
fn test_sparse_adam_step() -> OptimizerResult<()> {
let param = Arc::new(RwLock::new(randn::<f32>(&[2, 2]).unwrap()));
let mut param_write = param.write();
param_write.set_grad(Some(randn::<f32>(&[2, 2]).unwrap()));
drop(param_write);
let params = vec![param];
let mut optimizer = SparseAdam::new(params, Some(0.1), None, None, None, None);
optimizer.step()?;
Ok(())
}
#[test]
fn test_sparse_adam_basic() -> OptimizerResult<()> {
let params = vec![Arc::new(RwLock::new(randn::<f32>(&[2, 2])?))];
let mut optimizer = SparseAdam::new(
params,
Some(0.01),
Some(0.9),
Some(0.999),
Some(1e-10),
Some(0.01),
);
assert_eq!(optimizer.get_lr()[0], 0.01);
optimizer.set_lr(0.001);
assert_eq!(optimizer.get_lr()[0], 0.001);
let state = optimizer.state_dict()?;
assert_eq!(state.param_groups.len(), 1);
assert_eq!(state.param_groups[0].lr, 0.001);
Ok(())
}
}