首页 > 系统相关 >IO进程练习:请在linux 利用c语言编程实现两个线程按照顺序依次输出”ABABABAB......“

IO进程练习:请在linux 利用c语言编程实现两个线程按照顺序依次输出”ABABABAB......“

时间:2024-08-31 09:52:47浏览次数:6  
标签:ABABABAB ...... 线程 pthread cond NULL sem1 sem0

例如:a线程输出”A”之后b线程输出”B”,然后a线程输出“A”,再b线程输出”B”,之后往复循环。

【1】使用信号量实现

代码展示:

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

// 定义两个全局信号量,实现同步机制
sem_t sem0;
sem_t sem1;

void *handler_thread(void *arg)
{
    while (1)
    {
        // 由于 sem0 初值为 0,所以B线程刚开始申请不到资源,不会打印,等到A线程执行完释放 sem0 资源之后才能获得 sem0 资源
        sem_wait(&sem0); // P操作(申请资源), sem0--
        printf("B");     // 打印 B
        fflush(NULL);    // 强制刷新缓存区,不刷新缓存,B 将无法输出
        sleep(1);        // 睡眠 1 秒,实现B 输出后停顿 1 秒再释放 sem1 资源,A线程才能执行输出 A
        sem_post(&sem1); // V操作(释放资源) sem1++
    }
}

int main(int argc, char const *argv[])
{
    pthread_t tid;                  // 线程标识
    if (sem_init(&sem0, 0, 0) != 0) // 初始化信号量 sem0 初值为 0
    {
        perror("sem init 0 err");
        return -1;
    }

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

    if (pthread_create(&tid, NULL, handler_thread, NULL) != 0) // 创建一个新的线程 handler_thread
    {
        perror("pthread err");
        return -1;
    }

    while (1)
    {
        // 因为我们要先打印 A 所以要让打印 A 的线程(A线程)刚开始就可以获得资源并执行
        // 所以让A线程申请 sem1 资源,sem1 初值为 1,可以直接申请资源成功,sem1--
        sem_wait(&sem1); // P 操作(申请资源),sem1--,需要等待B线程释放资源后才能再次获得资源
        printf("A");     // 打印 A
        fflush(NULL);    // 强制刷新缓存区,不刷新缓存,A 将无法输出
        sleep(1);        // 睡眠 1 秒,实现A 输出后停顿 1 秒再输出 B
        // A 线程执行完之后,接下来需要执行 B 线程,但B 进程由于申请不到 sem0 资源而阻塞,所以A 线程执行完之后要释放 sem0 资源
        sem_post(&sem0); // V操作(释放资源),sem0++
    }

    return 0;
}

运行结果:

【2】使用条件变量实现

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

代码展示:

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

pthread_mutex_t lock; // 互斥锁
pthread_cond_t cond;  // 条件变量

void *handler_A(void *arg) // A线程
{
    while (1)
    {
        sleep(1);                   // A 线程先睡眠 1 秒,目的是让 B 线程中的 条件等待语句先执行 pthread_cond_wait(&cond,&lock)
        pthread_mutex_lock(&lock);  // A 线程获得互斥锁,上锁
        printf("A");                // 打印 A
        fflush(NULL);               // 强制刷新缓存
        sleep(1);//睡眠 1 秒之后再产生条件,以实现间隔输出
        pthread_cond_signal(&cond); // 产生条件,不阻塞
        pthread_mutex_unlock(&lock);//解锁
    }

    return NULL;
}

void *handler_B(void *arg) // B线程
{
    while (1)
    {
        pthread_mutex_lock(&lock);//获得互斥锁,上锁
        pthread_cond_wait(&cond, &lock); // 阻塞,解锁,等待条件产生
        printf("B");//打印 B
        fflush(NULL);//强制刷新缓存区
        pthread_mutex_unlock(&lock);//开锁
    }

    return NULL;
}

int main(int argc, char const *argv[])
{
    pthread_t tid1, tid2; // 两个线程标识

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

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

    if (pthread_create(&tid1, NULL, handler_A, NULL) != 0) // 创建A线程
    {
        perror("phtread err");
        return -1;
    }

    if (pthread_create(&tid2, NULL, handler_B, NULL) != 0) // 创建B线程
    {
        perror("phtread err");
        return -1;
    }

    // 如果不加下面这两句,主线程main 会直接结束,return 0,两个从线程根本就不会执行,所以要阻塞,等待两个线程结束后,再结束主线程 main
    pthread_join(tid1, NULL); // 阻塞,等待指定的线程结束然后给其回收资源
    pthread_join(tid2, NULL); // 阻塞,等待指定的线程结束然后给其回收资源
    return 0;
}

