linux——线程

在 Linux 系统中，进程和线程是两种重要的并发执行单元。本文将详细介绍它们的区别、使用场景、以及多线程编程中的关键API和示例代码。

进程与线程的区别

进程

  • 进程是程序运行的一个实例，承担分配系统资源的基本单位。
  • 每个进程都有独立的地址空间，一个进程崩溃不会影响其他进程。
  • 进程的创建和切换消耗较多资源。

线程

  • 线程是进程中的一个执行路径，是CPU调度的基本单位。
  • 线程共享进程的地址空间，但每个线程有自己的堆栈和局部变量。
  • 线程的创建和切换开销较小。
  • 如果一个线程崩溃，会导致整个进程崩溃。

使用线程的理由

  1. 节省资源：创建进程需要分配独立的地址空间，建立多个数据表来维护其代码段、数据段和堆栈段，这种方式十分昂贵。线程共享同一进程的地址空间和大部分数据，启动一个线程比启动一个进程要快很多。一个进程的开销大约是一个线程的30倍。
  2. 方便的通信机制：不同进程之间的数据传递需要通过通信机制，如管道、信号等，这种方式耗时且复杂。而线程共享进程的数据空间，数据共享非常方便和快捷，但需要注意数据同步的问题。

多线程开发及API

多线程开发主要包含三点：线程、互斥锁、条件变量。以下是具体的操作和API介绍：

线程操作

线程的创建
#include <pthread.h>
int pthread_create(pthread_t *restrict tidp, const pthread_attr_t *restrict attr, void *(*start_rtn)(void *), void *restrict arg);
// 返回：若成功返回0，否则返回错误编号
线程的获取和比较
#include <pthread.h>
pthread_t pthread_self(void);
线程的等待
#include <pthread.h>
int pthread_join(pthread_t thread, void **rval_ptr);
// 参数：
// pthread_t thread：等待的线程
// void **rval：线程退出状态的收回，NULL表示不收回
线程的退出
#include <pthread.h>
int pthread_exit(void *rval_ptr);

线程的创建、退出、等待示例

#include <stdio.h>
#include <pthread.h>

void *func1(void *arg)
{
   static int ret = 10;
   printf("t1:%ld thread is created\n", (unsigned long)pthread_self());
   printf("t1: parameter is %d\n", *((int *)arg));
   pthread_exit((void*)&ret); // 线程退出
}

int main()
{
    int ret;
    int param = 100;
    int *pret = NULL;
    pthread_t t1;

    ret = pthread_create(&t1, NULL, func1, (void*)&param); // 创建线程
    if(ret == 0){
        printf("main: create t1 success\n");
    }
    printf("main: %ld\n", (unsigned long)pthread_self()); // 获取线程ID
   
    pthread_join(t1, (void**)&pret); // 等待线程退出
    printf("main: t1 quit with %d\n", *pret);
    return 0;
}

传入一个结构体的线程创建示例

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

struct data
{
    int a;
    char *s;
};

void *func1(void *arg)
{
    static char *x = "t1 run out";
    struct data *temp;
    temp = (struct data*)arg;
    printf("t1:%ld pthread is created\n", (unsigned long)pthread_self());
    printf("t1: %d\n", temp->a);
    printf("t1: %s\n", temp->s);
    pthread_exit((void*)x);
}

int main()
{
    int ret;
    pthread_t t1;
    char *pret = NULL;
    struct data *p = (struct data*)malloc(sizeof(struct data));
    p->a = 1;
    p->s = "xiancheng";
    
    ret = pthread_create(&t1, NULL, func1, (void*)p);
    if(ret == 0){
        printf("main: create t1 success\n");
    }
    
    printf("main: %ld\n", (unsigned long)pthread_self());

    pthread_join(t1, (void**)&pret);
    printf("main: t1 quit with %s\n", pret);
    free(p);
    return 0;
}

线程共享空间验证示例

#include <stdio.h>
#include <pthread.h>
#include <unistd.h>

int g_data = 10;

