From 66200c6f7a60a084a2d66081c04b5561094985de Mon Sep 17 00:00:00 2001
From: goldenhawking <goldenhawking@163.com>
Date: Sat, 16 Mar 2024 17:47:29 +0800
Subject: [PATCH] =?UTF-8?q?=E8=A7=A3=E5=86=B3=E5=A4=9A=E7=BA=BF=E7=A8=8B?=
 =?UTF-8?q?=E6=93=8D=E4=BD=9CQList=E7=9A=84Bug?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 taskbusplatform/core/taskproject.cpp | 6 ++++++
 taskbusplatform/core/taskproject.h   | 2 ++
 2 files changed, 8 insertions(+)

diff --git a/taskbusplatform/core/taskproject.cpp b/taskbusplatform/core/taskproject.cpp
index 831df13..b9e7198 100644
--- a/taskbusplatform/core/taskproject.cpp
+++ b/taskbusplatform/core/taskproject.cpp
@@ -990,8 +990,10 @@ void taskProject::timerEvent(QTimerEvent * evt)
 
 void taskProject::push_msg(QString smsg)
 {
+	m_mtxMsg.lock();
 	m_bufferMsgs.push_back(QByteArray::fromStdString(smsg.toStdString()));
 	m_bufferMsgSources.push_back(QString("Project:"));
+	m_mtxMsg.unlock();
 }
 void taskProject::send_msg(QString smsgSource, QByteArrayList lst)
 {
@@ -1004,8 +1006,10 @@ void taskProject::send_msg(QString smsgSource, QByteArrayList lst)
 	last_ck = curr_ck;
 
 	const int szMsgs = lst.size();
+	m_mtxMsg.lock();
 	for(int i=0;i<szMsgs;++i)
 		m_bufferMsgSources.push_back(smsgSource);
+	m_mtxMsg.unlock();
 	m_bufferMsgs.append(lst);
 
 	if (keep==false)
@@ -1014,10 +1018,12 @@ void taskProject::send_msg(QString smsgSource, QByteArrayList lst)
 }
 void taskProject::flush_msg()
 {
+	m_mtxMsg.lock();
 	if (m_bufferMsgs.size())
 	{
 		emit sig_message(m_bufferMsgSources,m_bufferMsgs);
 		m_bufferMsgSources.clear();
 		m_bufferMsgs.clear();
 	}
+	m_mtxMsg.unlock();
 }
diff --git a/taskbusplatform/core/taskproject.h b/taskbusplatform/core/taskproject.h
index 0195726..c96de6f 100644
--- a/taskbusplatform/core/taskproject.h
+++ b/taskbusplatform/core/taskproject.h
@@ -16,6 +16,7 @@
 #include <QVariant>
 #include <QByteArrayList>
 #include <functional>
+#include <QMutex>
 class taskCell;
 class taskNode;
 /*!
@@ -167,6 +168,7 @@ protected:
 	int m_nTimerID = -1;
 	QByteArrayList m_bufferMsgs;
 	QStringList    m_bufferMsgSources;
+	QMutex m_mtxMsg;
 	void timerEvent(QTimerEvent * evt) override;
 	void push_msg(QString smsg);
 	void send_msg(QString smsgSource, QByteArrayList lst);
-- 
GitLab