运行结果:


今天的分享就到这里结束啦,如果有哪里写的不好的地方,请指正。
如果觉得不错并且对你有帮助的话点个关注支持一下吧!

标签:ABABABAB,......,线程,pthread,cond,NULL,sem1,sem0
From: https://blog.csdn.net/dghbs/article/details/141739657

相关文章

  • 线程(函数接口、同步、互斥、条件变量)
    线程Thread1.什么是线程1.1概念线程是一个轻量级的进程,为了提高系统的性能引入线程。线程和进程是参与统一的调度。在同一个进程中可以创建的多个线程,共享进程资源。(Linux里同样用task_struct来描述一个线程)1.2进程和线程区别相同点:都为系统提供了并发执行的......
  • Redis多线程特性
    Redis6.0版本之前是用单线程模型,6.0版本为什么使用多线程?Redis几乎不存在CPU成为性能瓶颈的情况,主要受限于内存和网络IO内存优化内存淘汰策略增加内存硬件网络IO优化Redis在处理客户端的请求时,包括获取(socket读)、解析、执行、内容返回(socket写)等都由一个顺序串......
  • 程序员金九银十面试宝典(持续更新中................)
    大家好,我是一位老程序员,分享大家的一路关注的,很久没有更新了,今年大家都很不容易,这里有一份多年来整理的一份Java,大模型,项目管理,Mac软件等各类学习资料及面试题,无论你刚入行的程序员,还是经验丰富IT人士,希望这些资料能帮到你。让我们乘风破浪,顺利拿到理想offer!其它资料在陆陆续续......
  • 服务重启了,如何保证线程池中的数据不丢失?
    大家好,我是苏三,又跟大家见面了。前言最近有位小伙伴在我的技术群里,问了我一个问题:服务down机了,线程池中如何保证不丢失数据?这个问题挺有意思的,今天通过这篇文章,拿出来跟大家一起探讨一下。1什么是线程池?之前没有线程池的时候,我们在代码中,创建一个线程有两种方式:继承Thread......
  • 服务重启了,如何保证线程池中的数据不丢失?
    大家好,我是苏三,又跟大家见面了。前言最近有位小伙伴在我的技术群里,问了我一个问题:服务down机了,线程池中如何保证不丢失数据?这个问题挺有意思的,今天通过这篇文章,拿出来跟大家一起探讨一下。1什么是线程池?之前没有线程池的时候,我们在代码中,创建一个线程有两种方式:继承Threa......
  • day07(IO进程)线程 Thread
    目录一.什么是线程1. 概念2. 进程和线程区别3.线程资源二.函数接口1.创建线程:pthread_create2. 退出线程:pthread_exit3.回收线程资源 pthread_join练习:输入输出,quit结束三.同步1.概念2.同步机制3. 函数接口练习:用信号量实现输入输出quit结束......
  • 单线程Redis:Redis为什么这么快
    1Redis是不是单线程Redis使用后台线程执行耗时的I/O操作,以免阻塞主线程bio_close_file:后台I/O线程之一,异步关闭文件bio_aof_fsync:后台I/O线程之一,异步地将AOF(AppendOnlyFile)日志同步到磁盘bio_lazy_free:异步释放内存,有些内存释放操作可能比较耗时,因此这些操......
  • io进程----线程
    目录一丶概念二丶进程和线程的区别三丶资源四丶函数接口1.创建线程 pthread_create2.退出线程pthread_exit3.获取线程IDp_threadself​编辑4.回收线程资源五丶线程同步5.1概念5.2信号量5.3信号量的分类5.4函数接口1.初始化信号量2.申请资源3.释放资源......
  • 创建订单使用多线程处理
    创建订单使用多线程异步处理,快速响应创单请求订单创建结果放入Redis里面就结束,获取订单结果走新接口从Redis里面取/***订单创建*/@Component@ConfigurationProperties(prefix="spring.create-order.thread-pool")publicclassCreateOrderimplementsSerializable,......
  • 线程池ThreadPool, C++
    一、为什么要有线程池?线程池是一种用于管理和复用线程的机制。它可以提高程序的性能和效率,特别是在处理大量并发任务时。线程池中包含一定数量的线程,这些线程可以重复执行多个任务。当有任务需要执行时,可以将任务提交给线程池,线程池会选择一个可用的线程来执行任务。任务执行完......