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

 更新时间:2021年02月04日 14:18:48   投稿:zx  
这篇文章主要介绍了C语言创建线程thread_create()的方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧

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

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

int thrd_create(thrd_t *thr, thrd_start_t func, 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()用于确保一个线程已完成。它的原型是:

int thrd_join(thrd_t thr, int *result);

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

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

int thrd_detach(thrd_t thr);

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

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

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

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

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

#include <stdbool.h>
#include <threads.h>
#define MAX_THREADS 8      // 1、2、4、8……所创建线程数量的最大值
#define MIN_BLOCK_SIZE 100   // 一个数组块的最小值
typedef struct         // 函数parallel_sum()的参数
{
  float *start;    // 传递给parallel_sum()的数组块的起始地址
  int len;      // 数组块长度
  int block_size;   // 最小数组块的大小
  double sum;         // 求和结果
} Sum_arg;
int parallel_sum(void *arg);  // 线程函数的原型
// ---------------------------------------------------------------
// 计算数组元素的和,并写入*sumPtr
// sum()调用函数parallel_sum()进行并行处理
// 返回值:如果没有发生错误,则返回true;否则,返回false
bool sum(float arr[], int len, double* sumPtr)
{
  int block_size = len / MAX_THREADS;
  if (block_size < MIN_BLOCK_SIZE) block_size = len;
  Sum_arg args = { arr, len, block_size, 0.0 };
  if (parallel_sum(&args))
  { *sumPtr = args.sum; return true; }
  else
    return false;
}
// ---------------------------------------------------------------
// 递归辅助函数,用以将工作分解到几个线程中处理
int parallel_sum(void *arg)
{
  Sum_arg *argp = (Sum_arg*)arg;       // 指向参数的指针
  if (argp->len <= argp->block_size)         // 如果length <= block_size,
                            // 对所有元素求和
  {                                 
    for (int i = 0; i < argp->len; ++i)
      argp->sum += argp->start[i];
    return 1;
  }
  else                        // 如果length > block_size,
                            // 分解数组
  {                                      
    int mid = argp->len / 2;
    Sum_arg arg2 = { argp->start+mid, argp->len-mid,
             argp->block_size, 0};    // 指定后一半数组
    argp->len = mid;           // 前一半数组的长度
    thrd_t th;               // 在新线程中处理前一半数组
    int res = 0;
    if (thrd_create(&th, parallel_sum, arg) != thrd_success)
      return 0;              // 没能成功创建新线程
    if (!parallel_sum(&arg2))  // 在当前线程下,以递归方式处理后一半数组
    {
      thrd_detach(th); return 0;     // 递归调用失败
    }
    thrd_join(th, &res);
    if (!res)
      return 0;      // 同级线程报告执行失败
    argp->sum += arg2.sum;
    return 1; 
  }
}

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

相关文章

  • C语言之没有main函数的helloworld示例

    C语言之没有main函数的helloworld示例

    这篇文章主要介绍了C语言之没有main函数的helloworld示例,本文分解了带main函数的helloworld示例,从而分析出不需要main函数的helloworld示例,需要的朋友可以参考下
    2015-03-03
  • C语言实现直方图均衡化

    C语言实现直方图均衡化

    这篇文章主要为大家详细介绍了C语言实现直方图均衡化,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2021-10-10
  • 深入解析C++编程中的纯虚函数和抽象类

    深入解析C++编程中的纯虚函数和抽象类

    这篇文章主要介绍了深入解析C++编程中的纯虚函数和抽象类,是C++入门学习中的基础知识,需要的朋友可以参考下
    2015-09-09
  • 非常经典的C语言趣味题目

    非常经典的C语言趣味题目

    在这个网站上发现一套很有趣的C语言测试题,如果你招聘C语言相关开发人员,或者正在学习C语言,很值得做一做
    2013-04-04
  • C++实现广度优先遍历图

    C++实现广度优先遍历图

    这篇文章主要为大家详细介绍了C++实现广度优先遍历图,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2021-09-09
  • OpenCV实现低对比度图像脏污区域检测

    OpenCV实现低对比度图像脏污区域检测

    本文主要介绍了OpenCV实现低对比度图像脏污区域检测,文中通过示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2021-09-09
  • C语言版扫雷小游戏

    C语言版扫雷小游戏

    这篇文章主要为大家详细介绍了C语言版的扫雷小游戏,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2021-08-08
  • 基于C语言实现2048游戏

    基于C语言实现2048游戏

    这篇文章主要为大家详细介绍了基于C语言实现2048游戏,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2021-10-10
  • Qt学习笔记之QPalette调色板类

    Qt学习笔记之QPalette调色板类

    这篇文章主要为大家详细介绍了Qt学习笔记之QPalette调色板类,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2019-07-07
  • C语言入门篇--充分理解操作符

    C语言入门篇--充分理解操作符

    本篇文章是基础篇,适合c语言刚入门的朋友,本文主要介绍了c语言的操作符基础理论,希望可以帮助大家快速入门c语言的世界,更好的理解c语言
    2021-08-08

最新评论