#include<iostream> #include<thread> #include<vector> #include<string> #include<mutex> #include<list> using namespace std; class A { public: //把收到的消息（玩家命令）入到一个队列的线程。 void inMsgRecvQueue() { for (int i = 0; i < 10000; i++) { cout << "inMsgRecvQueue()执行，插入一个元素" << i << endl; std::unique_lock<std::mutex>sbguard(my_mutex1); msgRecvQueue.push_back(i);//假设数字i就是玩家收到的命令，我直接弄到消息队列里面 //假如outMsgRecvQueue（）正在处理一个事务，需要一段时间，而不是正卡在wait()那里等待，那么此时这个notifu_one()没有效果。 mycond.notify_one();//我们尝试吧wait()的线程唤醒，执行完这行，那么outMsgRecvQueue（）的wait就会被唤醒，之后的事情后续研究。 //其他处理代码 } return; }
//bool outMsgLULProc(int& command) { // // std::unique_lock<std::mutex> sbguard1(my_mutex1); // if (!msgRecvQueue.empty()) { // //消息队列不会空 // command = msgRecvQueue.front();//返回第一个元素，但不检查元素是否存在 // msgRecvQueue.pop_front();//移除第一个元素。但不返回。 // return true; // } // return false; //}
//把数据从消息队列中取出的线程： void outMsgRecvQueue() { int command = 0; while (1) { std::unique_lock<std::mutex> sbguard1(my_mutex1);
//wait（）是用来等一个东西， //如果第二个参数返回值为true，那wait（）直接返回，程序继续往下走。 //如果第二个参数的也就是lambda返回值是false，那么wait将解锁互斥量，并堵塞到本行。 // 等到什么时候为止呢，堵塞到其他某个线程调用notify_one（）成员函数为止， //如果wait（）没有第二个参数，mycond.wait(sbguard1），那么就跟第二个参数返回false效果一样（堵塞到本行） // wait（）将解锁互斥量并堵塞到本行。堵塞到其他某个线程调用notifu_one()成员函数为止 //当其他线程用notifu_one（）将本wait（原来是睡着/堵塞）的状态后，ait开始恢复干活了，恢复后wait干什么活？ // a)不断的尝试重新获取互斥量锁，如果获取不到，流程就卡在wait这里等着获取，如果获取互斥锁，wait就继续执行b // b) // b.1)如果wait有第二个参数（lambda），就判断这个lambda表达式，如果lambda为false，那么wait又对互斥量进行解锁，堵塞到本行,等待再次被唤醒。 // b.2)如果lambda表达式为true，则wait返回，流程走下来（此时互斥锁被锁着）。 // b.3)如果wait没有第二个参数，则wait返回，流程走下来 mycond.wait(sbguard1, [this]() {//一个lambda就是一个可调用对象（函数） if (!msgRecvQueue.empty()) { return true; } else { return false; } }); //流程只要能走到这里，这个互斥锁一定是锁着的,同时msgRecvQueue至少是有一条数据的 //一会再写其他的 command = msgRecvQueue.front(); msgRecvQueue.pop_front(); sbguard1.unlock();//因为unique_lock的灵活性，所以我们可以随时的unlock解锁，以免锁住太长时间。 cout << "outMsgRecvQueue取出一个元素" << command << endl;
//执行一些具体动作，帮助玩家抽卡，抽卡需要100ms处理时间； //... //执行100毫秒 }
//for (int i = 0; i < 10000; i++) { // bool result = outMsgLULProc(command); // if (result == true) { // cout << "outMsgRecvQueue执行了，取出一个元素，并且移除了一个元素" << command << endl; // //可以进行数据处理 // } // else // { // cout << "outMsgRecvQueue()执行，但目前消息队列为空" << i << endl; // } //} cout << "end" << endl; } private: std::list<int> msgRecvQueue;//容器，专门用于代表玩家给咱们发送的命令 std::mutex my_mutex1;//创建了一个互斥量、 std::condition_variable mycond;//生成一个条件变量对象。需要和互斥量配合使用 }; int main() { /* （1）条件变量（是一个类）std::condition_variable、wait()、notify_one()：通知一个线程 * 线程A：等待一个条件满足 * 线程B：专门往消息队列中扔数据，扔完数据后，队列有消息了，然后通知线程A有数据了，线程A再从等待的这行语句中继续往下执行。 std::condition_variable实际上是一个类；是一个和条件相关的一个类，说白了就是等待一个条件达成，这个类是需要和互斥量来配合工作 用的时候我们要生成这个类的对象。详解见上面注释 （2）上述代码深入思考 仔细分析，一步一步测试，减少bug （3）notify_all() 两个线程干不同的活，都卡在wait（），都希望被唤醒，用notifl_all()，同时唤醒所有睡眠的进程， */ A myobja; std::thread mytobj(&A::outMsgRecvQueue, &myobja);//第二个参数是引用，才能保证线程里用的是同一个对象。 std::thread mytobj2(&A::inMsgRecvQueue, &myobja); mytobj.join(); mytobj2.join();
cout << "666" << endl;
return 0; }
