需求:
不同线程,或者同一线程的不同类之间通信,按照Qt的机制,定义一个信号,一个槽,然后绑定。以两个类A,B为例,A触发一个信号,B执行一个槽,在定义好信号和槽之后,需要在另一处,将两个类的信号和槽进行绑定。如果模块特别多,绑了绑去 略显麻烦,耦合性太高。
此处分享一个类,别人写的,忘记了在哪看到的。可以将上述问题解决,降低耦合性。
使用:
1,A B两个类都需要包含头文件。#include "PSEventController.h"
2, A类中触发的地方,调用publish函数。
//比如按下按钮 ,需提供一个唯一的标识字符串,可自定义参数
PSEventController::publish(actionName.toLatin1(),Q_ARG(bool,isChecked));
3,B类中 定义 on_psEvent_xxx 函数,并实现。
//此处的addLine 即为上述pulish 函数中的第一个参数,isChecked 为publis中的第二个参数
void on_psEvent_addLine(bool isChecked);
4,B类中初始化的时候 执行 subscribe 函数。
PSEventController::subscribe(this,"addLine");
这样,A 和B 两个类 发布和订阅的唯一字符串标识符只要一致,A 在pubsh 的时候 B 就可以subscribe到,并且A 和B 完全耦合,相互不可见。
具体代码:
//PSEventController.h
#ifndef PSEVENTCONTROLLER_H
#define PSEVENTCONTROLLER_H#include <QObject>
#include <QReadWriteLock>
#include <QMap>
#include <QList>#define METHOD_PREFIX "on_psEvent_"class PSEventController : public QObject
{Q_OBJECT
public:static void unSubscribe(QObject* listener, const QByteArray& eventName);static bool subscribe(QObject* listener, const QByteArray& eventName);static bool publish(const QByteArray& eventName, Qt::ConnectionType connectionType,QGenericArgument val0 = QGenericArgument(), QGenericArgument val1 = QGenericArgument(),QGenericArgument val2 = QGenericArgument(), QGenericArgument val3 = QGenericArgument(),QGenericArgument val4 = QGenericArgument(), QGenericArgument val5 = QGenericArgument(),QGenericArgument val6 = QGenericArgument(), QGenericArgument val7 = QGenericArgument(),QGenericArgument val8 = QGenericArgument(), QGenericArgument val9 = QGenericArgument());static inline bool publish(const QByteArray& eventName,QGenericArgument val0 = QGenericArgument(), QGenericArgument val1 = QGenericArgument(),QGenericArgument val2 = QGenericArgument(), QGenericArgument val3 = QGenericArgument(),QGenericArgument val4 = QGenericArgument(), QGenericArgument val5 = QGenericArgument(),QGenericArgument val6 = QGenericArgument(), QGenericArgument val7 = QGenericArgument(),QGenericArgument val8 = QGenericArgument(), QGenericArgument val9 = QGenericArgument()){return publish(eventName, Qt::AutoConnection, val0, val1, val2, val3, val4, val5, val6, val7, val8, val9);}static inline QString get_Errors(){return ps_LastError_;}static inline void clearEvents(){QWriteLocker locker(&ps_Lock_);psEvents_pool_.clear();}static inline QByteArray methodFormatting(const QByteArray& eventName) {return METHOD_PREFIX + eventName;}
private:static QMap<QByteArray, QList<QObject*>> psEvents_pool_;static QReadWriteLock ps_Lock_;static QString ps_LastError_;
};#endif // PSEVENTCONTROLLER_H
//PSEventController.cpp
#include "PSEventController.h"
#include <QWriteLocker>QMap<QByteArray, QList<QObject*>> PSEventController::psEvents_pool_;
QReadWriteLock PSEventController::ps_Lock_;
QString PSEventController::ps_LastError_;void PSEventController::unSubscribe(QObject* listener, const QByteArray& eventName)
{QWriteLocker locker(&ps_Lock_);int index = -1;if (psEvents_pool_.contains(eventName) &&(index = psEvents_pool_[eventName].indexOf(listener)) >= 0 && index < psEvents_pool_[eventName].count())psEvents_pool_[eventName].takeAt(index);
}bool PSEventController::subscribe(QObject* listener, const QByteArray& eventName)
{QWriteLocker locker(&ps_Lock_);if (psEvents_pool_.contains(eventName)) {if (-1 != psEvents_pool_[eventName].indexOf(listener)) {ps_LastError_ = QString("This object is subscribed to this eventName");return false;}psEvents_pool_[eventName].push_back(listener);return true;} else {psEvents_pool_.insert(eventName, { listener });return true;}
}bool PSEventController::publish(const QByteArray& eventName, Qt::ConnectionType connectionType,QGenericArgument val0, QGenericArgument val1, QGenericArgument val2, QGenericArgument val3,QGenericArgument val4, QGenericArgument val5, QGenericArgument val6, QGenericArgument val7,QGenericArgument val8, QGenericArgument val9)
{QReadLocker locker(&ps_Lock_);if (!psEvents_pool_.contains(eventName)) {ps_LastError_ = QString("No objects subscribe to this eventName");return false;}auto methodName = methodFormatting(eventName);QStringList errors;for (auto listener : psEvents_pool_[eventName]) {if (!listener)continue;auto ret = QMetaObject::invokeMethod(listener, methodName, connectionType,val0, val1, val2, val3, val4, val5, val6, val7, val8, val9);if (!ret)errors.append(QString("%1:%2").arg(listener->metaObject()->className()).arg(listener->objectName()));}if (errors.isEmpty())return true;ps_LastError_ = QString("%1 execution failed:[\n").arg(QString(eventName));for (auto& err : errors)ps_LastError_ += QString("%1;\n").arg(err);ps_LastError_ += "]\n";return false;
}