void *func1(void *arg)
{
    printf("t1:%ld thread is created\n", (unsigned long)pthread_self());
    printf("t1: parameter is %d\n", *((int*)arg));
    while(1){
        printf("%d\n", g_data++);
        sleep(1);
        if(g_data == 3){
            pthread_exit(NULL);
        }
    }
}

void *func2(void *arg)
{
    printf("t2:%ld thread is created\n", (unsigned long)pthread_self());
    printf("t2: parameter is %d\n", *((int*)arg));
    while(1){
        printf("%d\n", g_data++);
        sleep(1);
    }
}

int main()
{
    int ret;
    int param = 100;
    pthread_t t1;
    pthread_t t2;
    
    ret = pthread_create(&t1, NULL, func1, (void*)&param);
    if(ret == 0){
        printf("main: create t1 success\n");
    }
    
    ret = pthread_create(&t2, NULL, func2, (void*)&param);
    if(ret == 0){
        printf("main: create t2 success\n");
    }

    printf("main: %ld\n", (unsigned long)pthread_self());
    while(1){
        printf("%d\n", g_data++);
        sleep(1);
    } 
    
    pthread_join(t1, NULL);
    pthread_join(t2, NULL);
  
    return 0;
}

互斥锁（Mutex）

互斥锁API
创建及销毁互斥锁
#include <pthread.h>
int pthread_mutex_init(pthread_mutex_t *restrict mutex, const pthread_mutexattr_t *restrict attr);
int pthread_mutex_destroy(pthread_mutex_t *restrict mutex);
加锁及解锁
#include <pthread.h>
int pthread_mutex_lock(pthread_mutex_t *restrict mutex);
int pthread_mutex_trylock(pthread_mutex_t *restrict mutex);
int pthread_mutex_unlock(pthread_mutex_t *restrict mutex);

使用互斥锁的示例

#include <stdio.h>
#include <pthread.h>
#include <unistd.h>

int g_data = 0;
pthread_mutex_t mutex; // 定义锁

void *func1(void *arg)
{
    pthread_mutex_lock(&mutex); // 加锁
    for(int i = 0; i < 5; i++){
        printf("t1: %ld thread is created\n", (unsigned long)pthread_self());
        printf("t1: parameter is %d\n", *((int*)arg));
        sleep(1);
    }
    pthread_mutex_unlock(&mutex); // 解锁
}

void *func2(void *arg)
{
    pthread_mutex_lock(&mutex);
    for(int i = 0; i < 5; i++){
        printf("t2: %ld thread is created\n", (unsigned long)pthread_self());
        printf("t2: parameter is %d\n", *((int*)arg));
        sleep(1);
    }
    pthread_mutex_unlock(&mutex);
}

void *func3(void *arg)
{
    pthread_mutex_lock(&mutex);
    for(int i = 0; i < 5; i++){
        printf("t3: %ld thread is created\n", (unsigned long)pthread_self());
        printf("t3: parameter is %d\n", *((int*)arg));
        sleep(1);
    }
    pthread_mutex_unlock(&mutex);
}

int main()
{
    int ret;
    int param = 100;
    pthread_t t1;
    pthread_t t2;
    pthread_t t3;
     
    pthread_mutex_init(&mutex, NULL); // 初始化锁
     
    ret = pthread_create(&t1, NULL, func1, (void*)&param);
    if(ret == 0){
        printf("main: create t1 success\n");
    }

    ret = pthread_create(&t2, NULL, func2, (void*)&param);
    if(ret == 0){
        printf("main: create t2 success\n");
    }

    ret = pthread_create(&t3, NULL, func3, (void*)&param);
    if(ret == 0){
        printf("main: create t3 success\n");
    }

    printf("main: %ld\n", (unsigned long)pthread_self());

    pthread_join(t1, NULL);
    pthread_join(t2, NULL);
    pthread_join(t3, NULL);
     
    pthread_mutex_destroy(&mutex); // 收回锁
    
    return 0;
}

互斥锁限制共享资源的访问示例

#include <stdio.h>
#include <pthread.h>
#include <unistd.h>

int g_data = 0;
pthread_mutex_t mutex;

