首先写一个小语句热身;

 std::chrono::milliseconds die(1000);
        std::this_thread::sleep_for(die);

这个意思是进行延迟一秒的时间; 

 condition_variablu的语句可理解为条件,须和unique_lock 配合打掩护,常常与 wait 。wait_for 搭配;

条件变量是一个对象,能够在通知恢复之前阻止调用线程。它使用在调用其等待函数之一时锁定线程。线程将保持阻塞状态,直到被另一个调用同一对象上的通知函数的线程唤醒。

int cargo = 1;
bool shipment_available() { return cargo != 0; }
void thread_second_eds() {
    for (int i = 0; i < 10; i++) {
        cout << "我想回家" << endl;
    }
}
void consume(int n) {
    for (int i = 0; i < n; ++i) {
        std::unique_lock<std::mutex> lck(mtx);//自动上锁
        //第二个参数为false才阻塞(wait),阻塞完即unlock,给其它线程资源
        cv.wait(lck, shipment_available);
        std::thread fff(thread_second_eds);
       
        for (int i = 0; i < 10; i++) {
            cout << "if wo xiang huijia de hua jiu shi laig ge hun " << i << endl;
            std::chrono::microseconds(2000);
       }
        fff.join();
        cargo = 1;
    }
}

 分析:在consume 中的std::unique_lock<std::mutex>lck(mtx)是自动上锁的,原因是在与unique_lock 的作用,他与wait 进行贴合;如果 shipment_available是true 的话,我们就进行下一步,如果是false 那么我们就等待,将线程给另一家。

 wait_for()的系列;

std::mutex mtx;
    std::unique_lock<std::mutex> lck(mtx);  
    while (cv.wait_for(lck, std::chrono::seconds(1)) == std::cv_status::timeout) {//借的一句话,我也不明白什么意思;
        std::cout << '.' << std::endl;
    }

wait_for(lck, std::chrono::seconds(1)) == std::cv_status::timeout估计应该是延迟一秒,求解答》》》
线程池:

线程池(thread pool)是一种线程使用模式。线程过多会带来调度开销,进而影响缓存局部性和整体性能。而线程池维护着多个线程,等待着监督管理者分配可并发执行的任务。这避免了在处理短时间任务时创建与销毁线程的代价。

优点:
可以更好的使用系统资源。更快的响应,当达到线程上线的时候,线程池会让后来的进程进行等待,当没有进程命令的时候不用进行等待;

线程池的伸缩性对性能有较大的影响:

Logo

腾讯云面向开发者汇聚海量精品云计算使用和开发经验,营造开放的云计算技术生态圈。

更多推荐