//+------------------------------------------------------------------+ //| NeuronLSTM.mqh | //| Copyright 2021, MetaQuotes Ltd. | //| https://www.mql5.com | //+------------------------------------------------------------------+ #property copyright "Copyright 2021, MetaQuotes Ltd." #property link "https://www.mql5.com" //+------------------------------------------------------------------+ //| Подключаем библиотеки | //+------------------------------------------------------------------+ #include "neuronbase.mqh" #include //+------------------------------------------------------------------+ //| Class CNeuronLSTM | //| Назначение: Класс организации рекуррентного LSTM блока | //+------------------------------------------------------------------+ class CNeuronLSTM : public CNeuronBase { protected: CNeuronBase *m_cForgetGate; CNeuronBase *m_cInputGate; CNeuronBase *m_cNewContent; CNeuronBase *m_cOutputGate; CArrayObj *m_cMemorys; CArrayObj *m_cHiddenStates; CArrayObj *m_cInputs; CArrayObj *m_cForgetGateOuts; CArrayObj *m_cInputGateOuts; CArrayObj *m_cNewContentOuts; CArrayObj *m_cOutputGateOuts; CBufferDouble *m_cInputGradient; int m_iDepth; void ClearBuffer(CArrayObj *buffer); bool InsertBuffer(CArrayObj *&array, CBufferDouble *element, bool create_new = true); CBufferDouble *CreateBuffer(CArrayObj *&array); public: CNeuronLSTM(void); ~CNeuronLSTM(void); //--- virtual bool Init(CLayerDescription *desc); virtual bool SetOpenCL(CMyOpenCL *opencl); virtual bool FeedForward(CNeuronBase *prevLayer); virtual bool CalcHiddenGradient(CNeuronBase *prevLayer); virtual bool CalcDeltaWeights(CNeuronBase *prevLayer) { return true; } virtual bool UpdateWeights(int batch_size, double learningRate, double &Beta[], double &Lambda[]); //--- virtual int GetDepth(void) const { return m_iDepth; } //--- Методы работы с файлами virtual bool Save(const int file_handle); virtual bool Load(const int file_handle); //--- Метод идентификации объекта virtual int Type(void) const { return(defNeuronLSTM); } }; //+------------------------------------------------------------------+ //| Конструктор класса | //+------------------------------------------------------------------+ CNeuronLSTM::CNeuronLSTM(void) : m_iDepth(2) { m_cForgetGate = new CNeuronBase(); m_cInputGate = new CNeuronBase(); m_cNewContent = new CNeuronBase(); m_cOutputGate = new CNeuronBase(); m_cMemorys = new CArrayObj(); m_cHiddenStates = new CArrayObj(); m_cInputs = new CArrayObj(); m_cForgetGateOuts = new CArrayObj(); m_cInputGateOuts = new CArrayObj(); m_cNewContentOuts = new CArrayObj(); m_cOutputGateOuts = new CArrayObj(); m_cInputGradient = new CBufferDouble(); } //+------------------------------------------------------------------+ //| Деструктор класса | //+------------------------------------------------------------------+ CNeuronLSTM::~CNeuronLSTM(void) { if(m_cForgetGate) delete m_cForgetGate; if(m_cInputGate) delete m_cInputGate; if(m_cNewContent) delete m_cNewContent; if(m_cOutputGate) delete m_cOutputGate; if(m_cMemorys) delete m_cMemorys; if(m_cHiddenStates) delete m_cHiddenStates; if(m_cInputs) delete m_cInputs; if(m_cForgetGateOuts) delete m_cForgetGateOuts; if(m_cInputGateOuts) delete m_cInputGateOuts; if(m_cNewContentOuts) delete m_cNewContentOuts; if(m_cOutputGateOuts) delete m_cOutputGateOuts; if(m_cInputGradient) delete m_cInputGradient; } //+------------------------------------------------------------------+ //| Метод инициализации класса | //+------------------------------------------------------------------+ bool CNeuronLSTM::Init(CLayerDescription *desc) { //--- Блок контролей if(!desc || desc.type != Type() || desc.count <= 0 || desc.window == 0) return false; //--- Создаём описание для внутренних нейронных слоёв CLayerDescription *temp = new CLayerDescription(); if(!temp) return false; temp.type = defNeuronBase; temp.window = desc.window + desc.count; temp.count = desc.count; temp.activation = ACT_SIGMOID; temp.activation_params[0] = 1; temp.activation_params[1] = 0; temp.optimization = desc.optimization; //--- Вызываем метод инициализации родительского класса desc.window = 0; if(!CNeuronBase::Init(desc)) return false; m_iDepth = (int)fmax(desc.window_out, 2); //--- Инициализируем ForgetGate if(!m_cForgetGate) { m_cForgetGate = new CNeuronBase(); if(!m_cForgetGate) return false; } if(!m_cForgetGate.Init(temp)) return false; //--- Инициализируем InputGate if(CheckPointer(m_cInputGate) == POINTER_INVALID) { m_cInputGate = new CNeuronBase(); if(CheckPointer(m_cInputGate) == POINTER_INVALID) return false; } if(!m_cInputGate.Init(temp)) return false; //--- Инициализируем OutputGate if(CheckPointer(m_cOutputGate) == POINTER_INVALID) { m_cOutputGate = new CNeuronBase(); if(CheckPointer(m_cOutputGate) == POINTER_INVALID) return false; } if(!m_cOutputGate.Init(temp)) return false; //--- Инициализируем NewContent if(CheckPointer(m_cNewContent) == POINTER_INVALID) { m_cNewContent = new CNeuronBase(); if(CheckPointer(m_cNewContent) == POINTER_INVALID) return false; } temp.activation = ACT_TANH; if(!m_cNewContent.Init(temp)) return false; //--- Инициализируем буфер InputGradient if(CheckPointer(m_cInputGradient) == POINTER_INVALID) { m_cInputGradient = new CBufferDouble(); if(CheckPointer(m_cInputGradient) == POINTER_INVALID) return false; } if(!m_cInputGradient.BufferInit(temp.window, 0)) return false; delete temp; //--- Инициализируем Memory CBufferDouble *buffer = CreateBuffer(m_cMemorys); if(CheckPointer(buffer) == POINTER_INVALID) return false; if(m_cMemorys.Total() > 0) { if(!buffer.BufferInit(desc.count, 0)) { delete buffer; return false; } m_cMemorys.Clear(); } if(!m_cMemorys.Add(buffer)) { delete buffer; return false; } //--- Инициализируем HiddenStates buffer = CreateBuffer(m_cHiddenStates); if(CheckPointer(buffer) == POINTER_INVALID) return false; if(m_cHiddenStates.Total() > 0) { if(!buffer.BufferInit(desc.count, 0)) return false; m_cHiddenStates.Clear(); } if(!m_cHiddenStates.Add(buffer)) return false; //--- SetOpenCL(m_cOpenCL); //--- return true; } //+------------------------------------------------------------------+ //| Метод передачи указателя на объект OpenCL до всех | //| внутренних объектов | //+------------------------------------------------------------------+ bool CNeuronLSTM::SetOpenCL(CMyOpenCL *opencl) { //--- Вызов метода родительского класса CNeuronBase::SetOpenCL(opencl); //--- Вызываем аналогичный метод для всех внутренних слоёв if(!m_cForgetGate.SetOpenCL(m_cOpenCL) || m_cInputGate.SetOpenCL(m_cOpenCL) || m_cOutputGate.SetOpenCL(m_cOpenCL) || m_cNewContent.SetOpenCL(m_cOpenCL) || m_cInputGradient.BufferCreate(m_cOpenCL)) delete m_cOpenCL; //--- return(!!m_cOpenCL); } //+------------------------------------------------------------------+ //| Метод удаления из стека мзлишних данных | //+------------------------------------------------------------------+ void CNeuronLSTM::ClearBuffer(CArrayObj *buffer) { if(CheckPointer(buffer) == POINTER_INVALID) return; int total = buffer.Total(); if(total > m_iDepth + 1) buffer.DeleteRange(m_iDepth + 1, total); } //+------------------------------------------------------------------+ //| Метод прямого прохода | //+------------------------------------------------------------------+ bool CNeuronLSTM::FeedForward(CNeuronBase *prevLayer) { //--- Проверяем актуальность всех объектов if(CheckPointer(prevLayer) == POINTER_INVALID || CheckPointer(prevLayer.GetOutputs()) == POINTER_INVALID || CheckPointer(m_cOutputs) == POINTER_INVALID || CheckPointer(m_cForgetGate) == POINTER_INVALID || CheckPointer(m_cInputGate) == POINTER_INVALID || CheckPointer(m_cOutputGate) == POINTER_INVALID || CheckPointer(m_cNewContent) == POINTER_INVALID) return false; //--- Подготавиваем заготовки для новых буферов памяти и скрытого состояния CBufferDouble *memory = CreateBuffer(m_cMemorys); if(CheckPointer(memory) == POINTER_INVALID) return false; CBufferDouble *hidden = CreateBuffer(m_cHiddenStates); if(CheckPointer(hidden) == POINTER_INVALID) { delete memory; return false; } //--- Только для проверки градиента //memory.m_mMatrix.Fill(0); //hidden.m_mMatrix.Fill; //--- Создаём буфер исходных данных if(!m_cInputs) { m_cInputs = new CArrayObj(); if(!m_cInputs) { delete memory; delete hidden; return false; } } CNeuronBase *inputs = new CNeuronBase(); if(!inputs) { delete memory; delete hidden; return false; } CLayerDescription *desc = new CLayerDescription(); if(!desc) { delete inputs; delete memory; delete hidden; return false; } desc.type = defNeuronBase; desc.count = (int)(prevLayer.GetOutputs().Total() + m_cOutputs.Total()); desc.window = 0; if(!inputs.Init(desc)) { delete inputs; delete memory; delete hidden; return false; } delete desc; CBufferDouble *inputs_buffer = inputs.GetOutputs(); if(!inputs_buffer) { delete inputs; delete memory; delete hidden; return false; } inputs_buffer.m_mMatrix = prevLayer.GetOutputs().m_mMatrix; ulong shift = inputs_buffer.m_mMatrix.Cols(); ulong cols = hidden.m_mMatrix.Cols(); if(!inputs_buffer.m_mMatrix.Resize(inputs_buffer.m_mMatrix.Rows(), shift + cols)) { delete inputs; delete memory; delete hidden; return false; } for(ulong c = 0; c < cols; c++) if(!inputs_buffer.m_mMatrix.Col(hidden.m_mMatrix.Col(c), shift + c)) { delete inputs; delete memory; delete hidden; return false; } //--- Делаем прямой проход внутренних нейронных слоёв if(!m_cForgetGate.FeedForward(inputs)) { delete inputs; delete memory; delete hidden; return false; } if(!m_cInputGate.FeedForward(inputs)) { delete inputs; delete memory; delete hidden; return false; } if(!m_cOutputGate.FeedForward(inputs)) { delete inputs; delete memory; delete hidden; return false; } if(!m_cNewContent.FeedForward(inputs)) { delete inputs; delete memory; delete hidden; return false; } //--- Разветвление алгоритма по вычислительному устройству CBufferDouble *fg = m_cForgetGate.GetOutputs(); CBufferDouble *ig = m_cInputGate.GetOutputs(); CBufferDouble *og = m_cOutputGate.GetOutputs(); CBufferDouble *nc = m_cNewContent.GetOutputs(); if(!m_cOpenCL) { memory.m_mMatrix *= fg.m_mMatrix; memory.m_mMatrix += ig.m_mMatrix * nc.m_mMatrix; ulong total = memory.Total(); for(ulong i = 0; i < total; i++) if(!hidden.m_mMatrix.Flat(i, MathTanh(memory.m_mMatrix.Flat(i)) * og.m_mMatrix.Flat(i))) { delete inputs; delete memory; delete hidden; return false; } } else { //--- Создаём буферы if(!fg.BufferCreate(m_cOpenCL)) return false; if(!ig.BufferCreate(m_cOpenCL)) return false; if(!og.BufferCreate(m_cOpenCL)) return false; if(!nc.BufferCreate(m_cOpenCL)) return false; if(!memory.BufferCreate(m_cOpenCL)) return false; if(!hidden.BufferCreate(m_cOpenCL)) return false; //--- Передаём параметры кернелу if(!m_cOpenCL.SetArgumentBuffer(def_k_LSTMFeedForward, def_lstmff_forgetgate, fg.GetIndex())) return false; if(!m_cOpenCL.SetArgumentBuffer(def_k_LSTMFeedForward, def_lstmff_inputgate, ig.GetIndex())) return false; if(!m_cOpenCL.SetArgumentBuffer(def_k_LSTMFeedForward, def_lstmff_newcontent, nc.GetIndex())) return false; if(!m_cOpenCL.SetArgumentBuffer(def_k_LSTMFeedForward, def_lstmff_outputgate, og.GetIndex())) return false; if(!m_cOpenCL.SetArgumentBuffer(def_k_LSTMFeedForward, def_lstmff_memory, memory.GetIndex())) return false; if(!m_cOpenCL.SetArgumentBuffer(def_k_LSTMFeedForward, def_lstmff_hiddenstate, hidden.GetIndex())) return false; if(!m_cOpenCL.SetArgument(def_k_LSTMFeedForward, def_lstmff_outputs_total, m_cOutputs.Total())) return false; //--- Запуск кернела int NDRange[] = {(int)(m_cOutputs.Total() + 3) / 4}; int off_set[] = {0}; if(!m_cOpenCL.Execute(def_k_LSTMFeedForward, 1, off_set, NDRange)) return false; //--- Получаем результаты if(!memory.BufferRead()) return false; if(!hidden.BufferRead()) return false; } //--- Копируем скрытое состояние в буфер результатов нейронного слоя m_cOutputs.m_mMatrix = hidden.m_mMatrix; if(!!m_cOpenCL && !m_cOutputs.BufferWrite()) { delete inputs; delete memory; delete hidden; return false; } //--- Сохраним текущее состояние if(!m_cInputs.Insert(inputs, 0)) { delete inputs; delete memory; delete hidden; return false; } ClearBuffer(m_cInputs); if(!InsertBuffer(m_cForgetGateOuts, m_cForgetGate.GetOutputs())) { delete memory; delete hidden; return false; } if(!InsertBuffer(m_cInputGateOuts, m_cInputGate.GetOutputs())) { delete memory; delete hidden; return false; } if(!InsertBuffer(m_cOutputGateOuts, m_cOutputGate.GetOutputs())) { delete memory; delete hidden; return false; } if(!InsertBuffer(m_cNewContentOuts, m_cNewContent.GetOutputs())) { delete memory; delete hidden; return false; } if(!InsertBuffer(m_cMemorys, memory, false)) { delete hidden; return false; } if(!InsertBuffer(m_cHiddenStates, hidden, false)) return false; //--- return true; } //+------------------------------------------------------------------+ //| Метод добавления данных в стек | //+------------------------------------------------------------------+ bool CNeuronLSTM::InsertBuffer(CArrayObj *&array, CBufferDouble *element, bool create_new = true) { //--- Блок контролей if(CheckPointer(element) == POINTER_INVALID) return false; if(CheckPointer(array) == POINTER_INVALID) { array = new CArrayObj(); if(CheckPointer(array) == POINTER_INVALID) return false; } //--- if(create_new) { CBufferDouble *buffer = new CBufferDouble(); if(CheckPointer(buffer) == POINTER_INVALID) return false; buffer.m_mMatrix = element.m_mMatrix; if(!array.Insert(buffer, 0)) { delete buffer; return false; } } else { if(!array.Insert(element, 0)) { delete element; return false; } } //--- Удалим из буфера излишнюю историю ClearBuffer(array); //--- return true; } //+------------------------------------------------------------------+ //| Метод создания нового буфера данных | //+------------------------------------------------------------------+ CBufferDouble *CNeuronLSTM::CreateBuffer(CArrayObj *&array) { if(CheckPointer(array) == POINTER_INVALID) { array = new CArrayObj(); if(CheckPointer(array) == POINTER_INVALID) return NULL; } CBufferDouble *buffer = new CBufferDouble(); if(CheckPointer(buffer) == POINTER_INVALID) return NULL; if(!buffer.BufferInit(m_cOutputs.Rows(), m_cOutputs.Cols(), 0)) { delete buffer; return NULL; } if(m_cOpenCL) { if(!buffer.BufferCreate(m_cOpenCL)) delete buffer; } //--- return buffer; } //+------------------------------------------------------------------+ //| Метод распределения градиента ошибки через скрытый слой | //+------------------------------------------------------------------+ bool CNeuronLSTM::CalcHiddenGradient(CNeuronBase *prevLayer) { //--- Проверяем актуальность всех объектов if(CheckPointer(prevLayer) == POINTER_INVALID || CheckPointer(prevLayer.GetGradients()) == POINTER_INVALID || CheckPointer(m_cGradients) == POINTER_INVALID || CheckPointer(m_cForgetGate) == POINTER_INVALID || CheckPointer(m_cForgetGateOuts) == POINTER_INVALID || CheckPointer(m_cInputGate) == POINTER_INVALID || CheckPointer(m_cInputGateOuts) == POINTER_INVALID || CheckPointer(m_cOutputGate) == POINTER_INVALID || CheckPointer(m_cOutputGateOuts) == POINTER_INVALID || CheckPointer(m_cNewContent) == POINTER_INVALID || CheckPointer(m_cNewContentOuts) == POINTER_INVALID) return false; //--- Проверяем наличие данных прямого прохода int total = (int)fmin(m_cMemorys.Total(), m_cHiddenStates.Total()) - 1; if(total <= 0) return false; //--- Делаем укзатели на буферы градиентов и результатов внутренних слоёв CBufferDouble *fg_grad = m_cForgetGate.GetGradients(); if(CheckPointer(fg_grad) == POINTER_INVALID) return false; CBufferDouble *fg_out = m_cForgetGate.GetOutputs(); if(CheckPointer(fg_out) == POINTER_INVALID) return false; CBufferDouble *ig_grad = m_cInputGate.GetGradients(); if(CheckPointer(ig_grad) == POINTER_INVALID) return false; CBufferDouble *ig_out = m_cInputGate.GetOutputs(); if(CheckPointer(ig_out) == POINTER_INVALID) return false; CBufferDouble *og_grad = m_cOutputGate.GetGradients(); if(CheckPointer(og_grad) == POINTER_INVALID) return false; CBufferDouble *og_out = m_cOutputGate.GetOutputs(); if(CheckPointer(og_out) == POINTER_INVALID) return false; CBufferDouble *nc_grad = m_cNewContent.GetGradients(); if(CheckPointer(nc_grad) == POINTER_INVALID) return false; CBufferDouble *nc_out = m_cNewContent.GetOutputs(); if(CheckPointer(nc_out) == POINTER_INVALID) return false; //--- uint out_total = m_cOutputs.Total(); //--- Цикл перебора накопленной истории for(int i = 0; i < total; i++) { //--- Получаем указатели на буферы из стека CBufferDouble *fg = m_cForgetGateOuts.At(i); if(CheckPointer(fg) == POINTER_INVALID) return false; CBufferDouble *ig = m_cInputGateOuts.At(i); if(CheckPointer(ig) == POINTER_INVALID) return false; CBufferDouble *og = m_cOutputGateOuts.At(i); if(CheckPointer(og) == POINTER_INVALID) return false; CBufferDouble *nc = m_cNewContentOuts.At(i); if(CheckPointer(nc) == POINTER_INVALID) return false; CBufferDouble *memory = m_cMemorys.At(i + 1); if(CheckPointer(memory) == POINTER_INVALID) return false; CBufferDouble *hidden = m_cHiddenStates.At(i); if(CheckPointer(hidden) == POINTER_INVALID) return false; CNeuronBase *inputs = m_cInputs.At(i); if(CheckPointer(inputs) == POINTER_INVALID) return false; //--- Разветвление алгоритма по вычислительному устройству if(CheckPointer(m_cOpenCL) == POINTER_INVALID) { //--- Посчитаем градиент на выходе каждого внутреннего слоя MATRIX m = hidden.m_mMatrix / (og.m_mMatrix + 1e-8); //--- OutputGate градиент MATRIX grad = m_cGradients.m_mMatrix; og_grad.m_mMatrix = grad * m; //--- Градиент памяти grad *= og.m_mMatrix; //--- Скорректируем градиент на производную grad *= 1 - m.Power(2); //--- InputGate градиент ig_grad.m_mMatrix = grad * nc.m_mMatrix; //--- NewContent градиент nc_grad.m_mMatrix = grad * ig.m_mMatrix; //--- ForgetGates градиент fg_grad.m_mMatrix = grad * memory.m_mMatrix; } else { //--- Создаём буферы if(hidden.GetIndex() < 0) return false; if(m_cGradients.GetIndex() < 0) return false; if(ig.GetIndex() < 0) return false; if(og.GetIndex() < 0) return false; if(nc.GetIndex() < 0) return false; if(memory.GetIndex() < 0) return false; if(fg_grad.GetIndex() < 0) return false; if(ig_grad.GetIndex() < 0) return false; if(og_grad.GetIndex() < 0) return false; if(nc_grad.GetIndex() < 0) return false; //--- Передаём параметры кернелу if(!m_cOpenCL.SetArgumentBuffer(def_k_LSTMHiddenGradients, def_lstmhgr_fg_gradients, fg_grad.GetIndex())) return false; if(!m_cOpenCL.SetArgumentBuffer(def_k_LSTMHiddenGradients, def_lstmhgr_gradients, m_cGradients.GetIndex())) return false; if(!m_cOpenCL.SetArgumentBuffer(def_k_LSTMHiddenGradients, def_lstmhgr_ig_gradients, ig_grad.GetIndex())) return false; if(!m_cOpenCL.SetArgumentBuffer(def_k_LSTMHiddenGradients, def_lstmhgr_inputgate, ig.GetIndex())) return false; if(!m_cOpenCL.SetArgumentBuffer(def_k_LSTMHiddenGradients, def_lstmhgr_memory, memory.GetIndex())) return false; if(!m_cOpenCL.SetArgumentBuffer(def_k_LSTMHiddenGradients, def_lstmhgr_nc_gradients, nc_grad.GetIndex())) return false; if(!m_cOpenCL.SetArgumentBuffer(def_k_LSTMHiddenGradients, def_lstmhgr_newcontent, nc.GetIndex())) return false; if(!m_cOpenCL.SetArgumentBuffer(def_k_LSTMHiddenGradients, def_lstmhgr_og_gradients, og_grad.GetIndex())) return false; if(!m_cOpenCL.SetArgumentBuffer(def_k_LSTMHiddenGradients, def_lstmhgr_outputgate, og.GetIndex())) return false; if(!m_cOpenCL.SetArgumentBuffer(def_k_LSTMHiddenGradients, def_lstmhgr_outputs, hidden.GetIndex())) return false; if(!m_cOpenCL.SetArgument(def_k_LSTMHiddenGradients, def_lstmhgr_outputs_total, m_cOutputs.Total())) return false; //--- Запуск кернела int NDRange[] = { (int)(m_cOutputs.Total() + 3) / 4 }; int off_set[] = {0}; if(!m_cOpenCL.Execute(def_k_LSTMHiddenGradients, 1, off_set, NDRange)) return false; //--- Получаем результаты if(!fg_grad.BufferRead()) return false; if(!ig_grad.BufferRead()) return false; if(!og_grad.BufferRead()) return false; if(!nc_grad.BufferRead()) return false; } //--- Скопируем соответсвующие исторические данные в буфера внутренних слоёв fg_out.m_mMatrix = fg.m_mMatrix; ig_out.m_mMatrix = ig.m_mMatrix; og_out.m_mMatrix = og.m_mMatrix; nc_out.m_mMatrix = nc.m_mMatrix; //--- Проведём градиент через внутренние слои if(!m_cForgetGate.CalcHiddenGradient(inputs)) return false; if(!m_cInputGradient) { m_cInputGradient = new CBufferDouble(); if(CheckPointer(m_cInputGradient) == POINTER_INVALID) return false; } m_cInputGradient.m_mMatrix = inputs.GetGradients().m_mMatrix; if(!m_cInputGate.CalcHiddenGradient(inputs)) return false; if(!m_cInputGradient.SumArray(inputs.GetGradients())) return false; if(!m_cOutputGate.CalcHiddenGradient(inputs)) return false; if(!m_cInputGradient.SumArray(inputs.GetGradients())) return false; if(!m_cNewContent.CalcHiddenGradient(inputs)) return false; if(!inputs.GetGradients().SumArray(m_cInputGradient)) return false; //--- Спроэцируем градиент на матрицы весов внутренних слоёв if(!m_cForgetGate.CalcDeltaWeights(inputs)) return false; if(!m_cInputGate.CalcDeltaWeights(inputs)) return false; if(!m_cOutputGate.CalcDeltaWeights(inputs)) return false; if(!m_cNewContent.CalcDeltaWeights(inputs)) return false; //--- Если посчитан градиент текущего состояния, то передаём на предыдущий слой ulong split[] = {prevLayer.GetGradients().Cols()}; MATRIX m[]; if(!inputs.GetGradients().m_mMatrix.Vsplit(split, m)) return false; if(i == 0) { CBufferDouble *prevLayer_grad = prevLayer.GetGradients(); prevLayer_grad.m_mMatrix = m[0]; if(m_cOpenCL && !prevLayer_grad.BufferWrite()) return false; } //--- Запишем градиент скрытого состояния в буфер градиентов для новой итерации m_cGradients.m_mMatrix = m[1]; if(m_cOpenCL && !m_cGradients.BufferWrite()) return false; } //--- return true; } //+------------------------------------------------------------------+ //| Метод обновления матриц весовых коэффициентов | //+------------------------------------------------------------------+ bool CNeuronLSTM::UpdateWeights(int batch_size, double learningRate, double &Beta[], double &Lambda[]) { //--- Проверяем состояние объектов if(CheckPointer(m_cForgetGate) == POINTER_INVALID || CheckPointer(m_cInputGate) == POINTER_INVALID || CheckPointer(m_cOutputGate) == POINTER_INVALID || CheckPointer(m_cNewContent) == POINTER_INVALID || m_iDepth <= 0) return false; int batch = batch_size * m_iDepth; //--- Обновляем матрицы весов внутренних слоёв if(!m_cForgetGate.UpdateWeights(batch, learningRate, Beta, Lambda)) return false; if(!m_cInputGate.UpdateWeights(batch, learningRate, Beta, Lambda)) return false; if(!m_cOutputGate.UpdateWeights(batch, learningRate, Beta, Lambda)) return false; if(!m_cNewContent.UpdateWeights(batch, learningRate, Beta, Lambda)) return false; //--- return true; } //+------------------------------------------------------------------+ //| Метод сохранениия элементов класса в файл | //+------------------------------------------------------------------+ bool CNeuronLSTM::Save(const int file_handle) { //--- Вызов метода родительского класса if(!CNeuronBase::Save(file_handle)) return false; //--- Созраняем константы if(FileWriteInteger(file_handle, m_iDepth) <= 0) return false; //--- Вызываем аналогичный метод для всех внутренних слоёв if(!m_cForgetGate.Save(file_handle)) return false; if(!m_cInputGate.Save(file_handle)) return false; if(!m_cOutputGate.Save(file_handle)) return false; if(!m_cNewContent.Save(file_handle)) return false; //--- return true; } //+------------------------------------------------------------------+ //| Метод восстановления класса из файла | //+------------------------------------------------------------------+ bool CNeuronLSTM::Load(const int file_handle) { //--- Вызов метода родительского класса if(!CNeuronBase::Load(file_handle)) return false; //--- Считываем константы m_iDepth = FileReadInteger(file_handle); //--- Вызываем аналогичный метод для всех внутренних слоёв if(FileReadInteger(file_handle) != defNeuronBase || !m_cForgetGate.Load(file_handle)) return false; if(FileReadInteger(file_handle) != defNeuronBase || !m_cInputGate.Load(file_handle)) return false; if(FileReadInteger(file_handle) != defNeuronBase || !m_cOutputGate.Load(file_handle)) return false; if(FileReadInteger(file_handle) != defNeuronBase || !m_cNewContent.Load(file_handle)) return false; //--- Инициализируем буфер InputGradient if(CheckPointer(m_cInputGradient) == POINTER_INVALID) { m_cInputGradient = new CBufferDouble(); if(CheckPointer(m_cInputGradient) == POINTER_INVALID) return false; } //--- Инициализируем Memory CBufferDouble *buffer = CreateBuffer(m_cMemorys); if(CheckPointer(buffer) == POINTER_INVALID) return false; if(m_cMemorys.Total() > 0) { if(!buffer.BufferInit(m_cOutputs.Total(), 0)) return false; m_cMemorys.Clear(); } if(!m_cMemorys.Add(buffer)) return false; //--- Инициализируем HiddenStates buffer = CreateBuffer(m_cHiddenStates); if(CheckPointer(buffer) == POINTER_INVALID) return false; if(m_cHiddenStates.Total() > 0) { if(!buffer.BufferInit(m_cOutputs.Total(), 0)) return false; m_cHiddenStates.Clear(); } if(!m_cHiddenStates.Add(buffer)) return false; //--- Очищаем остальные стеки if(CheckPointer(m_cInputs) != POINTER_INVALID) m_cInputs.Clear(); if(CheckPointer(m_cForgetGateOuts) != POINTER_INVALID) m_cForgetGateOuts.Clear(); if(CheckPointer(m_cInputGateOuts) != POINTER_INVALID) m_cInputGateOuts.Clear(); if(CheckPointer(m_cNewContentOuts) != POINTER_INVALID) m_cNewContentOuts.Clear(); if(CheckPointer(m_cOutputGateOuts) != POINTER_INVALID) m_cOutputGateOuts.Clear(); //--- return true; } //+------------------------------------------------------------------+