for循环std::thread创建线程参数赋值怎么实现

可以使用lambda表达式来实现for循环中std::thread的创建和参数赋值。例如：

#include <iostream>
#include <thread>
#include <vector>

int main() {
    std::vector<std::thread> threads;
    for (int i = 0; i < 5; ++i) {
        threads.emplace_back([i]() {
            std::cout << "Thread " << i << " is running." << std::endl;
        });
    }
    for (auto& t : threads) {
        t.join();
    }
    return 0;
}

这段代码中，我们使用了一个vector来存储创建的线程，然后使用emplace_back()函数向vector中添加线程。在lambda表达式中，我们将i作为参数传递给线程函数，以便在每个线程中输出不同的线程编号。最后，我们使用join()函数等待所有线程执行完毕。

相关问题

std::thread创建线程demo

下面是一个使用 `std::thread` 创建线程的简单示例：

#include <iostream>
#include <thread>

void printMessage(const std::string& message) {
    std::cout << "Message: " << message << std::endl;
}

int main() {
    std::string message = "Hello, world!";
    std::thread t(printMessage, message);
    t.join();  // 等待线程执行完毕
    return 0;
}

上述代码中，定义了一个名为 `printMessage` 的函数，该函数接受一个 `std::string` 类型的参数，并在控制台输出该字符串。在 `main` 函数中，定义了一个 `std::string` 类型的变量 `message`，并将其赋值为 `"Hello, world!"`。然后，使用 `std::thread` 类创建了一个名为 `t` 的线程，该线程执行 `printMessage` 函数，并传递 `message` 变量作为参数。最后，调用 `t.join()` 等待线程执行完毕。

运行上述代码，应该会在控制台输出 `"Message: Hello, world!"`。

需要注意的是，创建线程时需要传递一个可调用对象（函数、函数指针、lambda 表达式等）作为参数，并且在创建线程后，需要调用 `join()` 或 `detach()` 方法等待线程执行完毕或将线程分离。此外，如果线程执行过程中抛出了异常，则需要使用 try-catch 语句捕获异常。

void URcontrolcenter::start() { // 创建六个线程 for (int i = 0; i < 6; ++i) { threads.push_back(std::thread(&URcontrolcenter::processTasks, this)); } // 将任务分配到队列中 for (int i = 0; i < relationship_list.size(); ++i) { taskQueue.push(i); } // 等待所有任务完成 std::unique_lock<std::mutex> lock(mutex); conditionVariable.wait(lock, [this]() { return tasksCompleted == relationship_list.size(); }); } void URcontrolcenter::processTasks() { // 下面先报完成，然后下一轮上面给弹出 RewriteRelationShip relationship; int taskNumber; while (true) { // 获取下一个任务 { std::unique_lock<std::mutex> lock(mutex); if (taskQueue.empty()) { // 检查当前任务是否已经全部完成，如果已经完成，则退出循环，否则获取下一个任务，并处理该任务。 return; } taskNumber = taskQueue.front(); taskQueue.pop(); } // 处理任务 relationship.parseData(relationship_list[taskNumber], worningcrosstype); // 在任务完成后，增加了已完成任务的数量，并检查是否所有任务都已经完成。如果所有任务都已经完成，则调用conditionVariable.notify_one()函数，通知等待线程可以继续执行。 ++tasksCompleted; if (tasksCompleted == relationship_list.size()) { std::unique_lock<std::mutex> lock(mutex); conditionVariable.notify_one(); } } } 这段代码，需要使用std::atomic保证tasksCompleted的原子性，给出变量定义

需要将 `tasksCompleted` 定义为 `std::atomic<int>`，如下所示：

std::atomic<int> tasksCompleted{0};

这里使用了花括号初始化的方式，将 `tasksCompleted` 初始化为0。由于 `std::atomic` 类型的对象可以直接使用赋值运算符进行赋值，因此在后续的代码中可以直接使用 `++tasksCompleted;` 对其进行原子加1操作。