IO进程(线程Thread)

news2025/1/16 16:17:13

线程Thread

1.什么是线程

1.1 概念

线程是一个轻量级的进程,为了提高系统的性能引入线程。

线程和进程都参与统一的调度。

在同一个进程中可以创建的多个线程, 共享进程资源。

(Linux里同样用task_struct来描述一个线程)

1.2 进程和线程的区别

相同点:都为操作系统提供了并发执行能力

不同点:

调度和资源:线程是系统调度的最小单位,进程是资源分配的最小单位

地址空间方面:同一个进程创建的多个线程共享该进程的资源;进程的地址空间相互独立

通信方面:线程通信相对简单,只需要通过全局变量可以实现,但是需要考虑临界资源访问的问题;进程通信比较复杂,需要借助进程间的通信机制(借助3g-4g内核空间)

安全性方面:线程安全性差一些,当进程结束时会导致所有线程退出;进程相对安全

面试题:程序什么时候该使用线程?什么时候用进程?

对资源的管理和保护要求高,不限制开销和效率时,使用多进程。

要求效率高、速度快的高并发环境时,需要频繁创建、销毁或切换时,资源的保护管理要求不是很高时,使用多线程。

1.3 线程资源

共享的资源:可执行的指令、静态数据、进程中打开的文件描述符、信号处理函数、当前工作目录、用户ID、用户组ID

私有的资源:线程ID (TID)、PC(程序计数器)和相关寄存器、堆栈(局部变量, 返回地址)、错误号 (errno)、信号掩码和优先级、执行状态和属性

2.函数接口

2.1 创建线程pthread_create

int pthread_create(pthread_t *thread, const pthread_attr_t *attr,

void *(*start_routine) (void *), void *arg);

功能:创建线程

头文件;

                #include <ptthread.h>

参数: thread:线程标识

            attr:线程属性, NULL:代表设置默认属性

            start_routine:函数名:代表线程函数(自己写的)

            arg:用来给前面函数传参

返回值:成功:0

              失败:错误码

编译的时候需要加 -pthread 链接动态库

创建线程:

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

//线程函数
void *handler_thread(void *arg)
{
    printf("in handler_thread\n");
    while (1)
        ; //让从线程不退出,进程状态l也就是多线程
    return NULL;
}

int main(int argc, char const *argv[])
{
    pthread_t tid;
    if (pthread_create(&tid, NULL, handler_thread, NULL) != 0)
    {
        perror("create thread err");
        return -1;
    }
    printf("in main\n");
    while (1)
        ; //不能让整个进程结束
    return 0;
}

2.2 退出线程pthread_exit

void pthread_exit(void *value_ptr)

头文件同上

功能:用于退出线程的执行

参数:value_ptr:线程退出时返回的值

 

2.3 回收线程资源

int pthread_join(pthread_t thread, void **value_ptr)

功能:用于等待一个指定的线程结束,阻塞函数

参数:thread:创建的线程对象,线程ID

     value_ptr:指针*value_ptr指向线程返回的参数, 一般为NULL

返回值:成功 : 0

       失败:errno

int pthread_detach(pthread_t thread);

功能:让线程结束时自动回收线程资源,让线程和主线程分离,非阻塞函数

参数:thread:线程ID

非阻塞式的,例如主线程分离(detach)了线程T2,那么主线程不会阻塞在pthread_detach()pthread_detach()会直接返回,线程T2终止后会被操作系统自动回收资源

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

//线程函数
void *handler(void *arg)
{
    printf("in handler\n");
    //pthread_exit(NULL); //让从线程退出
    while (1) //让从线程不退出
        ;
    return NULL;
}

int main(int argc, char const *argv[])
{
    pthread_t tid;
    if (pthread_create(&tid, NULL, handler, NULL) != 0)
    {
        perror("create thread err");
        return -1;
    }
    printf("in main\n");

    //回收指定线程资源
    pthread_join(tid,NULL);
    //pthread_detach(tid);

    while(1)
        ;//不让整个进程结束
    return 0;
}