void *func1(void *arg)
{
    printf("t1: %ld pthread is created\n", (unsigned long)pthread_self());
    printf("t1: parameter is %d\n", *((int*)arg));
    while(1){
        pthread_mutex_lock(&mutex);
        printf("%d\n", g_data++);
        sleep(1);
        if(g_data == 3){
            pthread_mutex_unlock(&mutex);
            pthread_exit(NULL);
        }
    }
}

void *func2(void *arg)
{
    printf("t2: %ld pthread is created\n", (unsigned long)pthread_self());
    printf("t2: parameter is %d\n", *((int*)arg));
    while(1){
        printf("%d\n", g_data);
        pthread_mutex_lock(&mutex);
        g_data++;
        pthread_mutex_unlock(&mutex);
        sleep(1); 
    }
}

int main()
{
    int ret;
    int param = 100;
    pthread_t t1;
    pthread_t t2;
     
    pthread_mutex_init(&mutex, NULL);
     
    ret = pthread_create(&t1, NULL, func1, (void*)&param);
    if(ret == 0){
        printf("main: create t1 success\n");
    }

    ret = pthread_create(&t2, NULL, func2, (void*)&param);
    if(ret == 0){
        printf("main: create t2 success\n");
    }

    printf("main: %ld\n", (unsigned long)pthread_self());

    pthread_join(t1, NULL);
    pthread_join(t2, NULL);
     
    pthread_mutex_destroy(&mutex);
    return 0;
}

死锁示例

#include <stdio.h>
#include <pthread.h>
#include <unistd.h>

pthread_mutex_t mutex;
pthread_mutex_t mutex2;

void *func1(void *arg)
{
    pthread_mutex_lock(&mutex);
    sleep(1);
    pthread_mutex_lock(&mutex2);
    for(int i = 0; i < 5; i++){
        printf("t1: %ld\n", (unsigned long)pthread_self());
        printf("t1: parameter is %d\n", *((int *)arg));
        sleep(1);
    }
    pthread_mutex_unlock(&mutex);
    pthread_mutex_unlock(&mutex2);
}

void *func2(void *arg)
{
    pthread_mutex_lock(&mutex2);
    sleep(1);
    pthread_mutex_lock(&mutex);
    for(int i = 0; i < 5; i++){
        printf("t2: %ld\n", (unsigned long)pthread_self());
        printf("t2: parameter is %d\n", *((int *)arg));
        sleep(1);
    }
    pthread_mutex_unlock(&mutex2);
    pthread_mutex_unlock(&mutex);
}

void *func3(void *arg)
{
    pthread_mutex_lock(&mutex);
    for(int i = 0; i < 5; i++){
        printf("t3: %ld\n", (unsigned long)pthread_self());
        printf("t3: parameter is %d\n", *((int *)arg));
        sleep(1);
    }
    pthread_mutex_unlock(&mutex);
}

int main()
{
    int ret;
    int param = 100;
    pthread_t t1;
    pthread_t t2;
    pthread_t t3;
    
    pthread_mutex_init(&mutex, NULL);
    pthread_mutex_init(&mutex2, NULL);

    ret = pthread_create(&t1, NULL, func1, (void*)&param);
    if(ret == 0){
        printf("main: create t1 success\n");
    }

    ret = pthread_create(&t2, NULL, func2, (void*)&param);
    if(ret == 0){
        printf("main: create t2 success\n");
    }

    ret = pthread_create(&t3, NULL, func3, (void*)&param);
    if(ret == 0){
        printf("main: create t3 success\n");
    }

    printf("main: %ld\n", (unsigned long)pthread_self());

    pthread_join(t1, NULL);
    pthread_join(t2, NULL);
    pthread_join(t3, NULL);
    
    pthread_mutex_destroy(&mutex);
    pthread_mutex_destroy(&mutex2);
   
    return 0;
}

条件变量实现线程同步

条件变量API
创建及销毁条件变量
#include <pthread.h>
int pthread_cond_init(pthread_cond_t *restrict cond, const pthread_condattr_t *restrict attr);
int pthread_cond_destroy(pthread_cond_t cond);
等待
#include <pthread.h>
int pthread_cond_wait(pthread_cond_t *restrict cond, pthread_mutex_t *restrict mutex);
int pthread_cond_timedwait(pthread_cond_t *restrict cond, pthread_mutex_t *restrict mutex, const struct timespec *restrict timeout);
触发
#include <pthread.h>
int pthread_cond_signal(pthread_cond_t *restrict cond);
int pthread_cond_broadcast(pthread_cond_t cond);

