首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >问答首页 >关于传递给‘`std::线程’的ctor的参数

关于传递给‘`std::线程’的ctor的参数
EN

Stack Overflow用户
提问于 2022-03-08 05:48:16
回答 1查看 49关注 0票数 -1

由于此代码段不编译,我理解std::thread需要callable&&而不是callable&

代码语言:javascript
运行
复制
    #include <iostream>
    #include <cmath>
    #include <thread>
    #include <future>
    #include <functional>
     
    // unique function to avoid disambiguating the std::pow overload set
    int f(int x, int y) { return std::pow(x,y); }
     
    void task_thread()
    {
        std::packaged_task<int(int,int)> task(f);
        std::future<int> result = task.get_future();
     
        std::thread task_td(task, 2, 10);  //std::move(task) works
        task_td.join();
     
        std::cout << "task_thread:\t" << result.get() << '\n';
    }
     
    int main()
    {
        task_thread();
    }

由于std::thread需要callable&&,为什么下面的代码片段可以工作?在这个代码片段中,f1是一个正常的函数,我认为它是一个callable&而不是callable&&

代码语言:javascript
运行
复制
#include <iostream>
#include <utility>
#include <thread>
#include <chrono>
 
void f1(int n)
{
    for (int i = 0; i < 5; ++i) {
        std::cout << "Thread 1 executing\n";
        ++n;
        std::this_thread::sleep_for(std::chrono::milliseconds(10));
    }
}
 
void f2(int& n)
{
    for (int i = 0; i < 5; ++i) {
        std::cout << "Thread 2 executing\n";
        ++n;
        std::this_thread::sleep_for(std::chrono::milliseconds(10));
    }
}
 
class foo
{
public:
    void bar()
    {
        for (int i = 0; i < 5; ++i) {
            std::cout << "Thread 3 executing\n";
            ++n;
            std::this_thread::sleep_for(std::chrono::milliseconds(10));
        }
    }
    int n = 0;
};
 
class baz
{
public:
    void operator()()
    {
        for (int i = 0; i < 5; ++i) {
            std::cout << "Thread 4 executing\n";
            ++n;
            std::this_thread::sleep_for(std::chrono::milliseconds(10));
        }
    }
    int n = 0;
};
 
int main()
{
    int n = 0;
    foo f;
    baz b;
    std::thread t1; // t1 is not a thread
    std::thread t2(f1, n + 1); // pass by value
    std::thread t3(f2, std::ref(n)); // pass by reference
    std::thread t4(std::move(t3)); // t4 is now running f2(). t3 is no longer a thread
    std::thread t5(&foo::bar, &f); // t5 runs foo::bar() on object f
    std::thread t6(b); // t6 runs baz::operator() on a copy of object b
    t2.join();
    t4.join();
    t5.join();
    t6.join();
    std::cout << "Final value of n is " << n << '\n';
    std::cout << "Final value of f.n (foo::n) is " << f.n << '\n';
    std::cout << "Final value of b.n (baz::n) is " << b.n << '\n';
}
EN

回答 1

Stack Overflow用户

回答已采纳

发布于 2022-03-08 06:07:19

std::thread通过“衰减复制”获取它所给出的所有对象(要调用的函数及其参数)。这实际上意味着将为给定的每个参数创建一个新的对象。这些对象将由std::thread存储,并在调用新线程上的函数时使用。如果提供lvalue,则通过复制创建新对象;如果提供xvalue或prvalue,则通过移动创建新对象。

这意味着,默认情况下,std::thread不会引用构造函数调用本身之外的变量。这也意味着它需要显式的努力(std::ref或类似的工作)才能通过不属于被调用线程的参数访问对象。

packaged_task是一种只移动的类型.编译失败,因为您没有在其上调用std::move,所以衰变复制试图复制类型。因为它只能移动,所以编译失败了。但这是packaged_task的属性,而不是std::thread的属性。

票数 3
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/71390564

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档