C语言细致讲解线程同步的集中方式

2024-04-02 19:04:59 779人浏览薄情痞子

摘要

目录互斥锁条件变量信号量读写锁互斥锁使用互斥量完成对临界区的资源的加锁操作，使得同一时刻，对一个共享数据的使用只能又一个线程完成例向屏幕上一次打印abcd四个字母可以使用的是一

互斥锁

使用互斥量完成对临界区的资源的加锁操作，使得同一时刻，对一个共享数据的使用只能又一个线程完成

例向屏幕上一次打印abcd四个字母

可以使用的是一个类似锁连的思想 a 加完解开后拿b锁依次类推

#define THRNUM 4
static pthread_mutex_t mut[4];
static int next(int n)
{
    if(n + 1 == THRNUM)
    return 0;
    return n+1;
}
static void* pthreadfunc(void* p)
{
    int n =(int)p;
    char c = 'a' + (int)p;
    while(1)
    {
    pthread_mutex_lock(mut + n);
    write(1,&c,1);
    pthread_mutex_unlock(mut + next(n));
    }
    pthread_exit(NULL);
}
int main()
{
    int i,err;
    pthread_t tid[THRNUM];
    //创建线程
    for(i = 0 ; i < THRNUM ;i++){
        //初始化锁
        pthread_mutex_init(mut + i,NULL);
        //加锁
        pthread_mutex_lock(mut+i );
    err = pthread_create(tid+i,NULL,pthreadfunc,(void*)i );
    if(err != 0)
    {
        fprintf(stderr,"create:%s\n",strerror(err));
        exit(1);
    }
    }
    //回收线程
    pthread_mutex_unlock(mut + 0);
    alarm(5);
    for(i = 0 ; i < THRNUM ;i++){
    pthread_join(tid+i,NULL);
    }
}

条件变量

条件变量并不是锁而是一种阻塞机制，使得我们的程序在某些特定的条件，比如生产者生产达到上限未消费，此时使用条件变量（加上while对条件的判断）来阻塞生产，让生产者消费

#include<stdio.h>
#include<unistd.h>
#include<pthread.h>
#include<stdlib.h>
#include<string.h>
int begnum=0;
static pthread_mutex_t mut = PTHREAD_MUTEX_INITIALIZER;
static pthread_cond_t  cond = PTHREAD_COND_INITIALIZER;
typedef struct _prodinfo
{
    int num;
    struct _prodinfo *next;
}prod;
struct _prodinfo* head=NULL;

void *thr_produce(void*arg)
{
    while(1)
    {
        prod* pd = malloc(sizeof(struct _prodinfo));
        pd->num=begnum++;
        pthread_mutex_lock(&mut);
        pd->next=head;
        head=pd;
        printf(" -%ld号线程生产%d产品\n",pthread_self(),pd->num);
        pthread_mutex_unlock(&mut);
        pthread_cond_signal(&cond);  
        sleep(rand()%4);
    }
}
void* thr_con(void* arg)
{
    prod* pro=NULL;
    while(1)
    {
        pthread_mutex_lock(&mut);
        while(head==NULL)
            pthread_cond_wait(&cond,&mut);
        pro = head;
        head=head->next;
        printf(" -%ld号线程消费%d产品\n",pthread_self(),pro->num);
        pthread_mutex_unlock(&mut);
        free(pro);
        sleep(rand()%4);
    }
}
int main()
{
    pthread_t cid,pid;
    int err1=pthread_create(&pid,NULL,thr_produce,NULL);
     if(err1)
        {
            fprintf(stderr,"pthread_creat():%s\n",strerror(err1));
            exit(1);
        }
    int err2=pthread_create(&cid,NULL,thr_con,NULL);
      if(err2)
        {
            fprintf(stderr,"pthread_creat():%s\n",strerror(err1));
            exit(1);
        }
    pthread_join(pid,NULL);
    pthread_join(cid,NULL);
}

信号量

介绍以下信号量是进化版的互斥量，允许多个线程访问共享资源与条件变量和互斥量类此的操作，在进程和线程中均可以使用

