C++11多線程訪問時候的數據保護實例

#include<iostream>
#include<thread>
#include<string>
#include<vector>
#include<list>
#include<mutex>
#include<unistd.h> 
using namespace std;
 
//用成員函數作為線程函數的方法寫線程
//std::cout 是共享對象（輸出流），應該確保它不受多個線程的同時訪問；
class A
{
public:
    //線程１：把收到的用戶消息放入到一個隊列
    void inMsgRecvQueue() 
    {
        int i;
        while(1)
        {
            cin >> i;
            //my_mutex.lock();
            cout << "已檢測到輸入命令: " << i << endl;
            msgRecvQueue.push_back(i); 
            //my_mutex.unlock();
        }
    }
    bool noempty_or_not()
    {
        if (!msgRecvQueue.empty())
        {
            return true;
        }
        return false;
    }
    void delete_first()
    {
        msgRecvQueue.pop_front();
    }
    
    void delete_first_app()
    {
        waitcommand.pop_front();    
    }

    //線程2：取出隊列中的首元素．
    void outMsgRecvQueue()
    {
        while(1)
        {
            bool result = noempty_or_not();
 
            if (result  == true)
            {    my_mutex.lock();
                cout << "將用戶輸入的命令" << msgRecvQueue.front() << "加入到App隊列,執行用戶程序  Please waitting...." << endl;
                waitcommand.push_back(msgRecvQueue.front());
                delete_first();
                my_mutex.unlock();
                App(waitcommand.front());   //根據命令代碼來執行應用程序，假設耗時巨大；
                delete_first_app();
                //my_mutex.unlock();
            }
            else
            {                
                //cout << "目前消息隊列中為空！" <<  endl;
            }
        }
        cout <<"end!" << endl;
    }

    // 應用程序
    void App (int ass)
    {    
        sleep(10);
        cout << " Command: " << ass << "執行完畢" << endl;
    }
 
private:
    std::list<int> waitcommand;
    std::list<int> msgRecvQueue;
    std::mutex my_mutex;        //這個鎖專門用於系統對waitcommand和msgRecvQueue的互斥修改;
};
 
int main()
{
    A myobja;
 
    std::thread myOutMsgObj(&A::outMsgRecvQueue, &myobja);
    std::thread myInMsgObj(&A::inMsgRecvQueue, &myobja);
    myOutMsgObj.join();
    myInMsgObj.join();
    return 0;
}