Add new class

DesktopEditor/graphics/BaseThreadMonitor.cpp

@@ -0,0 +1,111 @@
+/*
+ * (c) Copyright Ascensio System SIA 2010-2023
+ *
+ * This program is a free software product. You can redistribute it and/or
+ * modify it under the terms of the GNU Affero General Public License (AGPL)
+ * version 3 as published by the Free Software Foundation. In accordance with
+ * Section 7(a) of the GNU AGPL its Section 15 shall be amended to the effect
+ * that Ascensio System SIA expressly excludes the warranty of non-infringement
+ * of any third-party rights.
+ *
+ * This program is distributed WITHOUT ANY WARRANTY; without even the implied
+ * warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR  PURPOSE. For
+ * details, see the GNU AGPL at: http://www.gnu.org/licenses/agpl-3.0.html
+ *
+ * You can contact Ascensio System SIA at 20A-6 Ernesta Birznieka-Upish
+ * street, Riga, Latvia, EU, LV-1050.
+ *
+ * The  interactive user interfaces in modified source and object code versions
+ * of the Program must display Appropriate Legal Notices, as required under
+ * Section 5 of the GNU AGPL version 3.
+ *
+ * Pursuant to Section 7(b) of the License you must retain the original Product
+ * logo when distributing the program. Pursuant to Section 7(e) we decline to
+ * grant you any rights under trademark law for use of our trademarks.
+ *
+ * All the Product's GUI elements, including illustrations and icon sets, as
+ * well as technical writing content are licensed under the terms of the
+ * Creative Commons Attribution-ShareAlike 4.0 International. See the License
+ * terms at http://creativecommons.org/licenses/by-sa/4.0/legalcode
+ *
+ */
+
+#include "./BaseThreadMonitor.h"
+
+namespace NSThreads
+{
+	CBaseThreadMonitor::CBaseThreadMonitor()
+	{
+		m_bIsInit = false;
+		m_pReceiver = NULL;
+		m_funcRelease = nullptr;
+
+		m_oCS.InitializeCriticalSection();
+	}
+
+	CBaseThreadMonitor::~CBaseThreadMonitor()
+	{
+		m_oCS.DeleteCriticalSection();
+	}
+
+	bool CBaseThreadMonitor::Init(void* receiver)
+	{
+		CTemporaryCS oCS(&m_oCS);
+
+		if (m_bIsInit)
+			return false;
+
+		m_pReceiver = receiver;
+	}
+
+	bool CBaseThreadMonitor::Destroy()
+	{
+		CTemporaryCS oCS(&m_oCS);
+
+		m_bIsInit = false;
+		m_pReceiver = NULL;
+	}
+
+	bool CBaseThreadMonitor::IsInit()
+	{
+		CTemporaryCS oCS(&m_oCS);
+		return m_bIsInit;
+	}
+
+	void CBaseThreadMonitor::EnterCS()
+	{
+		m_oCS.Enter();
+	}
+	void CBaseThreadMonitor::LeaveCS()
+	{
+		m_oCS.Leave();
+	}
+
+	CBaseThread* CBaseThreadMonitor::GetBaseThread(const ASC_THREAD_ID& nThreadId)
+	{
+		return NULL;
+	}
+
+	void CBaseThreadMonitor::SetReleaseHandler(std::function<void(void* initializer, CBaseThread*)> func)
+	{
+		CTemporaryCS oCS(&m_oCS);
+		m_funcRelease = func;
+	}
+
+	void CBaseThreadMonitor::Register(CBaseThread* pInstance)
+	{
+		m_listThreads.push_back({NSThreads::GetCurrentThreadId(), pInstance});
+	}
+
+	void CBaseThreadMonitor::Unregister(CBaseThread* pInstance)
+	{
+		for (std::list<CBaseThreadInfo>::iterator i = m_listThreads.begin(); i != m_listThreads.end(); i++)
+		{
+			if (i->Instance == pInstance)
+			{
+				m_listThreads.erase(i);
+				return;
+			}
+		}
+	}
+}