c++线程并发---线程同步-创新互联

某个线程需要等待另外一个线程的任务完成，才可以执行的自己的任务，被称为同步。

#include#include#include#include#includestatic std::mutex              mtx;
static std::condition_variable cv;
void                           runthread(int index)
{
    while (1)
    {
        std::unique_lock< std::mutex >lck(mtx);  //上锁
        fprintf(stderr, "thread:%d is waiting.\n", index);
        cv.wait(lck);  // wait 解锁，然后加锁
        fprintf(stderr, "thread:%d is sleep.\n", index);
        std::this_thread::sleep_for(std::chrono::seconds(5));
        fprintf(stderr, "thread:%d is wakeup.\n", index);
    }
}

void runthread_1(int index)
{
    std::unique_lock< std::mutex >lck(mtx); //
    fprintf(stderr, "thread:%d is waiting.\n", index);
    std::this_thread::sleep_for(std::chrono::seconds(2));
    fprintf(stderr, "thread:%d is wakeup.\n", index);
}
int main()
{
    fprintf(stderr, "pid:%d\n", getpid());

    std::thread* pt[5];
    for (int i = 0; i< 5; i++)
    {
        pt[i] = new std::thread(runthread, i);  //创建5个线程
    }

    for (int i = 0; i< 3; i++)
    {
        std::this_thread::sleep_for(std::chrono::seconds(1));
        fprintf(stderr, "main thread sleep %d seconds\n", i);
    }
    cv.notify_all();     
    //  cv.notify_one();    // 唤醒其中的一个线程，此时该线程会执行完cv.wait(lck);
    // 由阻塞状态变成运行状态，此时m_mtx会锁上，因此，下面的runthread_1会被锁上，进而不能够打印输出
    // new std::thread(runthread_1, 10);

    for (int i = 0; i< 5; i++)
    {
        if (pt[i]->joinable())
        {
            pt[i]->join();
            delete pt[i];
            pt[i] = NULL;
        }
    }
    return 0;
}

使用一次性future来模拟一类事件，若线程需要等待某一个事件发生，则会以一个恰当的方式取得一个future,它代表目标事件，可以一边等待事件的发生，一边执行其他任务。

就好比： 去高铁站做高铁，你要等待高铁的到来，而在高铁来之前，你可以吃饭，玩手机等，等待其他事情的发生。

#include#include#include#includeusing namespace std;
//g++ -std=c++0x -pthread future.cpp
int printname(string a,int n)
{
       for(int i=0;i

thread1
thread1
thread1
2
3

auo f3=std::async(std::launch::async,printname,"thread2",3);
    auo f4=std::async(std::launch::deferred,printname,"thread3",3);
    auo f5=std::async(std::launch::deferred|std::launch::async,printname,"thread4",3);