阻塞多个线程执行完成，主要使用 std::future 、std::promise

川长思鸟来 2023-06-06 10:33 31阅读 0赞

使用的下面场景，在 future 等待的阶段会使用for 循环等待搜索的future都执行完毕（std::promise 设置value）。

#include <iostream>
    #include <string>
    #include <thread>
    #include <mutex>
    #include <chrono>
    #include <vector>
    #include <future>
    #include <condition_variable>
    
    using namespace std::chrono_literals; // for sleep_for(10s)
    using namespace std;
    void Func(std::shared_ptr<std::promise<void>> finished) {
      std::this_thread::sleep_for(10s);
      finished->set_value();
    }
    int main() {
      vector<std::future<void>> finished_futures;
      vector<std::shared_ptr<std::promise<void>>> finished_promises;
      int size = 10;
      std::vector<std::thread> threads;
      for (int i =0 ; i< size; ++i) {
        auto finished_promise = std::make_shared<std::promise<void>>();
        finished_promises.emplace_back(finished_promise);
        finished_futures.emplace_back(finished_promise->get_future());
        threads.emplace_back(std::move(std::thread(Func, finished_promise))) ;
      }
    
      for (int i=0; i< size; i++) {
        std::cout << "wait:" << i << "..." << std::endl;
        finished_futures[i].wait();
        std::cout << "wait:" << i << " end" << std::endl;
      }
      for (auto& p : threads) {
        p.join();
      }
      return 0;
    }

发表评论取消回复

表情：

评论列表（有 0 条评论，31人围观）

还没有评论，来说两句吧...

相关阅读

相关 Python多线程编程：并行执行与阻塞问题

在Python中，多线程是一种让程序同时执行多任务的技术。以下是一些关于并行执行和阻塞问题的关键点： 1. **创建线程**： - 使用`threading.Threa

比眉伴天荒/ 2025年02月18日 14:51/ 0 赞/ 70 阅读

相关【多线程】阻塞队列

![eccf0576596c1a839169c495d730fbc1.gif][] 1. 认识阻塞队列和消息队列阻塞队列也是一个队列，也是一个特殊的队列，也遵守先进先

川长思鸟来/ 2024年03月26日 20:10/ 0 赞/ 204 阅读

相关多线程 - 阻塞队列

阻塞队列阻塞队列是一种特殊的队列，它支持在队列为空时等待从队列中获取元素的操作，或在队列已满时等待插入元素的操作。当队列为空时，从队列中获取元素的操作会被阻塞，直

Dear 丶/ 2024年03月22日 16:23/ 0 赞/ 148 阅读

相关多线程--阻塞队列

目录一、阻塞队列 1.阻塞队列是什么？【查看队列相关知识】 2、如何使用阻塞队列二、生产者消费者模型 1.什么是生产者消费者模型 2.生产者消费者模型是用来

青旅半醒/ 2023年09月27日 16:50/ 0 赞/ 267 阅读

相关阻塞多个线程执行完成，主要使用 std::future 、std::promise

使用的下面场景，在 future 等待的阶段会使用for 循环等待搜索的future都执行完毕（std::promise 设置value）。 include <ios

川长思鸟来/ 2023年06月06日 10:33/ 0 赞/ 32 阅读

相关 java开启多个线程，执行完成后再执行主线程

代码例子： public static void main(String[] args) throws Exception{ int cou

╰半橙微兮°/ 2022年09月02日 12:59/ 0 赞/ 302 阅读

相关多线程阻塞队列

本文讲述java自带的阻塞队列BlockingDuque。队列添加的方法有三种，add，offer，put，队列满后，如果在调用添加方法 add会抛异常，offer会

古城微笑少年丶/ 2022年07月13日 12:27/ 0 赞/ 307 阅读

相关 Condition多个线程顺序执行

package thread; import java.util.concurrent.locks.Condition; import jav

布满荆棘的人生/ 2022年05月29日 01:26/ 0 赞/ 375 阅读

相关四十三、使用线程池与CountDownLatch完成多线程阻塞

\ 使用线程池与CountDownLatch完成多线程阻塞这篇文章主要是将主线程阻塞，让子线程先跑。 \\\1、添加Spring配置文件 <?

不念不忘少年蓝@/ 2022年05月17日 09:44/ 0 赞/ 252 阅读

相关多个线程顺序执行

1.wait-notifyAll 同步方法 package com.study.demo; / Created by Admini

Love The Way You Lie/ 2022年04月25日 00:36/ 0 赞/ 372 阅读