int sem_init(sem_t *sem, int pshared, unsigned int value);
int sem_destroy(sem_t *sem);
Link with -pthread.

sem为定义的信号量，传出型参数

pshared

0 代表线程信号量
1 代表进程信号量

alue 为定义的信号量个数

    int sem_wait(sem_t *sem);
    int sem_trywait(sem_t *sem);
    int sem_timedwait(sem_t *sem, const struct timespec *abs_timeout);

申请信号量，申请成功value–，当value为0 则阻塞

 int sem_post(sem_t *sem);

释放信号量value++

例信号量实现生产者消费者模型

sem_t pro_sem,con_sem;
#define semcnt 5
int i=0;
int queue[semcnt];
int beginnum = 100;
void *thr_produce(void*arg)
{
    while(1)
    {
        sem_wait(&pro_sem);//生产者申请资源 pro_sem每被占用一次--一次 当为0时则阻塞
        printf("%ld 线程生产了 %d\n",pthread_self(),beginnum);
        queue[(i++)%semcnt]= beginnum++;
        sem_post(&con_sem);//为消费者的信号量释放资源pro_sem每被释放一次++一次
        sleep(rand()%4);
    }
    return NULL;
}
void* thr_con(void* arg)
{   
    int i=0;
    int num=0;
    while(1)
    {
        sem_wait(&con_sem);
        num = queue[(i++)%semcnt];
        printf("%ld 线程消费了 %d\n",pthread_self(),num);
        sem_post(&pro_sem);
        sleep(rand()%3);
    }
    return NULL;
}
int main()
{
    sem_init(&pro_sem,0,semcnt);
    sem_init(&con_sem,0,0); //消费者初始默认没有产品
    pthread_t tid[2];
     int err1=pthread_create(&tid[0],NULL,thr_produce,NULL);
     if(err1)
        {
            fprintf(stderr,"pthread_creat():%s\n",strerror(err1));
            exit(1);
        }
    int err2=pthread_create(&tid[1],NULL,thr_con,NULL);
      if(err2)
        {
            fprintf(stderr,"pthread_creat():%s\n",strerror(err1));
            exit(1);
        }
        pthread_join(tid[0],NULL);
        pthread_join(tid[1],NULL);
    sem_destroy(&pro_sem);
    sem_destroy(&con_sem);
}

读写锁

读写锁与互斥量类似，但是读写锁允许更高的并行性，其特性为：写独占，读共享

读写锁实质上是一把锁，有不同的状态，写锁的优先级高

读写锁的三种状态

读模式下加锁（读锁）
写模式下加锁（写锁）
不加锁状态

读写锁的特性：读锁可以共享读的状态，当读锁加上时，阻塞写锁的加锁

即使读锁加上时后面的写锁依然会被阻塞，当前面读锁释放时才能加成功

pthread_rwlock_t rwlock =PTHREAD_RWLOCK_INITIALIZER;
int beginum=100;
void*thr_Wr(void*arg)
{
    while(1)
    {
        pthread_rwlock_wrlock(&rwlock);
        printf("-写线程--beginum = %d\n",beginum++);
        usleep(2000);//模拟占用时间
        pthread_rwlock_unlock(&rwlock);
        usleep(2000);//简单防止再抢锁的方法但不建议使用
    }
    return NULL;
}
void*thr_ead(void*arg)
{
    while (1)
    {
        pthread_rwlock_rdlock(&rwlock);
      printf("-读读线程--beginum = %d\n",beginum);
        usleep(2000);//模拟占用时间
       pthread_rwlock_unlock(&rwlock);
        usleep(2000);//简单防止再抢锁的方法但不建议使用
    }
    return NULL;
}
int main()
{
    int n=8,i=0;
    pthread_t tid[8];
    for(i = 0; i<5;i++)
    {
        pthread_create(&tid[i],NULL,thr_ead,NULL);
    }
     for(; i<8;i++)
    {
        pthread_create(&tid[i],NULL,thr_Wr,NULL);
    }
     for(i = 0; i<8;i++)
    {
        pthread_join(tid[i],NULL);
    }
   pthread_rwlock_destroy(&rwlock);
}

