贵州企业网站建设设计wordpress 培训机构

回调函数的实现

在消息队列和网络库的框架中，当接收到消息（报文）时，回调用户自定义的函数对象，把消息（报文）参数传给它，由它决定如何处理。

queue参考文章:C++ queue(STL queue，队列)用法详解_queue c++ 用法-CSDN博客

代码示例：

#include <iostream>#include <string>#include <thread>                      // 线程类头文件。#include <mutex>                      // 互斥锁类的头文件。#include <deque>                      // deque容器的头文件。#include <queue>                      // queue容器的头文件。#include <condition_variable>  // 条件变量的头文件。#include <functional>using namespace std;void show(const string& message) {  // 处理业务的普通函数cout << "处理数据：" << message << endl;}struct BB {  // 处理业务的类void show(const string& message) {cout << "处理表白数据：" << message << endl;}};class AA{mutex m_mutex;                                    // 互斥锁。condition_variable m_cond;                  // 条件变量。queue<string, deque<string>> m_q;   // 缓存队列，底层容器用deque。function<void(const string&)> m_callback;  // 回调函数对象。public:// 注册回调函数，回调函数只有一个参数（消费者接收到的数据）。template<typename Fn, typename ...Args>void callback(Fn && fn, Args&&...args) {m_callback = bind(forward<Fn>(fn), forward<Args>(args)..., std::placeholders::_1);  // 绑定回调函数。}void incache(int num)     // 生产数据，num指定数据的个数。{lock_guard<mutex> lock(m_mutex);   // 申请加锁。for (int ii = 0; ii < num; ii++){static int bh = 1;           // 编号。string message = to_string(bh++) + "号";    // 拼接出一个数据。m_q.push(message);     // 把生产出来的数据入队。}//m_cond.notify_one();     // 唤醒一个被当前条件变量阻塞的线程。m_cond.notify_all();          // 唤醒全部被当前条件变量阻塞的线程。}void outcache() {    // 消费者线程任务函数。while (true) {// 把互斥锁转换成unique_lock<mutex>，并申请加锁。unique_lock<mutex> lock(m_mutex);// 1）把互斥锁解开；2）阻塞，等待被唤醒；3）给互斥锁加锁。m_cond.wait(lock, [this] { return !m_q.empty(); });// 数据元素出队。string message = m_q.front();  m_q.pop();cout << "线程：" << this_thread::get_id() << "，" << message << endl;lock.unlock();      // 手工解锁。// 处理出队的数据（把数据消费掉）。if (m_callback) m_callback(message);  // 回调函数，把收到的数据传给它。}}};int main(){AA aa;// aa.callback(show);                   // 把普通函数show()注册为回调函数。BB bb;aa.callback(&BB::show, &bb);    // 把类成员函数BB::show()注册为回调函数。thread t1(&AA::outcache, &aa);     // 创建消费者线程t1。thread t2(&AA::outcache, &aa);     // 创建消费者线程t2。thread t3(&AA::outcache, &aa);     // 创建消费者线程t3。this_thread::sleep_for(chrono::seconds(2));    // 休眠2秒。aa.incache(2);      // 生产2个数据。this_thread::sleep_for(chrono::seconds(3));    // 休眠3秒。aa.incache(5);      // 生产5个数据。t1.join();   // 回收子线程的资源。t2.join();t3.join();}

注:此课件及源代码来自B站up主:码农论坛,该文章仅作为本人学习笔记及交流学习使用。