我可以在 C 上的同一个函数上使用 pthreads 吗？

Question

我怀疑这可能是愚蠢的家伙。我有一个函数来计算一些数学公式作为例子。

# include <stdio.h>
# include <time.h>
# include <stdlib.h>
# include <pthread.h>
# include <unistd.h>
# include <math.h>


pthread_mutex_t a_mutex = PTHREAD_MUTEX_INITIALIZER;
volatile long int a = 0;


void threadOne(void *arg) 
{


 int i;
    long int localA = 0;

    for (i = 1; i < 50000000; i++) 
    {
     localA = localA + i*a*sqrt(a);
    }

    pthread_mutex_lock(&a_mutex);
    a = a + localA;
    pthread_mutex_unlock(&a_mutex);
}


void threadTwo(void *arg) 
{
    int i;
    long int localA = 0;
    for (i = 50000000; i <= 100000000; i++)
    {
     localA = localA + i*a*sqrt(a);
    }
   pthread_mutex_lock(&a_mutex);
   a = a + localA;
   pthread_mutex_unlock(&a_mutex);
}


int main (int argc, char **argv) 
{
    pthread_t one, two;
    int i;
    pthread_create(&one, NULL, (void*)&threadOne, NULL);
    pthread_create(&two, NULL, (void*)&threadTwo, NULL);
    pthread_join(one, NULL);
    pthread_join(two, NULL);
}

现在这是我找到的一个例子，我有两个函数，每个函数都有一个线程，所以一个是在不同的线程上计算的。但是我可以只有一个函数，然后对一个函数有两个线程，所以该函数使用不同的数据运行两次吗？我的想法是这样的：我只有一个函数可以有两组不同的数据，然后根据正在运行的线程，该函数可以使用第一组或第二组运行。

但这可能吗？我想避免像这里一样复制函数两次。

假设我只保留功能

void threadOne(void *arg)

但是我使用不同的线程同时使用不同的数据运行它两次，这可以实现还是我只是傻？。

Answer 1

是的，这可以通过使用线程函数的参数来完成。

每个线程都需要循环一系列值。所以创建一个结构定义来包含最小值和最大值：

struct args {
    int min;
    int max;
};

定义一个单线程函数，它将void * 参数转换为指向该类型的指针并读取它：

void *thread_func(void *arg) 
{
    struct args *myargs = arg;
    int i;
    long int localA = 0;
    for (i = myargs->min; i < myargs->max; i++) 
    {
        localA = localA + i*a*sqrt(a);
    }
    pthread_mutex_lock(&a_mutex);
    a = a + localA;
    pthread_mutex_unlock(&a_mutex);
    return NULL;
}

（请注意，该函数需要返回一个void * 以符合pthread_create 期望的接口。）

然后在您的main 函数中为每组参数创建此结构的实例，并将其传递给pthread_create：

int main (int argc, char **argv) 
{
    pthread_t one, two;
    struct args args1 = { 1, 50000000 };
    struct args args2 = { 50000000 , 100000000 };
    pthread_create(&one, NULL, thread_func, &args1);
    pthread_create(&two, NULL, thread_func, &args2);
    pthread_join(one, NULL);
    pthread_join(two, NULL);
}