使用条件变量的示例

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

int g_data = 0;
pthread_mutex_t mutex;
pthread_cond_t cond;

void *func1(void *arg)
{
    static int cnt = 10;
    printf("t1: %ld pthread is created\n", (unsigned long)pthread_self());
    printf("t1: parameter is %d\n", *((int*)arg));
    while(1){
        pthread_cond_wait(&cond, &mutex); // 等待
        if(g_data == 3){
            printf("t1 run=========================\n");
        }
        printf("t1: %d\n", g_data);
        g_data = 0;
        sleep(1);
        if(cnt++ == 10){
            exit(1);
        }
    }
}

void *func2(void *arg)
{
    printf("t2: %ld pthread is created\n", (unsigned long)pthread_self());
    printf("t2: parameter is %d\n", *((int*)arg));
    while(1){
        printf("t2: %d\n", g_data);
        pthread_mutex_lock(&mutex);
        printf("%d\n", g_data++);
        if(g_data == 3){
            pthread_cond_signal(&cond); // 触发
        }
        pthread_mutex_unlock(&mutex);
        sleep(1);
    }
}

int main()
{
    int ret;
    int param = 100;
    pthread_t t1;
    pthread_t t2;

    pthread_cond_init(&cond, NULL);
    pthread_mutex_init(&mutex, NULL);

    ret = pthread_create(&t1, NULL, func1, (void *)&param);
    if(ret == 0){
        printf("main: create t1 success\n");
    }

    ret = pthread_create(&t2, NULL, func2, (void *)&param);
    if(ret == 0){
        printf("main: create t2 success\n");
    }
    
    pthread_join(t1, NULL);
    pthread_join(t2, NULL);

    pthread_mutex_destroy(&mutex);
    pthread_cond_destroy(&cond);
    return 0;
}

通过上述示例和API的讲解，本文详细介绍了Linux下进程与线程的区别、多线程开发的基本操作以及常见问题和解决方案。希望能够帮助大家更好地理解和使用多线程编程。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mfbz.cn/a/761029.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

20240701 每日AI必读资讯

20240701 每日AI必读资讯

&#x1f3eb;AI真炼丹&#xff1a;整整14天&#xff0c;无需人类参与 - 英矽智能推出全球首个AI参与决策的生物学实验室&#xff0c;实现了14天内完成靶点发现和验证的全自动化闭环实验。 - 该实验室由PandaOmics平台驱动&#xff0c;集成多种预测模型和海量数据&#xff0…
阅读更多...
前端:多服务端接口资源整合与zip打包下载

前端:多服务端接口资源整合与zip打包下载

项目需求 前端项目开发中，有一个页面需要去整合多个服务接口返回的数据资源，并且需要将这多个服务接口接口返回的数据进行资源压缩，最终打包成zip压缩包，并在客户端完成下载。 基本需求梳理如下， 实现思路 这个需求点其实本质上还是传统的“文件下载”功能需求，常见的例如…
阅读更多...
Golang基础问题

Golang基础问题

Go基础 文章目录 Go基础● Go有那些关键字&#xff1f;● Go方法与函数的区别&#xff1f;● Go函数返回局部变量的指针是否安全&#xff1f;● Go函数参数传递是值传递还是引用传递&#xff1f;● defer关键字的实现原理&#xff1f;● 内置函数make和new的区别&#xff1f;●…
阅读更多...
ollama+Dify大模型本地化部署打造个人知识库 (2)

ollama+Dify大模型本地化部署打造个人知识库 (2)

ollama大模型部署-CSDN博客文章浏览阅读26次。Ollama 是一个能在本地机器上轻松构建和运行大型语言模型的轻量级、可扩展框架&#xff0c;适用于多种场景&#xff0c;具有易于使用、资源占用少、可扩展性强等特点。https://blog.csdn.net/weixin_72819498/article/details/1400…
阅读更多...
LED裸眼3D显示屏：开启视觉新体验

