c++ - 尝试创建线程的问题

Closed. This question needs debugging details。它当前不接受答案。

想改善这个问题吗？更新问题，以便将其作为on-topic用于堆栈溢出。

上个月关闭。

Improve this question

我正在尝试制作一个函数，该函数接受std::function和值的 vector ，并将返回一个 vector ，其中包含这些值的函数输出，并利用线程来加快速度。
当我编译我的代码时，它说它无法专用于std::invoke的函数模板，并且它期望有1个参数并得到7
这是我的代码:

#include <vector>
#include <thread>
#include <functional>
#include <iterator>

template<
    typename RETURN,
    typename INPUT
>
void thread_instance(std::function<RETURN(INPUT)> function, 
                     const std::vector<INPUT>& input, 
                     typename std::vector<INPUT>::iterator input_start, 
                     typename std::vector<INPUT>::iterator input_end,
                     std::vector<RETURN>& output,
                     typename std::vector<RETURN>::iterator output_start)
{
    for (; input_start != input_end; ++input_start, ++output_start)
    {
        *output_start = function(*input_start);
    }
}

template<
    typename RETURN,
    typename INPUT
>
std::vector<RETURN> thread_map(std::function<RETURN(INPUT)> function, std::vector<INPUT> input, int thread_count)
{
    std::vector<std::thread> threads(thread_count);
    std::vector<RETURN> output(input.size());
    for (int i = 0; i < thread_count; ++i)
    {
        int start_index = (input.size() / thread_count) * i;
        int end_index = start_index + input.size() / thread_count;
        typename std::vector<INPUT>::iterator thread_input_start = input.begin() + start_index;
        typename std::vector<INPUT>::iterator thread_input_end = input.begin() + end_index;
        typename std::vector<RETURN>::iterator thread_output_start = output.begin() + start_index;
        threads[i] = std::thread(thread_instance<RETURN, INPUT>, function, input, thread_input_start, thread_input_end, output, thread_output_start);
    }
    for (int i = 0; i < thread_count; ++i)
    {
        threads[i].join();
    }
    return output;
}

int multiply_by_2(int num)
{
    return num * 2;
}

int main(int argc, char** argv)
{
    std::vector<int> nums_to_sum = { 4,3,67,5,32,6,3,2,4 };
    std::vector<int> summed_nums = thread_map(std::function<int(int)>(multiply_by_2), nums_to_sum, 12);
}

最佳答案

根据cppreference的std::thread:

The arguments to the thread function are moved or copied by value. If a reference argument needs to be passed to the thread function, it has to be wrapped (e.g., with std::ref or std::cref).

想一想，如果使用引用启动线程，并且线程启动后对象被销毁，会发生什么情况？悬挂的引用和不确定的行为!因此，按值接受参数的默认行为是有意义的。
就您而言，您甚至没有使用输出 vector 。输出 vector 的迭代器就足够了，并且可以按值传递。因此，我建议您更改函数，使其不通过引用接受输出 vector :

template<
    typename RETURN,
    typename INPUT
>
void thread_instance(std::function<RETURN(INPUT)> function,
    const std::vector<INPUT>& input,
    typename std::vector<INPUT>::iterator input_start,
    typename std::vector<INPUT>::iterator input_end,
    typename std::vector<RETURN>::iterator output_start)
{
    for (; input_start != input_end; ++input_start, ++output_start)
    {
        *output_start = function(*input_start);
    }
}

另一件事是，如果要使用整数除法计算起始迭代器，如下所示:

int start_index = (input.size() / thread_count) * i;

并且thread_count大于input.size()，结果将始终为零。用12以外的数字代替3是更好的选择，例如3。还请记住，创建线程是相对昂贵的，并且您不想创建太多线程。 std::thread::hardware_concurrency()将返回系统支持的并发线程数。

关于c++ - 尝试创建线程的问题，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/64380911/

上一篇：c++ - Qt错误涉及清洁项目未修复的MOC文件

下一篇：c++ - 我想知道是否有可能在使用调试器Visual Studio代码进入if语句之前检查if语句的计算结果

相关文章：

c++ - 通过 C++ 中的 switch 在运行时选择模板实例化

java - 更新 Java 线程池中的 UI

c++ - 模板参数的格式规范

为多个供应商发现 sql 数据库模式的 C++ 库？

c++ - 为 "adjacent"变量赋值时出现问题

node.js - 如何在 Node JS 中执行/中止长时间运行的任务？

java - 对于线程脚本，在 Groovy 中使用同步 println 和仅使用 println 有什么区别？

c++ - "if the context from which the specialization is referenced depends on a template parameter"是什么意思？

c++ - 模板参数字符串与 int

c++ - 如何使用插件 CDT 在 Eclipse 中为 Java 开发人员配置 opencv？