练习:输入输出,quit结束

通过线程实现数据的交互,主线程循环从终端输入,线程函数将数据循环输出,当输入quit结束程序。

(1)全局变量进行通信

(2)加上标志位(flag),实现主线程输入一次,线程函数打印一次, int flag = 0;

//主线程输入,从线程输出,quit结束
//使用flag全局变量
#include <stdio.h>
#include <pthread.h>
#include <string.h>

char buf[33];
int flag = 0; //为了进行线程间通讯,保证让主线程输入一次然后从线程输出一次
//线程函数
void *handler(void *arg)
{
    printf("in handler\n");
    //pthread_exit(NULL); //让从线程退出
    while (1)//让从线程不退出
    {
        if (flag)
        {
            if(strcmp(buf,"quit") == 0)
                break;
            printf("%s\n", buf);
            flag--;
        }

    }
    
    return NULL;
}

int main(int argc, char const *argv[])
{
    pthread_t tid;
    if (pthread_create(&tid, NULL, handler, NULL) != 0)
    {
        perror("create thread err");
        return -1;
    }
    printf("in main\n");
    while(1)//不让整个进程结束
    {
        if(!flag)
        {
            scanf("%s", buf);
            flag++;
            if (strcmp(buf, "quit") == 0)
                break;
        }
    }
    return 0;
}

3.同步

3.1 概念

同步(synchronization)指的是多个任务(线程)按照约定的顺序相互配合完成一件事情

(异步:异步则反之,并非一定需要一件事做完再做另一件事。)

3.2 同步机制

通过信号量实现线程间同步。

信号量通过信号量实现同步操作;由信号量来决定线程是继续运行还是阻塞等待.

信号量代表某一类资源,其值表示系统中该资源的数量:

信号量的值>0,表示有资源可以用, 可以申请到资源, 

信号量的值<=0, 表示没有资源可以通用, 无法申请到资源, 阻塞.

信号量还是一个受保护的变量,只能通过三种操作来访问:初始化、P操作(申请资源)、V操作(释放资源)

sem_init: 信号量初始化

sem_wait: 申请资源,P操作, 如果没有资源可以用, 阻塞,-1

sem_post: 释放资源,V操作, 非阻塞 +1

3.3 函数接口

int sem_init(sem_t *sem, int pshared, unsigned int value)

功能:初始化信号量   

参数:sem:初始化的信号量对象

    pshared:信号量共享的范围(0: 线程间使用   非0:1进程间使用)

    value:信号量初值

返回值:成功 0

       失败 -1

int sem_wait(sem_t *sem)

功能:申请资源  P操作 

参数:sem:信号量对象

返回值:成功 0

       失败 -1

注:此函数执行过程,当信号量的值大于0时,表示有资源可以用,则继续执行,同时对信号量减1;当信号量的值等于0时,表示没有资源可以使用,函数阻塞

int sem_post(sem_t *sem)

功能:释放资源  V操作      

参数:sem:信号量对象

返回值:成功 0

      失败 -1

注:释放一次信号量的值加1,函数不阻塞

头文件:

                #include <semaphore.h>

//主线程输入,从线程输出,quit结束
//使用同步sem
#include <semaphore.h>
#include <stdio.h>
#include <pthread.h>
#include <string.h>

char buf[33];
sem_t sem;
sem_t sem2;

void *handler(void *arg)
{
    while(1)
    {
        //申请资源
        sem_wait(&sem);
        if (!strcmp(buf, "quit"))
            break;
        printf("%s\n", buf);
        //释放资源
        sem_post(&sem2);
    }
}

int main(int argc, char const *argv[])
{
    pthread_t tid;

    //创建从线程
    if(pthread_create(&tid, NULL, handler, NULL))
    {
        perror("pthread create err");
        return -1;
    }

    //初始化信号量
    if (sem_init(&sem, 0, 0))
    {
        perror("sem init err");
        return -1;
    }
    if (sem_init(&sem2, 0, 0))
    {
        perror("sem2 init err");
        return -1;
    }

    //主线程
    while(1)
    {
        //申请资源
        sem_post(&sem2);
        scanf("%s", buf);
        //释放资源
        sem_post(&sem);
        if (strcmp(buf, "quit") == 0)
            break;
    }

    pthread_join(tid, NULL);

    return 0;
}