LED裸眼3D显示屏：开启视觉新体验

随着科技的不断进步&#xff0c;LED显示屏作为一种新型的显示技术&#xff0c;已经被广泛应用于各个领域。而其中&#xff0c;LED裸眼3D显示屏更是因其独特的技术原理和令人震撼的视觉效果&#xff0c;成为了业界关注的焦点。 裸眼3D显示屏是一种前沿的显示技术&#xff0c;它…
阅读更多...
NLP特征提取的惊人历史演变

NLP特征提取的惊人历史演变

NLP特征提取的惊人演变 1.理解特征提取2. 文本表示的演变2.1.词袋的简单性2.2. N-Gram 模型的进步2.3. TF-IDF 的崛起 3. 深入研究词嵌入3.1.探索 Word2Vec3.2.深入了解 GloVe3.3.深入研究 FastText 4. 上下文嵌入的影响4.1 ELMo 的突破4.2 理解 BERT 的机制4.3 Transformer的出…
阅读更多...
ctfshow-web入门-命令执行（web71-web74）

ctfshow-web入门-命令执行（web71-web74）

目录 1、web71 2、web72 3、web73 4、web74 1、web71 像上一题那样扫描但是输出全是问号 查看提示&#xff1a;我们可以结合 exit() 函数执行php代码让后面的匹配缓冲区不执行直接退出。 payload&#xff1a; cvar_export(scandir(/));exit(); 同理读取 flag.txt cinclud…
阅读更多...
[数据集][目标检测]电缆钢丝绳线缆缺陷检测数据集VOC+YOLO格式1800张3类别

[数据集][目标检测]电缆钢丝绳线缆缺陷检测数据集VOC+YOLO格式1800张3类别

数据集格式&#xff1a;Pascal VOC格式YOLO格式(不包含分割路径的txt文件&#xff0c;仅仅包含jpg图片以及对应的VOC格式xml文件和yolo格式txt文件) 图片数量(jpg文件个数)&#xff1a;1800 标注数量(xml文件个数)&#xff1a;1800 标注数量(txt文件个数)&#xff1a;1800 标注…
阅读更多...
uniapp H5端使用百度地图

uniapp H5端使用百度地图

1、登录百度地图开放平台 https://lbsyun.baidu.com/&#xff08;没有账号则先去创建一个百度账号&#xff09; 2、进入百度地图开放平台控制台&#xff08;导航栏“控制台”&#xff09;&#xff0c;点击“应用管理”-“我的应用” 3、选择“创建应用”&#xff0c;应用模块选…
阅读更多...
[图解]企业应用架构模式2024新译本讲解19-数据映射器1

[图解]企业应用架构模式2024新译本讲解19-数据映射器1

1 00:00:01,720 --> 00:00:03,950 下一个我们要讲的就是 2 00:00:04,660 --> 00:00:07,420 数据映射器这个模式 3 00:00:09,760 --> 00:00:13,420 这个也是在数据源模式里面 4 00:00:13,430 --> 00:00:14,820 用得最广泛的 5 00:00:16,250 --> 00:00:19,170…
阅读更多...
一、Redis简介

一、Redis简介

一、Redis介绍与一般应用 1.1 基本了解 Redis全称Remote Dictionary Server(远程字典服务)&#xff0c; 是一个开源的高性能键值存储系统&#xff0c;通常用作数据库、缓存和消息代理。使用ANSI C语言编写遵守BSD协议&#xff0c;是一个高性能的Key-Value数据库提供了丰富的数…
阅读更多...
2024.07使用gradle上传maven组件到central.sonatype，非常简单

2024.07使用gradle上传maven组件到central.sonatype，非常简单

本文基于sonatypeUploader2.0版本 在1.0版本我们还需要手动去添加maven-publish和signing插件&#xff0c;在2.0版本他已经内置了&#xff0c;如果你仍然需要手动配置&#xff0c;你可以手动添加这两个插件及逻辑。 具体信息参考开源仓库&#xff1a; 插件仓库&#xff1a;h…
阅读更多...
【Linux】部署NFS服务实现数据共享