到此这篇关于C语言细致讲解线程同步的集中方式的文章就介绍到这了,更多相关C语言线程同步内容请搜索编程网以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程网！

点击免费下载>>软考高级考试备考技巧/历年真题/备考精华资料

--结束END--

本文标题: C语言细致讲解线程同步的集中方式

本文链接: https://www.lsjlt.com/news/148285.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

本篇文章演示代码以及资料文档资料下载

下载Word文档到电脑，方便收藏和打印～

下载Word文档

去做题

猜你喜欢

C语言细致讲解线程同步的集中方式

目录互斥锁条件变量信号量读写锁互斥锁使用互斥量完成对临界区的资源的加锁操作，使得同一时刻，对一个共享数据的使用只能又一个线程完成例向屏幕上一次打印abcd四个字母可以使用的是一...

99+

2022-11-13
超详细讲解Linux C++多线程同步的方式

目录一.互斥锁1.互斥锁的初始化2.互斥锁的相关属性及分类3.测试加锁函数二.条件变量1.条件变量的相关函数三.读写锁1）初始化的销毁读写锁2）以写的方式获取锁，以读的方式获取锁，释放读写锁四.信号量1）信号量初始化2）...

99+

2022-06-04

Linux C++多线程同步 Linux C++多线程同步方式
c语言线程同步的方法有哪些

C语言线程同步的方法有以下几种：1. 互斥锁（Mutex）：使用互斥锁可以保证在同一时间只有一个线程能够进入关键代码段。当一个线程获...

99+

2023-10-12

c语言
C语言超详细讲解数据结构中的线性表

目录前言一、分文件编写1、分文件编写概念2、代码展示二、动态分布内存malloc1、初识malloc2、使用方法三、创建链表并进行增删操作1、初始化链表2、在链表中增加数据3、删除链...

99+

2022-11-13
C语言全面细致讲解单双精度float与double的使用方法

目录一、float与double类型介绍二、例题三、总结一、float与double类型介绍代码： #include <stdio.h> int main (void)...

99+

2022-11-13
C语言中程序环境和预处理的详细图文讲解

目录1. 程序的翻译环境和执行环境 2. 详解编译+链接 2.1 翻译环境2.2 编译本身也分为几个阶段2.3 运行环境 3. 预处理详解3.1 预定...

99+

2023-02-16

c语言程序环境和预处理的区别 c语言的编译预处理 c语言程序环境
C++中的多线程同步问题及解决方法

C++中的多线程同步问题及解决方法多线程编程是提高程序性能和效率的一种方式，但同时也带来了一系列的同步问题。在多线程编程中，多个线程可能会同时访问和修改共享的数据资源，这可能导致数据的竞争条件、死锁、饥饿等问题。为了避免这些问题，我们需要使...

99+

2023-10-22

多线程 (Multithreading) 同步 (synchronization) 解决方法 (Solution)
C#中常见的线程同步问题及解决方法

C#中常见的线程同步问题及解决方法引言：在多线程编程中，线程同步是一个关键的概念。当多个线程同时访问共享资源时，会导致数据不一致或出现竞态条件等问题。本文将介绍C#中常见的线程同步问题，并提供相应的解决方法和示例代码。一、不正确的数据共享当...

99+

2023-10-22

线程同步问题 C#中的线程同步
C++中的多线程同步问题和解决方法概述

C++中的多线程同步问题和解决方法概述多线程编程是一种并发编程的方式，有助于提高程序的性能和效率。然而，多线程编程也带来了一系列的挑战和问题，其中最突出的是多线程同步问题。本文将概述C++中的多线程同步问题，并介绍几种常见的解决方法。同时，...

99+

2023-10-22

C++多线程同步多线程问题同步解决方法
通俗易懂讲解C语言与Java中二叉树的三种非递归遍历方式

详解二叉树的三种非递归遍历方式（附C、java源码）前言二叉树的递归遍历方式很简单，三种递归遍历方式的区别，只是printf放的位置不一样而已，这里就不多讲了。把前序遍历代码贴在...

99+

2022-11-12