Delete emolynx.py
Browse files- emolynx.py +0 -129
emolynx.py
DELETED
|
@@ -1,129 +0,0 @@
|
|
| 1 |
-
import torch
|
| 2 |
-
from torch.optim import Optimizer
|
| 3 |
-
import math
|
| 4 |
-
from typing import Tuple, Callable, Union
|
| 5 |
-
|
| 6 |
-
# Helper function (Lynx)
|
| 7 |
-
def exists(val):
|
| 8 |
-
return val is not None
|
| 9 |
-
|
| 10 |
-
class EmoLynx(Optimizer):
|
| 11 |
-
# クラス定義&初期化
|
| 12 |
-
def __init__(self, params: Union[list, torch.nn.Module], lr=1e-3, betas=(0.9, 0.99),
|
| 13 |
-
# lynx用ベータ・互換性の追加(lynx用beta1・beta2)
|
| 14 |
-
eps=1e-8, weight_decay=0.01, decoupled_weight_decay: bool = False):
|
| 15 |
-
|
| 16 |
-
defaults = dict(lr=lr, betas=betas, eps=eps, weight_decay=weight_decay)
|
| 17 |
-
super().__init__(params, defaults)
|
| 18 |
-
|
| 19 |
-
# lynxに応じてウェイト減衰のため保存
|
| 20 |
-
self._init_lr = lr
|
| 21 |
-
self.decoupled_wd = decoupled_weight_decay
|
| 22 |
-
self.should_stop = False # 停止フラグの初期化
|
| 23 |
-
|
| 24 |
-
# 感情EMA更新(緊張と安静)
|
| 25 |
-
def _update_ema(self, state, loss_val):
|
| 26 |
-
ema = state.setdefault('ema', {})
|
| 27 |
-
ema['short'] = 0.3 * loss_val + 0.7 * ema.get('short', loss_val)
|
| 28 |
-
ema['long'] = 0.01 * loss_val + 0.99 * ema.get('long', loss_val)
|
| 29 |
-
return ema
|
| 30 |
-
|
| 31 |
-
# 感情スカラー値生成(EMA差分、滑らかな非線形スカラー、tanh 5 * diff で鋭敏さ強調)
|
| 32 |
-
def _compute_scalar(self, ema):
|
| 33 |
-
diff = ema['short'] - ema['long']
|
| 34 |
-
return math.tanh(5 * diff)
|
| 35 |
-
|
| 36 |
-
# Shadow混合比率(> 0.6:70〜90%、 < 0.6:10%、 > 0.3:30%、 平時:0%)
|
| 37 |
-
def _decide_ratio(self, scalar):
|
| 38 |
-
if scalar > 0.6:
|
| 39 |
-
return 0.7 + 0.2 * scalar
|
| 40 |
-
elif scalar < -0.6:
|
| 41 |
-
return 0.1
|
| 42 |
-
elif abs(scalar) > 0.3:
|
| 43 |
-
return 0.3
|
| 44 |
-
return 0.0
|
| 45 |
-
|
| 46 |
-
# 損失取得(損失値 loss_val を数値化、感情判定に使用、存在しないパラメータ(更新不要)はスキップ)
|
| 47 |
-
@torch.no_grad()
|
| 48 |
-
def step(self, closure: Callable | None = None): # クロージャの型ヒントを追加
|
| 49 |
-
loss = None
|
| 50 |
-
if exists(closure): # 一貫性のためにexistsヘルパーを使う
|
| 51 |
-
with torch.enable_grad():
|
| 52 |
-
loss = closure()
|
| 53 |
-
loss_val = loss.item() if loss is not None else 0.0
|
| 54 |
-
|
| 55 |
-
for group in self.param_groups:
|
| 56 |
-
# リンクス共通パラメータ抽出
|
| 57 |
-
lr, wd, beta1, beta2 = group['lr'], group['weight_decay'], *group['betas']
|
| 58 |
-
|
| 59 |
-
# ウェイト減衰の処理を分離 (from lynx)
|
| 60 |
-
_wd_actual = wd
|
| 61 |
-
if self.decoupled_wd:
|
| 62 |
-
_wd_actual /= self._init_lr # 非連結時ウェイト減衰調整
|
| 63 |
-
|
| 64 |
-
for p in filter(lambda p: exists(p.grad), group['params']): # PGチェックにフィルタ
|
| 65 |
-
|
| 66 |
-
grad = p.grad # PG直接使用(計算に".data"不要)
|
| 67 |
-
state = self.state[p]
|
| 68 |
-
|
| 69 |
-
# EMA更新・スカラー生成(EMA差分からスカラーを生成しスパイク比率を決定)
|
| 70 |
-
ema = self._update_ema(state, loss_val)
|
| 71 |
-
scalar = self._compute_scalar(ema)
|
| 72 |
-
ratio = self._decide_ratio(scalar)
|
| 73 |
-
|
| 74 |
-
# shadow_param:必要時のみ更新(スパイク部分に現在値を5%ずつ追従させる動的履歴)
|
| 75 |
-
if ratio > 0:
|
| 76 |
-
if 'shadow' not in state:
|
| 77 |
-
state['shadow'] = p.data.clone()
|
| 78 |
-
else:
|
| 79 |
-
p.data.mul_(1 - ratio).add_(state['shadow'], alpha=ratio)
|
| 80 |
-
state['shadow'].lerp_(p.data, 0.05)
|
| 81 |
-
# lynx更新前 p.data で shadow 更新(現在値を5%ずつ追従)
|
| 82 |
-
# p.data.mul_(1 - ratio).add_(state['shadow'], alpha=ratio)
|
| 83 |
-
# EmoNavi: p.data = p.data * (1-ratio) + shadow * ratio
|
| 84 |
-
|
| 85 |
-
# --- Start Lynx Gradient Update Logic ---
|
| 86 |
-
|
| 87 |
-
# lynx初期化(exp_avg_sq)
|
| 88 |
-
if 'exp_avg' not in state:
|
| 89 |
-
state['exp_avg'] = torch.zeros_like(p)
|
| 90 |
-
exp_avg = state['exp_avg']
|
| 91 |
-
|
| 92 |
-
# Stepweight decay (from lynx): p.data = p.data * (1 - lr * wd)
|
| 93 |
-
# decoupled_wd 考慮 _wd_actual 使用(EmoNaviのwdは最後に適用)
|
| 94 |
-
p.data.mul_(1. - lr * _wd_actual)
|
| 95 |
-
|
| 96 |
-
# 勾配ブレンド
|
| 97 |
-
# m_t = beta1 * exp_avg_prev + (1 - beta1) * grad
|
| 98 |
-
blended_grad = grad.mul(1. - beta1).add_(exp_avg, alpha=beta1)
|
| 99 |
-
|
| 100 |
-
# p: p.data = p.data - lr * sign(blended_grad)
|
| 101 |
-
p.data.add_(blended_grad.sign_(), alpha = -lr)
|
| 102 |
-
|
| 103 |
-
# exp_avg = beta2 * exp_avg + (1 - beta2) * grad
|
| 104 |
-
exp_avg.mul_(beta2).add_(grad, alpha = 1. - beta2)
|
| 105 |
-
|
| 106 |
-
# --- End Lynx Gradient Update Logic ---
|
| 107 |
-
|
| 108 |
-
# Early Stop用 scalar記録(バッファ共通で管理/最大32件保持/動静評価)
|
| 109 |
-
# この部分は p.state ではなく self.state ���アクセスする
|
| 110 |
-
hist = self.state.setdefault('scalar_hist', [])
|
| 111 |
-
hist.append(scalar)
|
| 112 |
-
if len(hist) > 32:
|
| 113 |
-
hist.pop(0)
|
| 114 |
-
|
| 115 |
-
# Early Stop判断(静けさの合図) - This part is outside the inner loop
|
| 116 |
-
if len(self.state['scalar_hist']) >= 32:
|
| 117 |
-
buf = self.state['scalar_hist']
|
| 118 |
-
avg_abs = sum(abs(s) for s in buf) / len(buf)
|
| 119 |
-
std = sum((s - sum(buf)/len(buf))**2 for s in buf) / len(buf)
|
| 120 |
-
if avg_abs < 0.05 and std < 0.005:
|
| 121 |
-
self.should_stop = True # 💡 外部からこれを見て判断可
|
| 122 |
-
|
| 123 |
-
return loss
|
| 124 |
-
|
| 125 |
-
"""
|
| 126 |
-
Lynx was developed with inspiration from Lion and Tiger,
|
| 127 |
-
which we deeply respect for their lightweight and intelligent design.
|
| 128 |
-
Lynx also integrates EmoNAVI to enhance its capabilities.
|
| 129 |
-
"""
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|