4.互斥

4.1 概念

互斥:多个线程在访问临界资源时,同一时间只能一个线程访问

临界资源:一次仅允许一个线所使用的资源

临界区:指的是一个访问共享资源的程序片段

互斥锁:通过互斥锁可以实现互斥机制,主要用来保护临界资源,每个临界资源都由一个互斥锁来保护,线程必须先获得互斥锁才能访问临界资源,访问完资源后释放该锁。如果无法获得锁,线程会阻塞直到获得锁为止。

pthread_mutex_init

pthread_mutex_lock

pthread_mutex_unlock

4.2 函数接口

int pthread_mutex_init(pthread_mutex_t *mutex, pthread_mutexattr_t *attr)

功能:初始化互斥锁  

参数:mutex:互斥锁

    attr:  互斥锁属性  //  NULL表示缺省属性

返回值:成功 0

      失败 -1

int pthread_mutex_lock(pthread_mutex_t *mutex)

功能:申请互斥锁     

参数:mutex:互斥锁

返回值:成功 0

      失败 -1

注:和pthread_mutex_trylock区别:pthread_mutex_lock是阻塞的;pthread_mutex_trylock不阻塞,如果申请不到锁会立刻返回

int pthread_mutex_unlock(pthread_mutex_t *mutex)

功能:释放互斥锁     

参数:mutex:互斥锁

返回值:成功 0

      失败 -1

int pthread_mutex_destroy(pthread_mutex_t *mutex)

功能:销毁互斥锁     

参数:mutex:互斥锁

//互斥
//用互斥实现数组的来回翻转

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

int a[10] = {0, 1, 2, 3, 4, 5, 6, 7, 8, 9};
pthread_mutex_t lock;

void *handler_p(void *arg) //打印函数
{
    while(1)
    {
        pthread_mutex_lock(&lock);
        for (int i = 0; i < 10; i++)
        {
            printf("%d", a[i]);
        }
        printf("\n");
        pthread_mutex_unlock(&lock);
        sleep(1);
    }

    return NULL;
}

void *handler_s(void *arg) //交换函数
{
    int t = 0;
    while (1)
    {
        pthread_mutex_lock(&lock);
        for (int i = 0; i < 5; ++i)
        {
            t = a[i];
            a[i] = a[9 - i];
            a[9 - i] = t;
        }
        pthread_mutex_unlock(&lock);
    }

    return NULL;
}

int main(int argc, char const *argv[])
{
    pthread_t tid1;
    pthread_t tid2;
    if (pthread_create(&tid1, NULL, handler_p, NULL))
    {
        perror("pthread create err");
        return -1;
    }
    if(pthread_create(&tid2, NULL, handler_s, NULL))
    {
        perror("pthread create err");
        return -1;
    }

    //初始化互斥锁
    if (pthread_mutex_init(&lock,NULL))
    {
        perror("init err");
        return -1;
    }


    pthread_join(tid1, NULL);
    pthread_join(tid2, NULL);

    pthread_mutex_destroy(&lock);

    return 0;
}

补充:死锁

是指两个或两个以上的进程或线程在执行过程中,由于竞争资源或者由于彼此通信而造成的一种阻塞的现象,若无外力作用,它们都将无法推进下去。

死锁产生的四个必要条件

1、互斥使用,即当资源被一个线程使用(占有)时,别的线程不能使用

2、不可抢占,资源请求者不能强制从资源占有者手中夺取资源,资源只能由资源占有者主动释放。

3、请求和保持,即当资源请求者在请求其他的资源的同时保持对原有资源的占有。

