C语言线程基本函数

学习笔记：

• C语言线程基本函数

学习内容：

线程常用基本函数：

1. pthread_create() 创建线程
2. pthread_exit() 退出当前线程
3. pthread_join() 等待其他线程结束
4. pthread_self() 自身线程ID号
5. pthread_cancel() 停止其他线程
6. pthread_detach() 分离某个线程

学习笔记：

线程使用需要导入对应头文件

• #include <pthread.h>

pthread_create() 创建线程

函数原型：

/**
 * @brief 创建一个线程
 * @param th 线程ID
 * @param attr 线程属性，通常使用NULL
 * @param func 线程函数入口
 * @param arg 线程函数传参
 * @return int 创建成功返回0，失败返回错误代码
 */
int pthread_create(pthread_t *th, 
                   const pthread_attr_t *attr, 
                   void *(* func)(void *), 
                   void *arg);

pthread_exit() 退出当前线程

函数原型：

/**
 * @brief 终止当前线程
 * @param res 向其他线程传送数据，（不能用局部变量传出）
 */
void pthread_exit(void *res);

• res 用法见示例代码

pthread_join() 等待其他线程结束

函数原型：

/**
 * @brief 等待 th 线程结束
 * @param th 线程ID
 * @param res 用于线程退出时向外传送数据，
 *            当没有需要传出的数据时为NULL
 * @return int 成功0；失败返回错误码
 */
int pthread_join(pthread_t th, void **res);

pthread_self() 自身线程ID号

函数原型：

/**
 * @brief 返回自身的线程ID
 * @return pthread_t 
 */
pthread_t pthread_self(void);

pthread_cancel() 停止其他线程

函数原型：

/**
 * @brief 在其他线程中强行取消一个执行中的线程
 * @param th 目标线程ID
 * @return int 成功地发送了 Cancel 信号，返回数字 0；
 * 			   反之如果发送失败，函数返回值为非零数
 */
int pthread_cancel(pthread_t th);

pthread_detach() 分离某个线程

函数原型：

/**
 * @brief 分离某个线程
 * @note 如果对某个线程使用了pthread_detach,
 *       那么在其他线程中无法使用   pthread_join
 * @param th 
 * @return int 成功：0；失败：错误号
 */
int pthread_detach(pthread_t th);

• 如果对某个线程使用了pthread_detach,那么在其他线程中无法使用 pthread_join

示例程序：

demo:

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <malloc.h>
#include <pthread.h>

#define OPEN_DEBUG_MESSAGE   
#ifdef OPEN_DEBUG_MESSAGE
#   define D_MES(message) printf(message)
#else
#   define D_MES(message)        
#endif


typedef struct TResultTag TRes;
struct TResultTag
{
    char data[20];
    int num;
};

void *task1_entry(void *param)
{
    TRes *res = (TRes *)param;
     
    int i;
    for(i = 0; i < 10; i++)
    {
        printf("task i -> %d\n",i);
        sleep(1);
    }
    sprintf(res->data, "task1 id:%lu", pthread_self()); 
    res->num = 520;

    pthread_exit(param);
}

int main()
{
    printf("hello\n");
    
    // 用于子线程结束后传出返回值
    TRes *res = (TRes *)malloc(sizeof(TRes));
    if (res != NULL)
    {   
        pthread_t task1;
        
        // 创建线程
        if (pthread_create(&task1, NULL, task1_entry, res) != 0)
        	printf("failed in pthread_create \n");
        
        sleep(1);
        // pthread_detach(task1);  // 打开该行 pthread_join 会失败 
	
        int i;
        for(i = 0; i < 5; i++)
        {
        	printf("main i -> %d\n",i);
        	sleep(1);
        }
        
        // 等待线程 task1 结束
        if (pthread_join(task1, (void **)&res) == 0)
        // 输出由 task1 传出的返回值
            printf("res->data:%s\nres->:%d\n", res->data, res->num);
        else
            printf("ERROR: pthread_join");

    }
    else    
        printf("failed in malloc\n");

    system("pause");
    
    return 0;    
} 

效果截图

• 不执行pthread_detach()
  

• 执行pthread_detach()