pthead 互斥锁使用详解

这篇具有很好参考价值的文章主要介绍了pthead 互斥锁使用详解。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

pthread 互斥锁使用

  • 互斥锁:一种简单的线程同步机制,它可以用来保护共享资源,防止多个线程同时修改共享资源而引发竞争条件。

pthread_mutex_init

  • 函数原型:

    int pthread_mutex_init(pthread_mutex_t *mutex, const pthread_mutexattr_t *attr);
    
    • mutex:指向要初始化的互斥锁的指针。
    • attr:一个可选的指向互斥锁属性的指针,用于设置互斥锁的属性,可以为 NULL。
    • 返回值:成功返回 0,失败返回错误代码。
  • 用于初始化一个互斥锁。

  • 使用互斥锁时,应该先初始化再使用,最后再销毁。

pthread_mutex_destroy

  • 函数原型:

    int pthread_mutex_destroy(pthread_mutex_t *mutex);
    
    • mutex:指向要销毁的互斥锁的指针
    • 返回值:成功返回 0,失败返回错误代码。
  • 用于销毁一个互斥锁。

  • 销毁互斥锁之前,要确保没有任何线程正在持有该互斥锁,否则会导致未定义的结果。

pthread_mutex_lock

  • 函数原型:

    int pthread_mutex_lock(pthread_mutex_t *mutex);
    
    • mutex:要获取的互斥锁的指针。
  • 用于获取一个互斥锁。

  • 如果一个线程在获取互斥锁时发现该互斥锁已经被其他线程占用,那么它就会被阻塞,直到该互斥锁被释放为止。

  • 在使用互斥锁时,要确保在临界区内的代码尽可能少,以避免长时间占用互斥锁而导致的性能问题。

pthread_mutex_unlock

  • 函数原型:

    int pthread_mutex_unlock(pthread_mutex_t *mutex);
    
    • mutex:要释放的互斥锁的指针。
  • 用于释放一个互斥锁。

  • 只有成功获取互斥锁的线程才能使用 pthread_mutex_unlock 函数释放该互斥锁。如果一个线程在未获取互斥锁的情况下尝试调用 pthread_mutex_unlock 函数,将会产生未定义的行为。

  • 在释放互斥锁之后,其他等待获取该互斥锁的线程将有机会获取到互斥锁,并进入临界区执行其任务。

示例

  • 以下示例演示了两个线程交替写一个文件:文章来源地址https://www.toymoban.com/news/detail-713101.html

    #include <stdio.h>
    #include <string.h>
    #include <pthread.h>
    
    pthread_mutex_t g_mutex;
    
    void* thread1_func(void* arg)
    {
        FILE *fp = (FILE*)arg;
    
        // 获取互斥锁
        pthread_mutex_lock(&g_mutex);
    
        // 进入临界区,访问共享资源
        char *s = "thread1: hello\n";
        fwrite(s, strlen(s), 1, fp);
    
        // 释放互斥锁
        pthread_mutex_unlock(&g_mutex);
        return NULL;
    }
    
    void* thread2_func(void* arg)
    {
        FILE *fp = (FILE*)arg;
    
        // 获取互斥锁
        pthread_mutex_lock(&g_mutex);
    
        // 进入临界区,访问共享资源
        char *s = "thread2: hello\n";
        fwrite(s, strlen(s), 1, fp);
    
        // 释放互斥锁
        pthread_mutex_unlock(&g_mutex);
        return NULL;
    }
    
    int main()
    {
        // 新建文件
        FILE* fp = fopen("test.txt", "wt");
    
        // 初始化互斥锁
        pthread_mutex_init(&g_mutex, NULL);
    
        // 创建线程
        pthread_t th1;
        pthread_t th2;
        pthread_create(&th1, NULL, thread1_func, fp);
        pthread_create(&th2, NULL, thread2_func, fp);
    
        // 等待线程结束
        pthread_join(th1, NULL);
        pthread_join(th2, NULL);
    
        // 销毁互斥锁
        pthread_mutex_destroy(&g_mutex);
    
        // 关闭文件
        fclose(fp);
        return 0;
    }
    