4、循环等待,即存在一个等待队列:P1占有P2的资源,P2占有P3的资源,P3占有P1的资源。这样就形成了一个等待环路。

注意:当上述四个条件都成立的时候,便形成死锁。当然,死锁的情况下如果打破上述任何一个条件,便可让死锁消失。

5.条件变量

条件变量用于在线程之间传递信号,以便某些线程可以等待某些条件发生。当某些条件发生时,条件变量会发出信号,使等待该条件的线程可以恢复执行。

一般和互斥锁搭配使用,实现同步机制:

pthread_cond_init(&cond,NULL); //初始化条件变量

使用前需要上锁:

pthread_mutex_lock(&lock);  //上锁

判断条件

pthread_cond_wait(&cond, &lock);      //阻塞等待条件产生,没有条件产生时阻塞,同时解锁,当条件产生时结束阻塞,再次上锁

pthread_cond_signal(&cond); //产生条件,不阻塞

pthread_cond_destroy(&cond); //销毁条件变量

注意: 必须保证让pthread_cond_wait先执行,pthread_cond_signal再产生条件

为什么pthread_cond_wait前要加互斥锁:防止调用 pthread_cond_wait之前其他线程改变条件,从而发生错乱。

例如赚钱花钱

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

//条件变量
int money;
pthread_mutex_t lock;
pthread_cond_t cond;
pthread_cond_t cond2;

void *spend_m(void *arg) //花钱
{
    while(1)
    {
        pthread_mutex_lock(&lock);
        if (money < 100)
        {
            pthread_cond_wait(&cond, &lock);
        }
        while(money >= 100)
        {
            money -= 100;
            printf("spend 100 dollars\n");
        }
        if (money < 100)
        {
            pthread_cond_signal(&cond2);
        }
        pthread_mutex_unlock(&lock);
    }
    
    return NULL;
}

//赚钱
int main(int argc, char const *argv[])
{
    pthread_t tid;
    //初始化
    if(pthread_create(&tid, NULL, spend_m, NULL) != 0)
    {
        perror("pthread create err");
        return -1;
    }
    if(pthread_mutex_init(&lock,NULL))
    {
        perror("lock init err");
        return -1;
    }
    if(pthread_cond_init(&cond,NULL))
    {
        perror("cond init err");
        return -1;
    }
    if(pthread_cond_init(&cond2,NULL))
    {
        perror("cond init err");
        return -1;
    }

    //主线程
    while(1)
    {
        //sleep(2); //为了保证pthread_cond_wait先执行
        pthread_mutex_lock(&lock);
        if (money >= 100)
        {
            pthread_cond_wait(&cond2, &lock);
        }
        scanf("%d", &money);
        if (money >= 100)
        {
            pthread_cond_signal(&cond);
        }
        pthread_mutex_unlock(&lock);
    }

    //回收
    pthread_join(tid,NULL);
    pthread_mutex_destroy(&lock);
    pthread_cond_destroy(&cond);

    return 0;

}

面试题:linux线程间同步有几种方式?

以下是一些常用的Linux线程间同步方式:

  1. 互斥锁(Mutex): 互斥算是一种特殊的同步。使用互斥锁可以确保同一时间只有一个线程可以访问共享资源。当一个线程进入临界区时,会锁定互斥锁,阻止其他线程进入该区域,直到该线程完成操作并释放锁。
  2. 信号量(Semaphore): 信号量用于控制对有限数量的资源的访问。它们是一种计数器,可以对其进行递增或递减操作。当信号量值为零时,线程必须等待,直到另一个线程递增该信号量。
  3. 条件变量(Condition Variable) : 条件变量用于在线程之间传递信号,以便某些线程可以等待某些条件发生。当某些条件发生时,条件变量会发出信号,使等待该条件的线程可以恢复执行。

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

精益思维驱动人工智能革新:理论到实践的跃迁之旅

随着科技的飞速发展&#xff0c;人工智能&#xff08;AI&#xff09;已成为引领未来的关键力量。在这个变革的时代&#xff0c;如何将精益思维与人工智能相结合&#xff0c;推动AI从理论走向实践&#xff0c;成为行业内外关注的焦点。本文&#xff0c;天行健精益生产顾问将分享…

