0

所以我们正在努力应对挑战，我们需要并行化 c++ 代码，以确保它使用多个内核而不是一个内核。我们为此使用了 openmp，它现在运行得更好了。但对于另一部分，我们需要使用 pthread。由于我们对 C++ 非常陌生（实际上这是我们第一次使用它），因此我们很难让线程正常工作。

这是原始代码的简约版本：

int main(int argc, char **argv) {
    ...code ...
    //These 2 functions should be running in parallel
    work_calculation(flights, parameter, alliances);
    play_calculation(flights, parameter, alliances);
    ...code...
}

void work_calculation(vector<Flight>& flights, Parameters& parameters, vector<vector<string> >& alliances)
{
    ... code ...
    do_calculation(flights, parameters, alliances);
    ... code ...
}

void do_calculation(vector<Flight>& flights, Parameters& parameters, 
vector<vector<string> >& alliances)
{
    ...code...
}

为了将 pthread 与具有多个参数的函数一起使用，我们发现我们需要使用结构体。所以我们想出了这个：

int main(int argc, char **argv) {
    ...code ...
    s_param parathread;
parathread.flights = flights;
parathread.parameters = parameters;
parathread.alliances = alliances;
pthread_t play;
pthread_t work;
pthread_create(&play, NULL, work_calculation ,&parathread);
pthread_create(&work, NULL, play_calculation, &parathread);
pthread_join(play, NULL);
pthread_join(work, NULL);
    ...code...
}

typedef struct 
{
    vector<Flight> flights;
    Parameters parameters;
    vector<vector<string> > alliances;
} s_param;

void* work_calculation(void* args)
    {
        ... code ...
        struct s_param *paraThread = (struct s_param*)args;
        do_calculation(paraThread->flights, paraThread->parameters, paraThread->alliances);
        ... code ...
        pthread_exit(NULL);
    }

void do_calculation(vector<Flight>& flights, Parameters& parameters, 
vector<vector<string> >& alliances)
{
    ...code... (same as original)
}

如果我们这样做，我们会收到以下错误：

错误：不允许指向不完整类类型的指针 -> 我在任何地方都使用 paraThread

我们还尝试在 struct s_pram *paraThread = (struct s_param*)args => 中不使用结构（就像这样： s_param *paraThread = args; ，但是在编译时我们得到了这些错误：

标识符 s_param 未定义，标识符 paraThread 未定义

我们做错了什么？我希望有人可以帮助我们找到问题所在。

4

5 回答 5

2

需要在struct实例化之前定义main；你在之后定义它main。

于 2012-12-13T13:29:27.443 回答
0

我认为你的问题在这条线上。

pthread_create(&play, NULL, work_calculation, &parathread);

正确的是这个。

pthread_create(&work, NULL, &work_calculation, &parathread);

将其应用于两个线程。

于 2012-12-13T13:25:34.910 回答
0

将 typedef struct {} s_param 的定义移到文件开头。

于 2012-12-13T13:30:23.753 回答
0

片段：

typedef struct 
{
    vector<Flight> flights;
    Parameters parameters;
    vector<vector<string> > alliances;
} s_param;

创建一个类型s_param，而不是struct s_param。Mike Seymour 有正确的答案（使用和定义的顺序不正确），但您仍然需要使用其中一个struct或typedef. 我自己更喜欢 typedef，但其他人有其他想法。

你可以使用：

typedef struct {
    vector<Flight> flights;
    Parameters parameters;
    vector<vector<string> > alliances;
} s_param;
:
s_param *something;

或者：

struct s_param {
    vector<Flight> flights;
    Parameters parameters;
    vector<vector<string> > alliances;
};
:
struct s_param *something; // I think struct is optional but I still prefer it.
于 2012-12-13T13:22:34.590 回答
0

如果您不熟悉线程，我将从更高级别的运行时库开始进行并行化。像 pthread 这样的低级线程库在其最低级别公开了并行性控制。那里代表了并行性的汇编语言。因此，它们提供了最大的灵活性，但在程序员工作、调试时间和维护成本方面的成本很高。

开源 C++ 运行时是 cilk Plus 和 TBB。他们有一个开源网站可以从中下载位。

www.threadingbuildingblocks.org

www.cilkplus.org

于 2012-12-13T14:39:04.817 回答