到了这里,关于pthead 互斥锁使用详解的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • GO语言网络编程(并发编程)Channel

    1.1.1 Channel 单纯地将函数并发执行是没有意义的。函数与函数间需要交换数据才能体现并发执行函数的意义。 虽然可以使用共享内存进行数据交换,但是共享内存在不同的goroutine中容易发生竞态问题。为了保证数据交换的正确性,必须使用互斥量对内存进行加锁,这种做法势

    2024年02月09日
    浏览(64)
  • GO语言网络编程(并发编程)select

    1.1.1 select多路复用 在某些场景下我们需要同时从多个通道接收数据。通道在接收数据时,如果没有数据可以接收将会发生阻塞。你也许会写出如下代码使用遍历的方式来实现: 这种方式虽然可以实现从多个通道接收值的需求,但是运行性能会差很多。为了应对这种场景,G

    2024年02月09日
    浏览(75)
  • GO语言网络编程(并发编程)runtime包

    1.1.1. runtime.Gosched() 让出CPU时间片,重新等待安排任务(大概意思就是本来计划的好好的周末出去烧烤,但是你妈让你去相亲,两种情况第一就是你相亲速度非常快,见面就黄不耽误你继续烧烤,第二种情况就是你相亲速度特别慢,见面就是你侬我侬的,耽误了烧烤,但是还馋就

    2024年02月09日
    浏览(62)
  • 【Linux系统编程:线程】 线程控制 -- 创建、终止、等待、分离 | 线程互斥与同步 | 互斥量与条件变量 | 生产者消费者模型 | 线程池 | STL/智能指针与线程安全 | 读者写者模型

    写在前面 本文重点: 了解线程概念,理解线程与进程区别与联系。 学会线程控制,线程创建,线程终止,线程等待。 了解线程分离与线程安全。 学会线程同步。 学会使用互斥量,条件变量,posix 信号量,以及读写锁。 理解基于读写锁的读者写者问题。 一、线程概念 💦

    2024年02月04日
    浏览(66)
  • Go语言并发编程(千锋教育)

    视频地址:https://www.bilibili.com/video/BV1t541147Bc?p=14 作者B站:https://space.bilibili.com/353694001 源代码:https://github.com/rubyhan1314/go_goroutine 1.1、并发与并行 其实操作系统里对这些概念都有所说明和举例。 并发 并发是指多个任务在同一时间段内交替执行,从外部看似乎是同时执行的。

    2024年02月14日
    浏览(56)
  • Go 语言面试题(三):并发编程

    对于无缓冲的 channel,发送方将阻塞该信道,直到接收方从该信道接收到数据为止,而接收方也将阻塞该信道,直到发送方将数据发送到该信道中为止。 对于有缓存的 channel,发送方在没有空插槽(缓冲区使用完)的情况下阻塞,而接收方在信道为空的情况下阻塞。 例如: 协

    2024年02月08日
    浏览(48)
  • C++11互斥量mutex使用详解

    mutex又称互斥量,C++ 11中与 mutex相关的类(包括锁类型)和函数都声明在#include头文件中,所以如果你需要使用 std::mutex,就必须包含#include头文件。 C++11提供如下4种语义的互斥量(mutex) : std::mutex,独占的互斥量,不能递归使用。 std::time_mutex,带超时的独占互斥量,不能递

    2024年02月16日
    浏览(35)
  • 【并发编程篇】详解Forkjoin

    Fork/Join 是一种在多线程领域中常用的算法或技术, 它的核心思想是将大任务分割成若干个小任务,然后将这些小任务分配给多个线程并行处理,最终将结果合并起来 。这种思想可以应用于多种场景,例如图像处理、批处理、并行排序等。 在 Java 中,Fork/Join 这种思想被封装

    2024年01月17日
    浏览(75)
  • Golang 并发编程详解

    并发是现代软件开发中的一个重要概念,它允许程序同时执行多个任务,提高系统的性能和响应能力。Golang 是一门天生支持并发的语言,它通过 goroutine 和 channel 提供了强大的并发编程支持。 在本文中,我们将深入探讨 Golang 中的并发编程,了解 goroutine、channel 以及一些常见

    2024年01月23日
    浏览(43)
  • C++多线程编程(第三章 案例1,使用互斥锁+ list模拟线程通信)

    主线程和子线程进行list通信,要用到互斥锁,避免同时操作 1、封装线程基类XThread控制线程启动和停止; 2、模拟消息服务器线程,接收字符串消息,并模拟处理; 3、通过Unique_lock和mutex互斥方位list 消息队列 4、主线程定时发送消息给子线程; 代码包含了XThread类(基类)、

    2024年02月15日
    浏览(35)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包