C语言创建线程thread_create()的方法

2023-07-05 22:00:03 93

在头文件threads.h中，定义和声明了支持多线程的宏、类型和函数。所有直接与线程相关的标识符，均以前缀thrd_作为开头。例如，thrd_t是一个对象类型，它标识了一个线程。

函数thrd_create（）用于创建并开始执行一个新线程。函数thrd_create（）的其中一个参数为在新线程中需要被执行的函数thrd_create（）的其中一个参数为在新线程中需要被执行的函数。thrd_create（）的完整原型是：

intthrd_create(thrd_t*thr,thrd_start_tfunc,void*arg);

参数func是一个指针，它指向在新线程需要被执行的函数，而void指针arg用于向该函数传递参数。换句话说，新线程将执行函数调用func（arg）。

参数func的类型为thrd_start_t，它被定义为int（*）（void*）（这是一个函数指针，指向一个void指针作为其参数并返回一个int值的函数），因此，该线程执行的函数返回一个int类型的值。

程序在后续过程中可以通过调用函数thread_join（）获得这个int类型的返回值（必要时，需等待该线程执行完）。

如果一个线程启动成功，函数thread_create（）将新线程写入一个对象进行标识，并通过参数thr指向该对象，然后返回宏值thread_success。

在大多数情况下，后续的其他操作均依赖于该线程的执行结果，并且只有当该线程完成后，才能执行其他操作。函数thread_join（）用于确保一个线程已完成。它的原型是：

intthrd_join(thrd_tthr,int*result);

调用thread_join（）的线程会被阻塞，直到通过thr标识的线程执行完成，这里“阻塞”（block）指的是：线程会在调用thread_join（）的位置停留必要的时间。然后，thread_join（）将线程thr中执行函数的返回值写入指针result所引用的int变量中，假设result不是一个空指针。最后，thread_join（）释放属于线程thr的所有资源。

如果程序逻辑上并不需要等待线程thr结束，则应该调用以下函数：

intthrd_detach(thrd_tthr);

thrd_detach（）使得当线程thr执行完成后，自动释放线程占用的所有资源。一旦一个线程执行了分离操作（调用thrd_detach（）），将不用程序等待其结束，程序也不会获得该线程执行函数的返回值。对于每个创建的线程，调用thread_join（）或thread_detach（）不得超过一次。

在例1中的程序展示了使用并行操作处理数组的一种方式。各个线程先自行处理数组的各部分，然后将它们的处理结果组合在一起。该程序仅需计算一个数字序列的总和。

函数sum（）首先根据创建线程的最大数量确定划分数组所得的各组元素的最大数量，然后调用递归辅助函数parallel_sum（）。

函数parallel_sum（）将数组平均分为两半，将其中的一半交给一个新线程处理，同时调用自身来处理另一半数组。如该例所示，一个线程函数需要多个参数，这些参数通常采用结构进行封装。

【例1】在几个并行线程中计算数组元素的和

#include
#include
#defineMAX_THREADS8//1、2、4、8……所创建线程数量的最大值
#defineMIN_BLOCK_SIZE100//一个数组块的最小值
typedefstruct//函数parallel_sum()的参数
{
float*start;//传递给parallel_sum()的数组块的起始地址
intlen;//数组块长度
intblock_size;//最小数组块的大小
doublesum;//求和结果
}Sum_arg;
intparallel_sum(void*arg);//线程函数的原型
//---------------------------------------------------------------
//计算数组元素的和，并写入*sumPtr
//sum()调用函数parallel_sum()进行并行处理
//返回值：如果没有发生错误，则返回true；否则，返回false
boolsum(floatarr[],intlen,double*sumPtr)
{
intblock_size=len/MAX_THREADS;
if(block_sizelen<=argp->block_size)//如果length<=block_size，
//对所有元素求和
{
for(inti=0;ilen;++i)
argp->sum+=argp->start[i];
return1;
}
else//如果length>block_size，
//分解数组
{
intmid=argp->len/2;
Sum_argarg2={argp->start+mid,argp->len-mid,
argp->block_size,0};//指定后一半数组
argp->len=mid;//前一半数组的长度
thrd_tth;//在新线程中处理前一半数组
intres=0;
if(thrd_create(&th,parallel_sum,arg)!=thrd_success)
return0;//没能成功创建新线程
if(!parallel_sum(&arg2))//在当前线程下，以递归方式处理后一半数组
{
thrd_detach(th);return0;//递归调用失败
}
thrd_join(th,&res);
if(!res)
return0;//同级线程报告执行失败
argp->sum+=arg2.sum;
return1;
}
}

到此这篇关于C语言创建线程thread_create()的方法的文章就介绍到这了,更多相关C语言创建线程内容请搜索毛票票以前的文章或继续浏览下面的相关文章希望大家以后多多支持毛票票！

C语言创建线程thread_create()的方法

热门推荐

随机推荐