【Linux】部署NFS服务实现数据共享

&#x1f468;‍&#x1f393;博主简介 &#x1f3c5;CSDN博客专家   &#x1f3c5;云计算领域优质创作者   &#x1f3c5;华为云开发者社区专家博主   &#x1f3c5;阿里云开发者社区专家博主 &#x1f48a;交流社区&#xff1a;运维交流社区 欢迎大家的加入&#xff01…
阅读更多...
（四）Appdesigner-文件存在判断及对话框设计

（四）Appdesigner-文件存在判断及对话框设计

目录 前言 一、文件存在判断 &#xff08;一&#xff09;基础知识 &#xff08;二&#xff09;实际操作 二、对话框设计 &#xff08;一&#xff09;基础知识 1.提示对话框 2.询问对话框 3.文件选择对话框 &#xff08;二&#xff09;实际操作 1.提示对话框 2.询问…
阅读更多...
台灯哪个牌子好？学生专用台灯第一品牌推荐

台灯哪个牌子好？学生专用台灯第一品牌推荐

台灯&#xff0c;作为人们生活中不可或缺的存在&#xff0c;每当夜幕缓缓降临&#xff0c;华灯初上&#xff0c;总预示着一个浪漫的夜晚即将揭幕。而灯的意义&#xff0c;远不止于驱散黑夜的阴影&#xff0c;它更擅长为我们的空间带来温暖与慰藉。在众多种类的灯具中&#xff0…
阅读更多...
零基础STM32单片机编程入门(五)FreeRTOS实时操作系统详解及实战含源码视频

零基础STM32单片机编程入门(五)FreeRTOS实时操作系统详解及实战含源码视频

文章目录 一.概要二.什么是实时操作系统三.FreeRTOS的特性四.FreeRTOS的任务详解1.任务函数定义2.任务的创建3.任务的调度原理 五.CubeMX配置一个FreeRTOS例程1.硬件准备2.创建工程3.调试FreeRTOS任务调度 六.CubeMX工程源代码下载七.讲解视频链接地址八.小结 一.概要 FreeRTO…
阅读更多...
Python | 计算位涡平流项

Python | 计算位涡平流项

写在前面 最近忙着复习、考试…都没怎么空敲代码&#xff0c;还得再准备一周考试。。。等考完试再慢慢更新了&#xff0c;今天先来浅更一个简单但是使用的python code 在做动力机制分析时&#xff0c;我们常常需要借助收支方程来诊断不同过程的贡献&#xff0c;其中最常见的一…
阅读更多...
使用Python绘制极坐标图

使用Python绘制极坐标图

使用Python绘制极坐标图 极坐标图极坐标图的优点使用场景 效果代码 极坐标图 极坐标图&#xff08;Polar Chart&#xff09;是一种图表类型&#xff0c;用于显示在极坐标系中的数据。极坐标图使用圆形坐标系&#xff0c;角度表示一个变量的值&#xff0c;半径表示另一个变量的…
阅读更多...
【Python】利用代理IP爬取当当网数据做数据分析

【Python】利用代理IP爬取当当网数据做数据分析

前言 在数字化浪潮的推动下&#xff0c;电商平台已经彻底改变了我们的购物方式。从简单的在线交易到复杂的用户交互&#xff0c;电商平台积累了海量的用户数据。这些数据&#xff0c;如同隐藏在深海中的宝藏&#xff0c;等待着被发掘和利用。通过分析用户的浏览、搜索、购买等行…
阅读更多...
基于人脸68特征点识别的美颜算法（一） 大眼算法 C++

基于人脸68特征点识别的美颜算法（一） 大眼算法 C++

1、加载一张原图&#xff0c;并识别人脸的68个特征点 cv::Mat img cv::imread("5.jpg");// 人脸68特征点的识别函数vector<Point2f> points_vec dectectFace68(img);// 大眼效果函数Mat dst0 on_BigEye(800, img, points_vec);2、函数 vector<Point2f&g…
阅读更多...
最新文章

Copyright @ 2022~2023

友情链接： 我的编程经验分享 一条长河网 尧图网站开发 尧图建网站