拷贝构造函数与运算符重载

目录 一、拷贝构造函数 1.概念 2.特性 二、运算符重载 1.运算符重载 2.运算符重载实现的形式 3.赋值运算符重载 一、拷贝构造函数 1.概念 拷贝构造函数是一种特殊的构造函数&#xff0c;它在创建对象时&#xff0c;使用同一类中之前创建的对象来初始化新创建的对象…

Vitis HLS 学习笔记--scal 函数-探究

目录 1. Vitis HLS重器-Vitis_Libraries 2. 初识scal() 3. 函数具体实现 3.1 变量命名规则 3.2 t_ParEntries解释 3.3 流类型详解 3.4 双重循环 4. 总结 1. Vitis HLS重器-Vitis_Libraries 在深入探索Vitis HLS&#xff08;High-Level Synthesis&#xff09;的旅程中&…

【单调栈】力扣85.最大矩形

好久没更新了 ~ 我又回来啦&#xff01; 两个好消息&#xff1a; 我考上研了&#xff0c;收到拟录取通知啦&#xff01;开放 留言功能 了&#xff0c;小伙伴对于内容有什么疑问可以在文章底部评论&#xff0c;看到之后会及时回复大家的&#xff01; 前面更新过的算法&#x…

kafka的概念以及Zookeeper集群 + Kafka集群 +elfk集群

目录 zookeeper同步过程 分布式通知和协调 zookeeper同步过程 分布式通知和协调 准备 3 台服务器做 Zookeeper 集群 192.168.68.5 192.168.68.6 192.168.68.7 安装前准备 //关闭防火墙 systemctl stop firewalld systemctl disable firewalld setenforce 0 node1服务器&a…

了解8大Python小陷阱,深入理解Python

学习了解python常见的使用陷阱&#xff0c;避免二次踩坑 Python是最流行的且适合初学者学习的语言之一。它的语法非常优雅简洁。只要知道python基础知识&#xff0c;阅读代码几无障碍。 然而&#xff0c;就像其他语言一样&#xff0c;Python确实有一些古怪特殊的地方。本文将介…

ssm062会员管理系统+jsp

会员管理系统 摘 要 随着科学技术的飞速发展&#xff0c;各行各业都在努力与现代先进技术接轨&#xff0c;通过科技手段提高自身的优势&#xff1b;对于会员管理系统当然也不能排除在外&#xff0c;随着网络技术的不断成熟&#xff0c;带动了会员管理系统&#xff0c;它彻底改…

关于二级指针void**的一点问题与思考

前言 这两天写一个高并发内存池的项目时&#xff0c;遇到了一个关于二级指针的问题&#xff0c;剖析清楚后发觉有必要记录一下&#xff0c;这让我加深了对于C/C中指针的理解&#xff08;果然学到老活到老&#xff09;。 问题的分析 在我的内存池项目中&#xff0c;有一个需求…

2024华中杯C题光纤传感器平面曲线重建原创论文分享

大家好&#xff0c;从昨天肝到现在&#xff0c;终于完成了2024华中杯数学建模C题的完整论文啦。 给大家看一下目录吧&#xff1a; 目录 摘 要&#xff1a; 10 一、问题重述 12 二&#xff0e;问题分析 13 2.1问题一 13 2.2问题二 14 2.3问题三 14 三、模型假设 15 四、…

Spring Task 定时任务调度

一、概念 Spring Task 是 Spring 框架的一个组件&#xff0c;它为任务调度提供了支持&#xff0c;使得开发者能够创建后台任务或定期执行的任务。通过 Spring Task&#xff0c;您可以方便地在 Java 应用程序中实现定时任务&#xff0c;比如每天凌晨进行数据同步、每小时执行一…

day02-新增员工

