前几天一直没想明白，搜索我的记忆海，愣是没找到这种三个线程相交互的！
1、问题描述
目前有三个class
WriteDB他主要负责把网页的信息写到数据中(间隔5分钟)，每次更新之后都会他会相应的把DataOperation中的变量isDataUpdate_设置为true；
Search他负责处理对用户执行查询信息的操作，当有用户执行Search，他会相应的把DataOperation中的变量isUserSearch_设置为true；
DataOperation这是一个中间的类，负责做类WriteDB和类Search的同步操作，会一直检查这两个变量isDataUpdate_和isUserSearch_，当他们都为false的时候，把最新在内存中的数据库写入到对应的文件中，以便能够查询最新的信息，如果其中一个为true，他都等待。
2、迷糊的那段时间
也就是前几天，一直在想，怎么能实现上面的东西！一直被WriteDB这个class和isUserSearch_(bool类型)所困扰！
还写出来类似第一版的DataOperation代码：
class DataOperation{public: DataOperation() { running_flag = true; isDataUpdate_ = false; isUserSearch_ = false; } void Stop() { running_flag = false; { boost::recursive_mutex::scoped_lock lock(mtx); cond.notify_one(); } } void EmitSignalThread() { while (running_flag) { if (isSearchEnd_) { break; } { boost::recursive_mutex::scoped_lock lock(mtx); if (IsReplaceDB()) { // 需要替换数据库 for (int i = 0; i <= 999; i++) { cout << "正在替换数据库" << i << endl; } } cond.notify_all(); } boost::this_thread::sleep(boost::posix_time::millisec(1000)); } } // 当后台有数据要更新，并且目前没有用户进行search的时候replace // 返回true表明正在进行，false表示还需要等待 bool IsReplaceDB() { return (isDataUpdate_ && isUserSearch_); } // 这个会阻塞 void WaitReplaceDB() { boost::recursive_mutex::scoped_lock lock(mtx); cout << "如果程序没有动静，那么表明此刻正在更新数据库...等待几秒即可！" << endl; cond.wait(mtx); boost::this_thread::sleep(boost::posix_time::millisec(100)); } void SetIsDataUpdate(bool isDataUpdate = true) { isDataUpdate_ = isDataUpdate; } void SetIsUserSearch(bool isUserSearch = true) { isUserSearch_ = isUserSearch; } void SetIsSearchEnd(bool isSearchEnd = false) { isSearchEnd_ = isSearchEnd; } bool GetIsSearchEnd() { return isSearchEnd_; }private: bool running_flag; // 数据助手是否需要存活 bool isDataUpdate_; // 数据是否有更新 bool isUserSearch_; // 当前是否有用户正在查询 bool isSearchEnd_; // 程序是否已经退出 boost::recursive_mutex mtx; boost::condition_variable_any cond;};
3、困扰的原因
我一直在想，以前的生产者和消费者是怎么做的？有没有想过还带有条件变量的？
4、能不能更简单
比如我就想过，只在DataOperation类中检测这两个bool变量，如果满足则更新DB，不满足Sleep；最终发现也有漏洞，毕竟这么做了Search中也要对应检测DB当前是否在更新，更新就Sleep----举一个极端的例子，但是是很可能发生：当前DataOperation发现没有用户在执行查询，那么DataOperation去设置标记(表面将要去更新数据库)，当在设置标记的时候，用户更好输入了查询，发现数据库没在更新，那么就会造成同时出现DataOperation正在更新数据库、用户正在查询的情况！那么此时系统就会崩溃了。
5、所以说
条件变量、互斥量是确实有存在的意义的！
6、再来看一下整体的设计
从作用来看WriteDB只是自己做自己的，并不和多线程的同步有关，他仅仅是每次都设置isDataUpdate_为true就行；剩下的同步仅在于Search和Dataoperation中，bool isUserSearch_;和bool isSearchEnd_;都没有实际的存在价值；只需要把isUserSearch_设置为条件变量就行。这样前面的两个bool变量的功能就被取代了(同时提一下，原来的条件变量，在这里才真正的用起来)
7、最终的测试代码
#include "iostream"#include "boost/thread.hpp"#include "boost/bind.hpp"using namespace std;#include "windows.h"#include "fstream"namespace MyNamespace{ ofstream cout("log.txt");}//#define WRITEFILE_NAMESPACE#ifdef WRITEFILE_NAMESPACEofstream out("log.txt");#endif // 0class DataOperation{public: DataOperation() { running_flag_ = true; isDataUpdate_ = false; } void Stop() { running_flag_ = false; } void EmitSignalThread() { while (running_flag_) { boost::recursive_mutex::scoped_lock lock(mtx); bool flag = GetDataUpdate(); // 如果有更新 那些就替换数据库 if (GetDataUpdate()) { // 需要替换数据库 for (int i = 0; i <= 999; i++) { if (i == 1) {#ifdef WRITEFILE_NAMESPACE out << "正在替换数据库" << i << endl;#else cout << "正在替换数据库" << i << endl;#endif // WRITEFILE_NAMESPACE } if (i == 999) {#ifdef WRITEFILE_NAMESPACE out << "替换完毕" << i << endl;#else cout << "替换完毕" << i << endl;#endif // WRITEFILE_NAMESPACE } } isDataUpdate_ = false; } isUserSearch_.notify_all(); // 等待10秒钟，所以结束的时候可能会在这里阻塞 // boost::this_thread::sleep(boost::posix_time::millisec(10000)); } } // 这个会阻塞 void WaitReplaceDB() { boost::recursive_mutex::scoped_lock lock(mtx);#ifdef WRITEFILE_NAMESPACE out << "如果程序没有动静，那么表明此刻正在更新数据库...等待几秒即可！" << endl;#else cout << "如果程序没有动静，那么表明此刻正在更新数据库...等待几秒即可！" << endl;#endif // WRITEFILE_NAMESPACE isUserSearch_.wait(mtx); boost::this_thread::sleep(boost::posix_time::millisec(100)); } void SetDataUpdate(bool isDataUpdate = true) { isDataUpdate_ = isDataUpdate; } bool GetDataUpdate() { return isDataUpdate_; } bool GetRunningFlag() { return running_flag_; }private: bool running_flag_; // 数据助手是否需要存活 bool isDataUpdate_; boost::recursive_mutex mtx; boost::condition_variable_any isUserSearch_; // 当前是否有用户正在查询};class WriteDB{public: void Start(DataOperation& dataoperation) { while (true) { // 在这里 这个线程进行数据库的更新可能需要大概好几分钟 for (int i = 0; i <= 9999; i++) { if (i == 1) {#ifdef WRITEFILE_NAMESPACE out << "WriteDB wait..." << i << endl;#else cout << "WriteDB wait..." << i << endl;#endif // WRITEFILE_NAMESPACE } if (i == 9999) {#ifdef WRITEFILE_NAMESPACE out << "WriteDB wait..." << i << endl;#else cout << "WriteDB wait..." << i << endl;#endif // WRITEFILE_NAMESPACE } } dataoperation.SetDataUpdate(); // 查询一下，如果程序退出了，那么线程也退出 if (!dataoperation.GetRunningFlag()) {#ifdef WRITEFILE_NAMESPACE out << "bye-bye" << endl;#else cout << "bye-bye" << endl;#endif // WRITEFILE_NAMESPACE break; } Sleep(10000); } }};class Search{public: void Start(DataOperation& dataoperation) { string user_enter; while (true) { getline(cin, user_enter); if (user_enter == "q") { dataoperation.Stop(); break; }#ifdef WRITEFILE_NAMESPACE out << "当前用户输入的是：" << user_enter << endl;#else cout << "当前用户输入的是：" << user_enter << endl;#endif // WRITEFILE_NAMESPACE // 如果正在更新数据库，那么wait dataoperation.WaitReplaceDB(); // out << "如果程序没有动静，那么表明此刻正在更新数据库...等待几秒即可！" << endl; // 如果没在更新数据库，直接进行查询 for (int i = 0; i <= 99999; i++) { // cout << "正在为您查询数据..." << i << endl; // if (i == 1) {#ifdef WRITEFILE_NAMESPACE out << "正在为您查询数据..." << i << endl;#else cout << "正在为您查询数据..." << i << endl;#endif // WRITEFILE_NAMESPACE } if (i == 99999) {#ifdef WRITEFILE_NAMESPACE out << "查询完毕..." << i << endl;#else cout << "查询完毕..." << i << endl;#endif // WRITEFILE_NAMESPACE } // } // 向等待的线程发出信号，让他去更新数据库 Sleep(100); } }};int main(){ boost::thread_group grp; WriteDB write_db; Search search; DataOperation data_operation; grp.create_thread(boost::bind(&WriteDB::Start, &write_db, boost::ref(data_operation))); grp.create_thread(boost::bind(&Search::Start, &search, boost::ref(data_operation))); grp.create_thread(boost::bind(&DataOperation::EmitSignalThread, boost::ref(data_operation))); grp.join_all(); return 0;} 