c++多線程編程互斥鎖初步

上一次講述了多線程編程，但是由於線程是共享內存空間和資源的，這就導致：在使用多線程的時候，對於共享資源的控制要做的很好。先上程序：

#include <iostream>
#include <thread>
#include <chrono>
#include <mutex>

using namespace std;

mutex mtx;

void fn1()
{
    for (int i = 0; i < 5; i++)
    {
        mtx.lock();
        cout << "線程" << this_thread::get_id() << ":" << "The thread1 is running !" << endl;
        mtx.unlock();
    }
}

void fn2()
{
    for (int i = 0; i < 5; i++)
    {
        mtx.lock();//鎖住的是什么資源，什么時候加鎖？
        cout << "線程" << this_thread::get_id() << ":" << "The thread2 is running !" << endl;
        mtx.unlock();
    }
}

int main()
{
    thread t1(fn1);
    thread t2(fn2);
    t1.detach();//this_thread是否表示當前進行，而這里的當前進程是否是main函數所在進程
    t2.detach();
    this_thread::sleep_for(chrono::milliseconds(1000));//sleep_for表示當前進行休眠一段時間，不與其他進程競爭CPU 
    cout << "主線程端口：" << this_thread::get_id() << endl;
    getchar();
    return 0;
}

上面一段程序，在main進程中創建了兩個子線程t1,t2。對各個子線程的cout輸出流進行了加鎖，完了又對鎖進行了釋放。

其結果如下：

 

 可見：線程t1,t2是交替執行的（這是由CPU時間片輪換造成的？）。假如我們不對cout輸出流加鎖，我們看看代碼：

#include <iostream>
#include <thread>
#include <chrono>
#include <mutex>

using namespace std;

mutex mtx;

void fn1()
{
    for (int i = 0; i < 5; i++)
    {
        //mtx.lock();
        cout << "線程" << this_thread::get_id() << ":" << "The thread1 is running !" << endl;
        //mtx.unlock();
    }
}

void fn2()
{
    for (int i = 0; i < 5; i++)
    {
        //mtx.lock();//鎖住的是什么資源，什么時候加鎖？
        cout << "線程" << this_thread::get_id() << ":" << "The thread2 is running !" << endl;
        //mtx.unlock();
    }
}

int main()
{
    thread t1(fn1);
    thread t2(fn2);
    t1.detach();//this_thread是否表示當前進行，而這里的當前進程是否是main函數所在進程
    t2.detach();
    this_thread::sleep_for(chrono::milliseconds(1000));//sleep_for表示當前進行休眠一段時間，不與其他進程競爭CPU 
    cout << "主線程端口：" << this_thread::get_id() << endl;
    getchar();
    return 0;
}

（就是單純的注釋掉了加鎖）。

結果如下：

 

 可以看到，結果產生了紊亂，分析一下這個結果：

線程t1才執行了一點：剛輸出完“線程”兩個字，轉到線程2執行了，接下來再輸出了線程t1的內容（並不是跑回去執行線程t1），再去執行線程t1.

造成這種紊亂的原因是：

cout本質上是一個輸出流對象，相當於一個公共接口，這個接口是一個公共資源。這里就涉及到了資源共享的問題！！！

所以要對cout這個共享資源加鎖！！！這樣等當前的輸出流執行完，才會到下一個線程！！