day01 新增员工业务逻辑整理 EmployeeController.java PostMappingApiOperation("新增员工")public Result save(RequestBody EmployeeDTO employeeDTO){System.out.println("当前线程的ID:" Thread.currentThread().getId());log.info("新增员工&a…

2024年华中杯数模竞赛A题完整解析(附代码)

2024年华中杯数模竞赛A题 基于动态优化的太阳能路灯光伏板朝向以最大化能量收集研究摘要问题重述问题分析模型假设符号说明 代码问题一 完整资料获取 基于动态优化的太阳能路灯光伏板朝向以最大化能量收集研究 摘要 随着可再生能源技术的发展&#xff0c;太阳能作为一种清洁的…

2024新版淘宝客PHP网站源码

源码介绍 2024超好看的淘客PHP网站源码&#xff0c;可以做优惠券网站&#xff0c;上传服务器&#xff0c;访问首页进行安装 安装好了之后就可以使用了&#xff0c;将里面的信息配置成自己的就行 喜欢的朋友们拿去使用把 效果截图 源码下载 2024新版淘宝客网站源码

【云计算】云数据中心网络(七):负载均衡

《云网络》系列&#xff0c;共包含以下文章&#xff1a; 云网络是未来的网络基础设施云网络产品体系概述云数据中心网络&#xff08;一&#xff09;&#xff1a;VPC云数据中心网络&#xff08;二&#xff09;&#xff1a;弹性公网 IP云数据中心网络&#xff08;三&#xff09;…

MySQL数据库-优化慢查询

1、什么是慢查询&#xff1f; 慢查询就是SQL执行时间过长&#xff0c;严重影响用户体验的SQL查询语句。当它频繁出现时数据库的性能和稳定性都会受到威胁 慢查询是数据库性能瓶颈的常见原因&#xff0c;是指SQL执行时间超过阈值&#xff1b;可能由于复杂的连接、缺少索引、不恰…

保持领先:四个ChatGPT小技巧助你成为不可替代的数据分析师

在前文中&#xff0c;我们初步探讨了为何ChatGPT无法完全替代数据分析师的原因&#xff0c;而本文将深入探讨如何利用GPT辅助数据分析师提升工作效率。 **场景一&#xff1a;SQL数据提取** 许多数据分析师需使用SQL语言从数据库中抽取数据。尽管SQL操作简便&#xff0c;但编写…

类和对象-封装-设计案例1-立方体类

#include<bits/stdc.h> using namespace std; class Cube{public://设置长void setL(int l){m_Ll;} //获取长int getL(){return m_L;}//设置宽 void setW(int w){m_Ww;}//获取宽 int getW(){return m_W;}//设置高 void setH(int h){m_Hh;}//获取高int getH(){return m_H;…

在线拍卖系统|基于Springboot的在线拍卖系统设计与实现(源码+数据库+文档)

在线拍卖系统目录 基于Springboot的在线拍卖系统设计与实现 一、前言 二、系统设计 三、系统功能设计 1、前台&#xff1a; 2、后台 用户功能模块 5.2用户功能模块 四、数据库设计 五、核心代码 六、论文参考 七、最新计算机毕设选题推荐 八、源码获取&#xff1a…

VR全景展览——开启全新视界的虚拟展览体验

随着VR技术的不断发展和成熟&#xff0c;VR全景展览已经成为现代展览行业的一大亮点。通过模拟现实世界的场景&#xff0c;VR全景展览为用户提供了一个沉浸式的观展体验&#xff0c;使参观者能够跨越地理和时间限制&#xff0c;探索不同领域的展览。 一、VR全景展览的功能优势 …

合并有序表 (顺序存储 和 链式存储 方式实现)

代码详细解析: 合并有序表文章浏览阅读1.4k次&#xff0c;点赞6次&#xff0c;收藏7次。●假设有两个有序表 LA和LB , 将他们合并成一个有序表LC●要求不破坏原有的表 LA和 LB构思:把这两个表, 合成一个有序表 , 不是简简单单吗?就算是把他们先遍历不按顺序插入到表 C里面 , …